add quellcodeHEADmaster

Signed-off-by: Manuel Traut <manut@mecka.net>

1 files changed, 67 insertions, 0 deletions

diff --git a/quellcode/versuch4/Receiver.cpp b/quellcode/versuch4/Receiver.cpp
new file mode 100755
index 0000000..5a0b880
--- /dev/null
+++ b/quellcode/versuch4/Receiver.cpp
@@ -0,0 +1,67 @@
+#include <iostream>
+
+#include "bench_i.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, 20);
+
+	// 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;
+}
+