summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorwolff1 <wolff1@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2008-12-13 00:01:49 +0000
committerwolff1 <wolff1@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2008-12-13 00:01:49 +0000
commit04ef325205f9bf0b6df93132cfcda7f63b9925a7 (patch)
tree8bb6e4b0c96ca86d6ff02308d44cf12e39b295bc
parent7cbe7a1028c14148a8a6ae34c95a517bc15826d4 (diff)
downloadATCD-04ef325205f9bf0b6df93132cfcda7f63b9925a7.tar.gz
ChangeLogTag: Sat Dec 13 00:01:24 UTC 2008 Friedhelm Wolf <fwolf@dre.vanderbilt.edu>
-rw-r--r--CIAO/ChangeLog6
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp43
2 files changed, 18 insertions, 31 deletions
diff --git a/CIAO/ChangeLog b/CIAO/ChangeLog
index b652de875e1..3a95e0d8ab9 100644
--- a/CIAO/ChangeLog
+++ b/CIAO/ChangeLog
@@ -1,3 +1,9 @@
+Sat Dec 13 00:01:24 UTC 2008 Friedhelm Wolf <fwolf@dre.vanderbilt.edu>
+
+ * ciao/FTComponentServer/CIAO_FTComponentServer.cpp:
+
+ Adopted the newest LWFT capabilities.
+
Fri Dec 12 23:31:02 UTC 2008 Friedhelm Wolf <fwolf@dre.vanderbilt.edu>
* DAnCE/NodeManager/Node_Manager_Module.cpp:
diff --git a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp b/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp
index 11b62b85c2c..896b28672eb 100644
--- a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp
+++ b/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp
@@ -31,9 +31,10 @@
#include "Configurator_Factory.h"
#include "Configurators/Server_Configurator.h"
#include "StateSynchronizationAgent_i.h"
-#include "ServerORBInitializer.h"
-#include "AppMonitor/AppSideReg.h"
-#include "ReplicationManagerC.h"
+#include "orbsvcs/orbsvcs/LWFT/LWFT_Server_Init.h"
+#include "orbsvcs/orbsvcs/LWFT/LWFT_Client_Init.h"
+#include "orbsvcs/orbsvcs/LWFT/AppOptions.h"
+#include "orbsvcs/orbsvcs/LWFT/ReplicationManagerC.h"
#ifdef CIAO_BUILD_COMPONENTSERVER_EXE
@@ -115,22 +116,16 @@ namespace CIAO
"Error configuring ComponentServer configurator, exiting.\n"));
throw Error ("Unable to load ComponentServer configurator.");
}
-
- this->configurator_->pre_orb_initialize ();
-
- // register FT ORB Initializer
- PortableInterceptor::ORBInitializer_ptr tmp;
-
- ACE_NEW_NORETURN (tmp,
- ServerORBInitializer); // No CORBA exceptions yet!
- PortableInterceptor::ORBInitializer_var orb_initializer = tmp;
+ AppOptions::instance ()->parse_args (argc, argv);
+
+ this->configurator_->pre_orb_initialize ();
- PortableInterceptor::register_orb_initializer (orb_initializer.in ());
+ LWFT_Client_Init initializer;
CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_ComponentServer_Task::CIAO_ComponentServer_Task - "
"Creating ORB\n"));
- this->orb_ = CORBA::ORB_init (argc, argv);
+ this->orb_ = initializer.init (argc, argv);
this->configurator_->post_orb_initialize (this->orb_.in ());
@@ -165,20 +160,6 @@ namespace CIAO
poa_manager->activate ();
CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "Activating AppMonitor_Thread.\n"));
-
- ACE_Barrier thread_barrier (2);
- AppSideReg proc_reg (&thread_barrier, orb_.in());
-
- if (proc_reg.activate () != 0)
- {
- CIAO_ERROR ((LM_ERROR, "AppSideReg::activate () failed.\n"));
- }
-
- // ACE_DEBUG ((LM_TRACE, ACE_TEXT ("AppSideReg activated.\n")));
- thread_barrier.wait();
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
"Creating state synchronization servant\n"));
// start up SSA
@@ -200,13 +181,13 @@ namespace CIAO
// activate servant here
StateSynchronizationAgent_var ssa (ssa_servant->_this ());
- Name_Helper_T <StateSynchronizationAgent> nsh (orb_, true);
+ Name_Helper_T <StateSynchronizationAgent> nsh (orb_);
nsh.bind (this->get_obj_path () + "/StateSynchronizationAgent", ssa.in ());
// register ssa with the replication manager
- Name_Helper_T <ReplicationManager> rmh (orb_.in (), true);
+ Name_Helper_T <ReplicationManager> rmh (orb_.in ());
- ReplicationManager_var rm = rmh.resolve ("FLARe/ReplicationManager");
+ ReplicationManager_var rm = rmh.resolve ("ReplicationManager");
rm->register_state_synchronization_agent (this->get_hostname ().c_str (),
this->get_process_id ().c_str (),