From 1adba473e6917b227e1b0a1118148101dca202e7 Mon Sep 17 00:00:00 2001
From: Manuel Traut <manut@mecka.net>
Date: Mon, 31 Mar 2014 16:53:55 +0200
Subject: add quellcode

Signed-off-by: Manuel Traut <manut@mecka.net>
---
 quellcode/versuch5/Server.cpp | 143 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 143 insertions(+)
 create mode 100755 quellcode/versuch5/Server.cpp

(limited to 'quellcode/versuch5/Server.cpp')

diff --git a/quellcode/versuch5/Server.cpp b/quellcode/versuch5/Server.cpp
new file mode 100755
index 0000000..94afb5c
--- /dev/null
+++ b/quellcode/versuch5/Server.cpp
@@ -0,0 +1,143 @@
+#include <iostream>
+
+#include "bench_i.h"
+
+#include "orbsvcs/CosNamingC.h"
+#include <tao/RTCORBA/RTCORBA.h>
+#include "tao/RTCORBA/Network_Priority_Mapping_Manager.h"
+#include "tao/RTCORBA/Network_Priority_Mapping.h"
+#include "Custom_Network_Priority_Mapping.h"
+
+RTCORBA::Priority corbaPriority = RTCORBA::minPriority;
+
+int main(int argc, char* argv[]){
+
+	struct sched_param schedparam; 
+	schedparam.sched_priority = 99;
+
+	if (sched_setscheduler(0, SCHED_FIFO, &schedparam) != 0) { 
+	  fprintf(stderr, "%s: PID %d: sched_setscheduler() failed errno = %d\n", __FUNCTION__, getpid(), errno); 
+	}
+
+    try{
+    // initialize ORB
+	CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "ServerORB");
+	std::cout<<"ORB initialized"<<std::endl;
+
+	// Network priority mapping
+	CORBA::Object_var netmapper = orb->resolve_initial_references("NetworkPriorityMappingManager");
+	RTCORBA::NetworkPriorityMappingManager_var mappingManager = RTCORBA::NetworkPriorityMappingManager::_narrow( netmapper.in() );
+
+    Custom_Network_Priority_Mapping *cnpm;
+	cnpm = new Custom_Network_Priority_Mapping();
+
+    cnpm->corba_priority(corbaPriority);
+    mappingManager->mapping(cnpm);
+	
+	// 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;
+	
+    // Set transport protocol properties
+    RTCORBA::TCPProtocolProperties_var tcpProperties = rtORB->create_tcp_protocol_properties (ACE_DEFAULT_MAX_SOCKET_BUFSIZ, ACE_DEFAULT_MAX_SOCKET_BUFSIZ, 1, 0, 1, 1 /*enable netw. priority*/);
+
+    RTCORBA::ProtocolList protocols;
+    protocols.length (1);
+    protocols[0].protocol_type = 0;
+    protocols[0].transport_protocol_properties = RTCORBA::ProtocolProperties::_duplicate (tcpProperties.in ());
+    protocols[0].orb_protocol_properties = RTCORBA::ProtocolProperties::_nil ();
+
+	// obtain rootPOA
+	CORBA::Object_var poa = orb->resolve_initial_references("RootPOA");
+	PortableServer::POA_var rootPOA = PortableServer::POA::_narrow(poa.in());
+
+	// NameService
+	CORBA::Object_var  namingObject = orb->resolve_initial_references("NameService");
+	CosNaming::NamingContext_var namingContext = CosNaming::NamingContext::_narrow(namingObject.in());
+
+	// activate POA Manager
+	PortableServer::POAManager_var poaManager = rootPOA->the_POAManager();
+	poaManager->activate();
+	std::cout<<"rootPOA OK"<<std::endl;
+
+	// create 2 lanes (message and port)
+	CORBA::ULong TOTAL_LANES = 2;
+	RTCORBA::ThreadpoolLanes lanes(TOTAL_LANES);
+	lanes.length(TOTAL_LANES);
+
+	// message lane
+	lanes[0].static_threads = 1;
+	lanes[0].dynamic_threads = 1;
+	lanes[0].lane_priority = 0;
+
+	// port lane
+	lanes[1].static_threads = 1;
+	lanes[1].dynamic_threads = 1;
+	lanes[1].lane_priority = RTCORBA::maxPriority;
+
+	// create threadpool
+	RTCORBA::ThreadpoolId threadpool_id = rtORB->create_threadpool_with_lanes(0 /*Stacksize*/, lanes, 0 /*borrowing*/, 0 /*buffering*/, 0 /*maxBuf*/, 0 /*maxBufSize*/);
+
+	// create Policy
+	CORBA::PolicyList benchPolicy(3);
+	benchPolicy.length(3);
+	benchPolicy[0] = rtORB->create_priority_model_policy(RTCORBA::CLIENT_PROPAGATED, 0 /*default priority*/);
+	benchPolicy[1] = rtORB->create_threadpool_policy(threadpool_id);
+	benchPolicy[2] = rtORB->create_server_protocol_policy (protocols);
+
+	// create ObjectAdapters, assign Policy
+	PortableServer::POA_var msgAndPort1POA = rootPOA->create_POA("msgAndPort1POA", poaManager.in(), benchPolicy);
+	PortableServer::POA_var msgAndPort2POA = rootPOA->create_POA("msgAndPort2POA", poaManager.in(), benchPolicy);
+	PortableServer::POA_var msgOnlyPOA = rootPOA->create_POA("msgOnlyPOA", poaManager.in(), benchPolicy);
+
+	// benchPolicy[0] = rtORB->create_priority_model_policy(RTCORBA::CLIENT_PROPAGATED, 0 /*default priority*/);
+
+	PortableServer::POA_var portOnlyPOA = rootPOA->create_POA("portOnlyPOA", poaManager.in(), benchPolicy);
+	std::cout<<"POAs created, Policies assigned"<<std::endl;
+
+	// create the servants
+	benchmark_msgAndPort1_i msgAndPort1_i(orb);
+	benchmark_msgAndPort2_i msgAndPort2_i(orb);
+	benchmark_msgOnly_i msgOnly_i(orb);
+	benchmark_setPortsOnly_i portOnly_i(orb);
+
+	// activate servants
+	CosNaming::Name name(1);
+	name.length(1);
+
+	PortableServer::ObjectId_var objectID = msgAndPort1POA->activate_object(&msgAndPort1_i);
+	CORBA::Object_var benchObj = msgAndPort1POA->id_to_reference(objectID.in());
+	name[0].id = CORBA::string_dup("msgAndPort1");
+	namingContext->bind(name, benchObj.in());
+
+	objectID = msgAndPort2POA->activate_object(&msgAndPort2_i);
+	benchObj = msgAndPort2POA->id_to_reference(objectID.in());
+	name[0].id = CORBA::string_dup("msgAndPort2");
+	namingContext->bind(name, benchObj.in());
+
+	objectID = msgOnlyPOA->activate_object(&msgOnly_i);
+	benchObj = msgOnlyPOA->id_to_reference(objectID.in());
+	name[0].id = CORBA::string_dup("msgOnly");
+	namingContext->bind(name, benchObj.in());
+
+	objectID = portOnlyPOA->activate_object(&portOnly_i);
+	benchObj = portOnlyPOA->id_to_reference(objectID.in());
+	name[0].id = CORBA::string_dup("portOnly");
+	namingContext->bind(name, benchObj.in());
+
+	std::cout<<"Servants activated"<<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;
+}
+
-- 
cgit v1.2.3