/**
 *
 * \file    Receiver.cpp
 * \brief   RTCORBA Server, holding one Object for setting digital Output
 *
 * \author  Manuel Traut
 * \version 2006-10-15
 *
 */

#include <iostream>

#include "benchI.h"

#include "orbsvcs/CosNamingC.h"
#include <tao/RTCORBA/RTCORBA.h>

int main(int argc, char* argv[]){
    try{
        // initialize ORB
		CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "ServerORB");
		std::cout<<"ORB initialized"<<std::endl;
	
		// access RT Extensions
		CORBA::Object_var rtorb = orb->resolve_initial_references("RTORB");
		RTCORBA::RTORB_var rtORB = RTCORBA::RTORB::_narrow(rtorb);
		std::cout<<"RT Extensions OK"<<std::endl;
	
		// obtain rootPOA
		CORBA::Object_var poa = orb->resolve_initial_references("RootPOA");
		PortableServer::POA_var rootPOA = PortableServer::POA::_narrow(poa.in());
	
		// activate POA Manager
		PortableServer::POAManager_var poaManager = rootPOA->the_POAManager();
		poaManager->activate();
		std::cout<<"rootPOA OK"<<std::endl;
	
		// create Policy
		CORBA::PolicyList benchPolicy(1);
		benchPolicy.length(1);
		benchPolicy[0] = rtORB->create_priority_model_policy(RTCORBA::CLIENT_PROPAGATED, RTCORBA::maxPriority);

		// create ObjectAdapter, assign Policy
		PortableServer::POA_var benchPOA = rootPOA->create_POA("benchPOA", poaManager.in(), benchPolicy);
		std::cout<<"Policy assigned"<<std::endl;

		// create the servant
		benchmark_Put_i bench_i;

		// activate servant
		PortableServer::ObjectId_var objectID = benchPOA->activate_object(&bench_i);
		CORBA::Object_var benchObj = benchPOA->id_to_reference(objectID.in());
		CORBA::String_var ior = orb->object_to_string(benchObj.in());
		std::cout<<"Servant activated"<<std::endl;

		// NameService
		CORBA::Object_var  namingObject = orb->resolve_initial_references("NameService");
		CosNaming::NamingContext_var namingContext = CosNaming::NamingContext::_narrow(namingObject.in());
		CosNaming::Name name(1);
		name.length(1);
		name[0].id = CORBA::string_dup("Receiver");
		namingContext->bind(name, benchObj.in());
		std::cout<<"Bound Receiver to NameService"<<std::endl;

		// start ORB
		orb->run();
		std::cout<<"ORB ready"<<std::endl;

		//destroy
		rootPOA->destroy(1,1);
		orb->destroy();
    }catch(CORBA::Exception &any){
    	std::cout<<"Exception: "<<any<<std::endl;
    }
    return 0;
}