summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authoraky <aky@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2011-06-29 19:20:24 +0000
committeraky <aky@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2011-06-29 19:20:24 +0000
commitbb397f18a2ce5b3fe6d2b00f636f4a3dedb39031 (patch)
treeb5de6290f1a6bde17bd3561e81d403d53b029cc4
parentf88445c51aa625a71b609d3773a245e62943d9c4 (diff)
downloadATCD-bb397f18a2ce5b3fe6d2b00f636f4a3dedb39031.tar.gz
Wed Jun 29 19:19:02 UTC 2011 Akshay V. Dabholkar <aky@dre.vanderbilt.edu>
-rw-r--r--CIAO/ChangeLog77
-rw-r--r--CIAO/MPC/config/ccm_generic_stub.mpb7
-rw-r--r--CIAO/MPC/config/ciao_generic_container.mpb9
-rw-r--r--CIAO/MPC/config/ciao_generic_container_stub.mpb7
-rw-r--r--CIAO/ciao/Containers/Generic/ClientContainerInterceptorRegistration_Impl.h4
-rw-r--r--CIAO/ciao/Containers/Generic/Generic_Container.h2
-rw-r--r--CIAO/ciao/Containers/Generic/Generic_Container.idl61
-rw-r--r--CIAO/ciao/Containers/Generic/Generic_Container.mpc4
-rw-r--r--CIAO/ciao/Containers/Generic/Generic_Container_export.h78
-rw-r--r--CIAO/ciao/Containers/Generic/Generic_Container_stub_export.h78
-rw-r--r--CIAO/ciao/Containers/Generic/ServantContainerInterceptorRegistration_Impl.h4
-rw-r--r--CIAO/ciao/Containers/Generic/ServerContainerInterceptorRegistration_Impl.h4
-rw-r--r--CIAO/ciao/Containers/Generic/StubContainerInterceptorRegistration_Impl.h4
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_CS_Client.idl35
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_CS_Client_svnt_export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.cpp120
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.h76
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_ComponentServer.idl68
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_ComponentServer.mpc94
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_Container_Impl.cpp460
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_Container_Impl.h115
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp590
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.h78
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_Impl.cpp269
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_Impl.h78
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_stub_export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_svnt_export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_Properties.idl29
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_ServerActivator_Impl.cpp530
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_ServerActivator_Impl.h194
-rw-r--r--CIAO/ciao/FTComponentServer/CIAO_ServerResources.idl268
-rw-r--r--CIAO/ciao/FTComponentServer/Configurator_Factory.cpp49
-rw-r--r--CIAO/ciao/FTComponentServer/Configurator_Factory.h39
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.cpp240
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.h79
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.inl12
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager_export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Basic_Configurator_export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/ComponentServer_Configurator_export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Config_Manager.cpp11
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Config_Manager.h53
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Configurators.mpc21
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/NA_Configurator_Export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/NoOp/CIAO_FT_NoOp_Configurator.vcproj402
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/NoOp/FT_NoOp_Configurator.mpc12
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.cpp46
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.h66
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator_export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.cpp513
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.h138
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.inl8
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/RT/RTNA_Configurator_Export.h58
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.cpp108
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.h78
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Server_Configurator.cpp334
-rw-r--r--CIAO/ciao/FTComponentServer/Configurators/Server_Configurator.h125
-rw-r--r--CIAO/ciao/FTComponentServer/Name_Helper_T.h196
57 files changed, 116 insertions, 6279 deletions
diff --git a/CIAO/ChangeLog b/CIAO/ChangeLog
index 4e93fd9a915..05b806cd125 100644
--- a/CIAO/ChangeLog
+++ b/CIAO/ChangeLog
@@ -1,3 +1,80 @@
+Wed Jun 29 19:19:02 UTC 2011 Akshay V. Dabholkar <aky@dre.vanderbilt.edu>
+
+ * MPC/config/ccm_generic_stub.mpb:
+ * MPC/config/ciao_generic_container.mpb:
+ * MPC/config/ciao_generic_container_stub.mpb:
+
+ * ciao/Containers/Generic/ClientContainerInterceptorRegistration_Impl.h:
+ * ciao/Containers/Generic/Generic_Container.h:
+ * ciao/Containers/Generic/Generic_Container.idl:
+ * ciao/Containers/Generic/Generic_Container.mpc:
+ * ciao/Containers/Generic/ServantContainerInterceptorRegistration_Impl.h:
+ * ciao/Containers/Generic/ServerContainerInterceptorRegistration_Impl.h:
+ * ciao/Containers/Generic/StubContainerInterceptorRegistration_Impl.h:
+
+ * ciao/Containers/Generic/Generic_Container_export.h:
+ * ciao/Containers/Generic/Generic_Container_stub_export.h:
+
+ Trying to fix compilation issues.
+
+ * ciao/FTComponentServer:
+
+ * ciao/FTComponentServer/CIAO_CS_Client.idl:
+ * ciao/FTComponentServer/CIAO_CS_Client_svnt_export.h:
+ * ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.h:
+ * ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.cpp:
+ * ciao/FTComponentServer/CIAO_ComponentServer.idl:
+ * ciao/FTComponentServer/CIAO_ComponentServer.mpc:
+ * ciao/FTComponentServer/CIAO_Container_Impl.h:
+ * ciao/FTComponentServer/CIAO_Container_Impl.cpp:
+ * ciao/FTComponentServer/CIAO_FTComponentServer.h:
+ * ciao/FTComponentServer/CIAO_FTComponentServer.cpp:
+ * ciao/FTComponentServer/CIAO_FTComponentServer_Impl.h:
+ * ciao/FTComponentServer/CIAO_FTComponentServer_Impl.cpp:
+ * ciao/FTComponentServer/CIAO_FTComponentServer_stub_export.h:
+ * ciao/FTComponentServer/CIAO_FTComponentServer_svnt_export.h:
+ * ciao/FTComponentServer/CIAO_Properties.idl:
+ * ciao/FTComponentServer/CIAO_ServerActivator_Impl.h:
+ * ciao/FTComponentServer/CIAO_ServerActivator_Impl.cpp:
+ * ciao/FTComponentServer/CIAO_ServerResources.idl:
+ * ciao/FTComponentServer/Configurator_Factory.h:
+ * ciao/FTComponentServer/Configurator_Factory.cpp:
+ * ciao/FTComponentServer/Configurators:
+
+ * ciao/FTComponentServer/Configurators/Basic_Config_Manager.h:
+ * ciao/FTComponentServer/Configurators/Basic_Config_Manager.inl:
+ * ciao/FTComponentServer/Configurators/Basic_Config_Manager.cpp:
+ * ciao/FTComponentServer/Configurators/Basic_Config_Manager_export.h:
+ * ciao/FTComponentServer/Configurators/Basic_Configurator_export.h:
+ * ciao/FTComponentServer/Configurators/ComponentServer_Configurator_export.h:
+ * ciao/FTComponentServer/Configurators/Config_Manager.h:
+ * ciao/FTComponentServer/Configurators/Config_Manager.cpp:
+ * ciao/FTComponentServer/Configurators/Configurators.mpc:
+ * ciao/FTComponentServer/Configurators/NA_Configurator_Export.h:
+ * ciao/FTComponentServer/Configurators/NoOp:
+
+ * ciao/FTComponentServer/Configurators/NoOp/CIAO_FT_NoOp_Configurator.vcproj:
+ * ciao/FTComponentServer/Configurators/NoOp/FT_NoOp_Configurator.mpc:
+ * ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.h:
+ * ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.cpp:
+ * ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator_export.h:
+
+ * ciao/FTComponentServer/Configurators/RT:
+
+ * ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.h:
+ * ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.inl:
+ * ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.cpp:
+ * ciao/FTComponentServer/Configurators/RT/RTNA_Configurator_Export.h:
+
+ * ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.h:
+ * ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.cpp:
+ * ciao/FTComponentServer/Configurators/Server_Configurator.h:
+ * ciao/FTComponentServer/Configurators/Server_Configurator.cpp:
+
+ * ciao/FTComponentServer/Name_Helper_T.h:
+
+ Removed these files.
+
Wed Jun 22 18:36:14 UTC 2011 Akshay V. Dabholkar <aky@dre.vanderbilt.edu>
* ciao/Containers/Generic:
diff --git a/CIAO/MPC/config/ccm_generic_stub.mpb b/CIAO/MPC/config/ccm_generic_stub.mpb
new file mode 100644
index 00000000000..08ebb3deb5d
--- /dev/null
+++ b/CIAO/MPC/config/ccm_generic_stub.mpb
@@ -0,0 +1,7 @@
+// -*- MPC -*-
+// $Id$
+
+project : ccm_stub {
+ after += CCM_lem_stub CCM_extension_stub
+ libs += CCM_lem_stub CCM_extension_stub
+}
diff --git a/CIAO/MPC/config/ciao_generic_container.mpb b/CIAO/MPC/config/ciao_generic_container.mpb
new file mode 100644
index 00000000000..9deacd8a8b0
--- /dev/null
+++ b/CIAO/MPC/config/ciao_generic_container.mpb
@@ -0,0 +1,9 @@
+// -*- MPC -*-
+// $Id$
+
+project : utils, ciao_servant, \
+ ciao_port_activator_stub, ciao_servant_activator_stub, \
+ ciao_extension_container_stub {
+ libs += CIAO_Extension_Container
+ after += CIAO_Extension_Container
+}
diff --git a/CIAO/MPC/config/ciao_generic_container_stub.mpb b/CIAO/MPC/config/ciao_generic_container_stub.mpb
new file mode 100644
index 00000000000..28b1fa64649
--- /dev/null
+++ b/CIAO/MPC/config/ciao_generic_container_stub.mpb
@@ -0,0 +1,7 @@
+// -*- MPC -*-
+// $Id$
+
+project : ciao_port_activator_stub, ciao_servant_activator_stub, ciao_container_base_stub {
+ libs += CIAO_Extension_Container_stub
+ after += CIAO_Extension_Container_stub
+}
diff --git a/CIAO/ciao/Containers/Generic/ClientContainerInterceptorRegistration_Impl.h b/CIAO/ciao/Containers/Generic/ClientContainerInterceptorRegistration_Impl.h
index 2b2531e9139..3a952337f6e 100644
--- a/CIAO/ciao/Containers/Generic/ClientContainerInterceptorRegistration_Impl.h
+++ b/CIAO/ciao/Containers/Generic/ClientContainerInterceptorRegistration_Impl.h
@@ -12,8 +12,8 @@
#include "ciao/Containers/Generic/Generic_Container_export.h"
-#include "ccm/Extension/CCM_ClientContainerInterceptorC.h"
-#include "ccm/Extension/CCM_ClientContainerInterceptorRegistrationC.h"
+#include "ccm/Generic/CCM_ClientContainerInterceptorC.h"
+#include "ccm/Generic/CCM_ClientContainerInterceptorRegistrationC.h"
#include "ciao/Containers/Generic/Interceptor_Registration_T.h"
namespace CIAO
diff --git a/CIAO/ciao/Containers/Generic/Generic_Container.h b/CIAO/ciao/Containers/Generic/Generic_Container.h
index 56c5db305c0..221786f6ccd 100644
--- a/CIAO/ciao/Containers/Generic/Generic_Container.h
+++ b/CIAO/ciao/Containers/Generic/Generic_Container.h
@@ -118,7 +118,7 @@ namespace CIAO
const char *name);
// @{
- /// Inherited from extension context.
+ /// Inherited from generic context.
Components::Cookie * install_service_reference (const char * service_id,
CORBA::Object_ptr objref);
diff --git a/CIAO/ciao/Containers/Generic/Generic_Container.idl b/CIAO/ciao/Containers/Generic/Generic_Container.idl
index 07ff8c5c146..f56ec13b8a3 100644
--- a/CIAO/ciao/Containers/Generic/Generic_Container.idl
+++ b/CIAO/ciao/Containers/Generic/Generic_Container.idl
@@ -2,14 +2,14 @@
* @file Generic_Container.idl
* @author Johnny Willemsen
* $Id$
- * Extends the basic container interface for extension capabilities.
+ * Extends the basic container interface for generic capabilities.
*/
#include "ciao/Containers/Container_Base.idl"
-#include "ccm/Extension/CCM_ClientContainerInterceptorRegistration.idl"
-#include "ccm/Extension/CCM_ServantContainerInterceptorRegistration.idl"
-#include "ccm/Extension/CCM_ServerContainerInterceptorRegistration.idl"
-#include "ccm/Extension/CCM_StubContainerInterceptorRegistration.idl"
+#include "ccm/Generic/CCM_ClientContainerInterceptorRegistration.idl"
+#include "ccm/Generic/CCM_ServantContainerInterceptorRegistration.idl"
+#include "ccm/Generic/CCM_ServerContainerInterceptorRegistration.idl"
+#include "ccm/Generic/CCM_StubContainerInterceptorRegistration.idl"
module CIAO
{
@@ -33,55 +33,4 @@ module CIAO
get_servant_interceptor_registration()
raises (Components::CCMException);
};
-
- local interface InstanceManager
- {
- readonly attribute string instance_type;
-
- readonly attribute ::CORBA::StringSeq dependencies;
-
- void configure (/*in ::Deployment::Properties config*/);
-
- void install_instance (/*in ::Deployment::DeploymentPlan plan,*/
- in unsigned long instanceRef,
- out any instance_reference);
- /*raises (Deployment::StartError,
- Deployment::InvalidProperty,
- Deployment::InvalidNodeExecParameter,
- Deployment::InvalidComponentExecParameter);*/
-
-
- void connect_instance (/*in ::Deployment::DeploymentPlan plan,*/
- in unsigned long connectionRef,
- in any provided_reference);
- //raises (Deployment::StartError,
- // Deployment::InvalidConnection);
-
- void disconnect_instance (/*in ::Deployment::DeploymentPlan plan,*/
- in unsigned long connectionRef);
- //raises (::Deployment::StopError);
-
- void instance_configured (/*in ::Deployment::DeploymentPlan plan,*/
- in unsigned long instanceRef);
- //raises (Deployment::StartError);
-
- void activate_instance (/*in ::Deployment::DeploymentPlan plan,*/
- in unsigned long instanceRef,
- in any instance_re:Dference);
- //raises (Deployment::StartError);
-
- void passivate_instance (/*in ::Deployment::DeploymentPlan plan,*/
- in unsigned long instanceRef,
- in any instance_reference);
- //raises (Deployment::StopError);
-
- void remove_instance (/*in ::Deployment::DeploymentPlan plan,*/
- in unsigned long instanceRef,
- in any instance_reference);
- //raises (::Deployment::StopError);
-
- /// Instruct the handler to release any resources prior to deallocation.
- void close ();
- };
-
};
diff --git a/CIAO/ciao/Containers/Generic/Generic_Container.mpc b/CIAO/ciao/Containers/Generic/Generic_Container.mpc
index e9f442e6f28..271169ecfc9 100644
--- a/CIAO/ciao/Containers/Generic/Generic_Container.mpc
+++ b/CIAO/ciao/Containers/Generic/Generic_Container.mpc
@@ -38,9 +38,9 @@ project(CIAO_Generic_Container_stub) : install, ccm_stub, ciao_lib, ciao_contain
}
}
-project(CIAO_Generic_Container) : install, ccm_svnt, ciao_lib, ciao_extension_container_stub, utils, \
+project(CIAO_Generic_Container) : install, ccm_svnt, ciao_lib, ciao_generic_container_stub, utils, \
ciao_base, ciao_servant_activator, \
- ciao_servant, ccm_extension_stub, portableserver {
+ ciao_servant, ccm_generic_stub, portableserver {
after += CIAO_Generic_Container_idl
dynamicflags += GENERIC_CONTAINER_BUILD_DLL
diff --git a/CIAO/ciao/Containers/Generic/Generic_Container_export.h b/CIAO/ciao/Containers/Generic/Generic_Container_export.h
deleted file mode 100644
index 44056987cfd..00000000000
--- a/CIAO/ciao/Containers/Generic/Generic_Container_export.h
+++ /dev/null
@@ -1,78 +0,0 @@
-// -*- C++ -*-
-// $Id$
-
-/**
- * Code generated by the The ACE ORB (TAO) IDL Compiler v2.0.2
- * TAO and the TAO IDL Compiler have been developed by:
- * Center for Distributed Object Computing
- * Washington University
- * St. Louis, MO
- * USA
- * http://www.cs.wustl.edu/~schmidt/doc-center.html
- * and
- * Distributed Object Computing Laboratory
- * University of California at Irvine
- * Irvine, CA
- * USA
- * and
- * Institute for Software Integrated Systems
- * Vanderbilt University
- * Nashville, TN
- * USA
- * http://www.isis.vanderbilt.edu/
- *
- * Information about TAO is available at:
- * http://www.cs.wustl.edu/~schmidt/TAO.html
- **/
-
-#ifndef GENERIC_CONTAINER_EXPORT_H
-#define GENERIC_CONTAINER_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (GENERIC_CONTAINER_HAS_DLL)
-# define GENERIC_CONTAINER_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && GENERIC_CONTAINER_HAS_DLL */
-
-#if !defined (GENERIC_CONTAINER_HAS_DLL)
-# define GENERIC_CONTAINER_HAS_DLL 1
-#endif /* ! GENERIC_CONTAINER_HAS_DLL */
-
-#if defined (GENERIC_CONTAINER_HAS_DLL) && (GENERIC_CONTAINER_HAS_DLL == 1)
-# if defined (GENERIC_CONTAINER_BUILD_DLL)
-# define GENERIC_CONTAINER_Export ACE_Proper_Export_Flag
-# define GENERIC_CONTAINER_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define GENERIC_CONTAINER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* GENERIC_CONTAINER_BUILD_DLL */
-# define GENERIC_CONTAINER_Export ACE_Proper_Import_Flag
-# define GENERIC_CONTAINER_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define GENERIC_CONTAINER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* GENERIC_CONTAINER_BUILD_DLL */
-#else /* GENERIC_CONTAINER_HAS_DLL == 1 */
-# define GENERIC_CONTAINER_Export
-# define GENERIC_CONTAINER_SINGLETON_DECLARATION(T)
-# define GENERIC_CONTAINER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* GENERIC_CONTAINER_HAS_DLL == 1 */
-
-// Set GENERIC_CONTAINER_NTRACE = 0 to turn on library-specific
-// tracing even if tracing is turned off for ACE.
-#if !defined (GENERIC_CONTAINER_NTRACE)
-# if (ACE_NTRACE == 1)
-# define GENERIC_CONTAINER_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define GENERIC_CONTAINER_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !GENERIC_CONTAINER_NTRACE */
-
-#if (GENERIC_CONTAINER_NTRACE == 1)
-# define GENERIC_CONTAINER_TRACE(X)
-#else /* (GENERIC_CONTAINER_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define GENERIC_CONTAINER_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (GENERIC_CONTAINER_NTRACE == 1) */
-
-#endif /* GENERIC_CONTAINER_EXPORT_H */
-
diff --git a/CIAO/ciao/Containers/Generic/Generic_Container_stub_export.h b/CIAO/ciao/Containers/Generic/Generic_Container_stub_export.h
deleted file mode 100644
index 6d2d79e7a5c..00000000000
--- a/CIAO/ciao/Containers/Generic/Generic_Container_stub_export.h
+++ /dev/null
@@ -1,78 +0,0 @@
-// -*- C++ -*-
-// $Id$
-
-/**
- * Code generated by the The ACE ORB (TAO) IDL Compiler v2.0.2
- * TAO and the TAO IDL Compiler have been developed by:
- * Center for Distributed Object Computing
- * Washington University
- * St. Louis, MO
- * USA
- * http://www.cs.wustl.edu/~schmidt/doc-center.html
- * and
- * Distributed Object Computing Laboratory
- * University of California at Irvine
- * Irvine, CA
- * USA
- * and
- * Institute for Software Integrated Systems
- * Vanderbilt University
- * Nashville, TN
- * USA
- * http://www.isis.vanderbilt.edu/
- *
- * Information about TAO is available at:
- * http://www.cs.wustl.edu/~schmidt/TAO.html
- **/
-
-#ifndef GENERIC_CONTAINER_STUB_EXPORT_H
-#define GENERIC_CONTAINER_STUB_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (GENERIC_CONTAINER_STUB_HAS_DLL)
-# define GENERIC_CONTAINER_STUB_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && GENERIC_CONTAINER_STUB_HAS_DLL */
-
-#if !defined (GENERIC_CONTAINER_STUB_HAS_DLL)
-# define GENERIC_CONTAINER_STUB_HAS_DLL 1
-#endif /* ! GENERIC_CONTAINER_STUB_HAS_DLL */
-
-#if defined (GENERIC_CONTAINER_STUB_HAS_DLL) && (GENERIC_CONTAINER_STUB_HAS_DLL == 1)
-# if defined (GENERIC_CONTAINER_STUB_BUILD_DLL)
-# define GENERIC_CONTAINER_STUB_Export ACE_Proper_Export_Flag
-# define GENERIC_CONTAINER_STUB_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define GENERIC_CONTAINER_STUB_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* GENERIC_CONTAINER_STUB_BUILD_DLL */
-# define GENERIC_CONTAINER_STUB_Export ACE_Proper_Import_Flag
-# define GENERIC_CONTAINER_STUB_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define GENERIC_CONTAINER_STUB_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* GENERIC_CONTAINER_STUB_BUILD_DLL */
-#else /* GENERIC_CONTAINER_STUB_HAS_DLL == 1 */
-# define GENERIC_CONTAINER_STUB_Export
-# define GENERIC_CONTAINER_STUB_SINGLETON_DECLARATION(T)
-# define GENERIC_CONTAINER_STUB_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* GENERIC_CONTAINER_STUB_HAS_DLL == 1 */
-
-// Set GENERIC_CONTAINER_STUB_NTRACE = 0 to turn on library-specific
-// tracing even if tracing is turned off for ACE.
-#if !defined (GENERIC_CONTAINER_STUB_NTRACE)
-# if (ACE_NTRACE == 1)
-# define GENERIC_CONTAINER_STUB_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define GENERIC_CONTAINER_STUB_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !GENERIC_CONTAINER_STUB_NTRACE */
-
-#if (GENERIC_CONTAINER_STUB_NTRACE == 1)
-# define GENERIC_CONTAINER_STUB_TRACE(X)
-#else /* (GENERIC_CONTAINER_STUB_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define GENERIC_CONTAINER_STUB_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (GENERIC_CONTAINER_STUB_NTRACE == 1) */
-
-#endif /* GENERIC_CONTAINER_STUB_EXPORT_H */
-
diff --git a/CIAO/ciao/Containers/Generic/ServantContainerInterceptorRegistration_Impl.h b/CIAO/ciao/Containers/Generic/ServantContainerInterceptorRegistration_Impl.h
index 7620dbb25f5..c9f6c7d24be 100644
--- a/CIAO/ciao/Containers/Generic/ServantContainerInterceptorRegistration_Impl.h
+++ b/CIAO/ciao/Containers/Generic/ServantContainerInterceptorRegistration_Impl.h
@@ -12,8 +12,8 @@
#include "ciao/Containers/Generic/Generic_Container_export.h"
-#include "ccm/Extension/CCM_ServantContainerInterceptorC.h"
-#include "ccm/Extension/CCM_ServantContainerInterceptorRegistrationC.h"
+#include "ccm/Generic/CCM_ServantContainerInterceptorC.h"
+#include "ccm/Generic/CCM_ServantContainerInterceptorRegistrationC.h"
#include "ciao/Containers/Generic/Interceptor_Registration_T.h"
namespace CIAO
diff --git a/CIAO/ciao/Containers/Generic/ServerContainerInterceptorRegistration_Impl.h b/CIAO/ciao/Containers/Generic/ServerContainerInterceptorRegistration_Impl.h
index 9a9b6aea1d8..c522f9fb6c6 100644
--- a/CIAO/ciao/Containers/Generic/ServerContainerInterceptorRegistration_Impl.h
+++ b/CIAO/ciao/Containers/Generic/ServerContainerInterceptorRegistration_Impl.h
@@ -12,8 +12,8 @@
#include "ciao/Containers/Generic/Generic_Container_export.h"
-#include "ccm/Extension/CCM_ServerContainerInterceptorC.h"
-#include "ccm/Extension/CCM_ServerContainerInterceptorRegistrationC.h"
+#include "ccm/Generic/CCM_ServerContainerInterceptorC.h"
+#include "ccm/Generic/CCM_ServerContainerInterceptorRegistrationC.h"
#include "ciao/Containers/Generic/Interceptor_Registration_T.h"
namespace CIAO
diff --git a/CIAO/ciao/Containers/Generic/StubContainerInterceptorRegistration_Impl.h b/CIAO/ciao/Containers/Generic/StubContainerInterceptorRegistration_Impl.h
index 11ce78b1731..a79fa574d8b 100644
--- a/CIAO/ciao/Containers/Generic/StubContainerInterceptorRegistration_Impl.h
+++ b/CIAO/ciao/Containers/Generic/StubContainerInterceptorRegistration_Impl.h
@@ -12,8 +12,8 @@
#include "ciao/Containers/Generic/Generic_Container_export.h"
-#include "ccm/Extension/CCM_StubContainerInterceptorC.h"
-#include "ccm/Extension/CCM_StubContainerInterceptorRegistrationC.h"
+#include "ccm/Generic/CCM_StubContainerInterceptorC.h"
+#include "ccm/Generic/CCM_StubContainerInterceptorRegistrationC.h"
#include "ciao/Containers/Generic/Interceptor_Registration_T.h"
namespace CIAO
diff --git a/CIAO/ciao/FTComponentServer/CIAO_CS_Client.idl b/CIAO/ciao/FTComponentServer/CIAO_CS_Client.idl
deleted file mode 100644
index 883c87450d3..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_CS_Client.idl
+++ /dev/null
@@ -1,35 +0,0 @@
-/**
- * @file CIAO_CS_Client.idl
- * @author William R. Otte <wotte@dre.vanderbilt.edu>
- *
- * A couple CIAO-specific extensions to the component server client
- * interfaces.
- */
-
-#ifndef CIAO_COMPONENTSERVER_IDL_
-#define CIAO_COMPONENTSERVER_IDL_
-
-#include <ccm/ComponentServer/CCM_ComponentServer_Client.idl>
-
-module CIAO
-{
- module Deployment
- {
- interface ServerActivator : ::Components::Deployment::ServerActivator
- {
- /// Used by spawned component servers to notify the server
- /// activator of their object reference and retrieve
- /// configuration information.
- void component_server_callback (in ::Components::Deployment::ComponentServer serverref,
- in string server_UUID,
- out ::Components::ConfigValues config);
-
- void configuration_complete (in string server_UUID);
- };
- };
-};
-
-
-#endif
-
-
diff --git a/CIAO/ciao/FTComponentServer/CIAO_CS_Client_svnt_export.h b/CIAO/ciao/FTComponentServer/CIAO_CS_Client_svnt_export.h
deleted file mode 100644
index 32a2ea33fd5..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_CS_Client_svnt_export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl CIAO_CS_Client_svnt
-// ------------------------------
-#ifndef CIAO_CS_CLIENT_SVNT_EXPORT_H
-#define CIAO_CS_CLIENT_SVNT_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (CIAO_CS_CLIENT_SVNT_HAS_DLL)
-# define CIAO_CS_CLIENT_SVNT_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && CIAO_CS_CLIENT_SVNT_HAS_DLL */
-
-#if !defined (CIAO_CS_CLIENT_SVNT_HAS_DLL)
-# define CIAO_CS_CLIENT_SVNT_HAS_DLL 1
-#endif /* ! CIAO_CS_CLIENT_SVNT_HAS_DLL */
-
-#if defined (CIAO_CS_CLIENT_SVNT_HAS_DLL) && (CIAO_CS_CLIENT_SVNT_HAS_DLL == 1)
-# if defined (CIAO_CS_CLIENT_SVNT_BUILD_DLL)
-# define CIAO_CS_Client_svnt_Export ACE_Proper_Export_Flag
-# define CIAO_CS_CLIENT_SVNT_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define CIAO_CS_CLIENT_SVNT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* CIAO_CS_CLIENT_SVNT_BUILD_DLL */
-# define CIAO_CS_Client_svnt_Export ACE_Proper_Import_Flag
-# define CIAO_CS_CLIENT_SVNT_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define CIAO_CS_CLIENT_SVNT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* CIAO_CS_CLIENT_SVNT_BUILD_DLL */
-#else /* CIAO_CS_CLIENT_SVNT_HAS_DLL == 1 */
-# define CIAO_CS_Client_svnt_Export
-# define CIAO_CS_CLIENT_SVNT_SINGLETON_DECLARATION(T)
-# define CIAO_CS_CLIENT_SVNT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* CIAO_CS_CLIENT_SVNT_HAS_DLL == 1 */
-
-// Set CIAO_CS_CLIENT_SVNT_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (CIAO_CS_CLIENT_SVNT_NTRACE)
-# if (ACE_NTRACE == 1)
-# define CIAO_CS_CLIENT_SVNT_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define CIAO_CS_CLIENT_SVNT_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !CIAO_CS_CLIENT_SVNT_NTRACE */
-
-#if (CIAO_CS_CLIENT_SVNT_NTRACE == 1)
-# define CIAO_CS_CLIENT_SVNT_TRACE(X)
-#else /* (CIAO_CS_CLIENT_SVNT_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define CIAO_CS_CLIENT_SVNT_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (CIAO_CS_CLIENT_SVNT_NTRACE == 1) */
-
-#endif /* CIAO_CS_CLIENT_SVNT_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.cpp b/CIAO/ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.cpp
deleted file mode 100644
index 5492df95404..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.cpp
+++ /dev/null
@@ -1,120 +0,0 @@
-// $Id$
-
-#include "ComponentInstallation_Impl.h"
-#include "DAnCE/Logger/Log_Macros.h"
-
-using namespace DAnCE;
-
-ComponentInstallation_Impl::ComponentInstallation_Impl()
-{
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::ComponentInstallation_Impl - started\n"));
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::ComponentInstallation_Impl - finished\n"));
-}
-
-ComponentInstallation_Impl::~ComponentInstallation_Impl()
-{
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::~ComponentInstallation_Impl - started\n"));
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::~ComponentInstallation_Impl - finished\n"));
-}
-
-void
-ComponentInstallation_Impl::install (const char * implUUID, const char * component_loc)
-{
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::install - started\n"));
-
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::install - implUUID %s, component_loc %s\n", implUUID, component_loc));
- if (0 != this->locations_.find (implUUID))
- {
- ACE_CString location = component_loc;
- this->locations_.bind (implUUID, location);
- }
- else
- {
- // I don't certaint that we should throw exception here
- //throw ::Components::Deployment::InstallationFailure();
- }
-
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::install - finished\n"));
-}
-
-
-void
-ComponentInstallation_Impl::replace (const char * , const char *)
-{
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::replace - started\n"));
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::replace - finished\n"));
-}
-
-void
-ComponentInstallation_Impl::remove (const char *)
-{
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::remove - started\n"));
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::remove - finished\n"));
-}
-
-char *
-ComponentInstallation_Impl::get_implementation (const char * implUUID)
-{
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::get_implementation - started\n"));
-
- ACE_CString s;
- if (0 == this->locations_.find (implUUID, s))
- {
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::get_implementation - ComponentInstallation_Impl::get_implementation for UUID %s, location %s\n", implUUID, s.c_str()));
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::get_implementation - finished\n"));
- return CORBA::string_dup (s.c_str());
- }
- else
- {
- DANCE_ERROR ( (LM_ERROR, "[%M] ComponentInstallation_Impl::get_implementation - cannot find location for specified implementation UUID\n"));
- throw ::Components::Deployment::UnknownImplId();
- return 0;
- }
-}
-
-
-char *
-ComponentInstallation_Impl::get_valuetypefactory_location (
- const char * implUUID,
- const char * repid
-)
-{
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::get_valuetypefactory_location - started\n"));
- ACE_CString key = ComponentInstallation_Impl::valuefactory_key (implUUID, repid);
- ACE_CString s;
- if (0 == this->locations_.find (implUUID, s))
- {
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::get_valuetypefactory_location - UUID:\"%s\" repid:\"%s\" -> location:\"%s\"\n", implUUID, repid, s.c_str()));
- return CORBA::string_dup (s.c_str());
- }
- else
- {
- DANCE_ERROR ( (LM_ERROR, "[%M] ComponentInstallation_Impl::get_valuetypefactory_location - cannot find location for specified implementation UUID and repid.\n"));
- throw ::Components::Deployment::InstallationFailure();
- return 0;
- }
- DANCE_DEBUG ( (LM_DEBUG, "[%M] ComponentInstallation_Impl::get_valuetypefactory_location - finished\n"));
- return 0;
-}
-
-
-void
-ComponentInstallation_Impl::install_valuetypefactory_location (
- const char * implUUID,
- const char * repid,
- const char * loc
-)
-{
- ACE_CString key = ComponentInstallation_Impl::valuefactory_key (implUUID, repid);
- if (0 != this->locations_.find (key))
- {
- ACE_CString location = loc;
- this->locations_.bind (implUUID, location);
- }
- else
- {
- // I don't certaint that we should throw exception here
- //throw ::Components::Deployment::InstallationFailure();
- }
-}
-
diff --git a/CIAO/ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.h b/CIAO/ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.h
deleted file mode 100644
index c291adcb346..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_ComponentInstallation_Impl.h
+++ /dev/null
@@ -1,76 +0,0 @@
-// -*- C++ -*-
-
-//=============================================================================
-/**
- * @file CIAO_ComponentInstallation_Impl.h
- *
- * $Id$
- *
- * @Brief Return location of component artifact
- *
- * @author Erwin Gottlieb <eg@prismtech.com>
- */
-//=============================================================================
-
-#ifndef COMPONENTINSTALLATION_IMPL_H_
-#define COMPONENTINSTALLATION_IMPL_H_
-
-#include "ace/Map_Manager.h"
-#include "ccm/CCM_ComponentC.h"
-
-#include "Cdmw/CDMW_DeploymentS.h"
-#include "tao/ORB.h"
-#include "NodeApplication_Export.h"
-
-namespace DAnCE
- {
-
- class NodeApplication_Export ComponentInstallation_Impl
- : public virtual POA_CdmwDeployment::ComponentInstallation
- {
- public:
- ComponentInstallation_Impl();
-
- virtual ~ComponentInstallation_Impl();
-
- virtual void install (
- const char * implUUID,
- const char * component_loc
- );
-
- virtual void replace (
- const char * implUUID,
- const char * component_loc
- );
-
- virtual void remove (
- const char * implUUID
- );
-
- virtual char * get_implementation (
- const char * implUUID
- );
-
- virtual char * get_valuetypefactory_location (
- const char * implUUID,
- const char * repid
- );
-
- void install_valuetypefactory_location (
- const char * implUUID,
- const char * repid,
- const char * loc
- );
-
- private:
- typedef ACE_Map_Manager< ACE_CString, ACE_CString, ACE_Null_Mutex > TLocations;
- TLocations locations_;
-
- static ACE_CString valuefactory_key (const char* uuid, const char* repid)
- {
- return ACE_CString (repid) + "@" + uuid;
- };
- };
-
-};
-#endif /*COMPONENTINSTALLATION_IMPL_H_*/
diff --git a/CIAO/ciao/FTComponentServer/CIAO_ComponentServer.idl b/CIAO/ciao/FTComponentServer/CIAO_ComponentServer.idl
deleted file mode 100644
index 69c1bdc1e00..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_ComponentServer.idl
+++ /dev/null
@@ -1,68 +0,0 @@
-/**
- * @file CIAO_ComponentServer.idl
- * @author William R. Otte <wotte@dre.vanderbilt.edu>
- *
- * $Id$
- *
- * A couple CIAO-specific extensions to the component server
- * interfaces.
- */
-
-#ifndef CIAO_COMPONENTSERVER_IDL_
-#define CIAO_COMPONENTSERVER_IDL_
-
-#include <ccm/CCM_Object.idl>
-#include <ccm/ComponentServer/CCM_ComponentServer.idl>
-
-module CIAO
-{
- module Deployment
- {
- interface ComponentServer : ::Components::Deployment::ComponentServer
- {
- oneway void shutdown ();
- };
-
- exception InvalidComponent
- {
- };
-
- /**
- * @interface CIAO_Container
- * @brief CIAO specific extensions to the component server interface.
- */
- interface Container : Components::Deployment::Container
- {
- /// Instruct the container to install a component without
- /// an explicit home.
- ::Components::CCMObject install_component (in ::Components::Deployment::UUID id,
- in string entrypt,
- in ::Components::ConfigValues config)
- raises (::Components::Deployment::UnknownImplId,
- ::Components::Deployment::ImplEntryPointNotFound,
- ::Components::Deployment::InstallationFailure,
- ::Components::Deployment::InvalidConfiguration);
-
- /// Activate component with specified ID, if no ID provided,
- /// activates all components.
- void activate_component (in ::Components::CCMObject comp)
- raises (InvalidComponent);
-
- /// Passivate component with specified ID, if no ID provided,
- /// passivates all components.
- void passivate_component (in ::Components::CCMObject comp)
- raises (InvalidComponent);
-
- /// Instruct the container to remove a component installed
- /// without an explicit home. If the component was installed
- /// with an explicit home, this operation will fail.
- void remove_component (in ::Components::CCMObject cref)
- raises (::Components::RemoveFailure);
-
- /// Returns a sequence of all homeless components.
- ::Components::CCMObjectSeq get_components ();
- };
- };
-};
-
-#endif /* CIAO_COMPONENTSERVER_IDL_ */
diff --git a/CIAO/ciao/FTComponentServer/CIAO_ComponentServer.mpc b/CIAO/ciao/FTComponentServer/CIAO_ComponentServer.mpc
deleted file mode 100644
index 62e17d7d7ad..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_ComponentServer.mpc
+++ /dev/null
@@ -1,94 +0,0 @@
-project(CIAO_FTComponentServer_IDL) : ciaoidldefaults, anytypecode {
- idlflags += -Wb,stub_export_macro=CIAO_FTComponentServer_stub_Export
- idlflags += -Wb,stub_export_include=CIAO_FTComponentServer_stub_export.h
- idlflags += -Wb,skel_export_macro=CIAO_FTComponentServer_svnt_Export
- idlflags += -Wb,skel_export_include=CIAO_FTComponentServer_svnt_export.h
-
- custom_only=1
-
- IDL_Files {
- CIAO_ComponentServer.idl
- CIAO_ServerResources.idl
- }
-}
-
-project(CIAO_FTCS_Client_IDL) : ciaoidldefaults, anytypecode {
- idlflags += -Wb,stub_export_macro=CIAO_FTComponentServer_stub_Export
- idlflags += -Wb,stub_export_include=CIAO_FTComponentServer_stub_export.h
- idlflags += -Wb,skel_export_macro=CIAO_CS_Client_svnt_Export
- idlflags += -Wb,skel_export_include=CIAO_CS_Client_svnt_export.h
-
- custom_only=1
-
- IDL_Files {
- CIAO_CS_Client.idl
- CIAO_Properties.idl
- }
-}
-
-project(CIAO_FTComponentServer_stub) : ccm_componentserver_stub, ciaolib_with_idl, ciao_output, \
- messaging, anytypecode, ciao_lib {
- after += CIAO_FTComponentServer_IDL CIAO_FTCS_Client_IDL
- dynamicflags = CIAO_FTCOMPONENTSERVER_STUB_BUILD_DLL
-
- IDL_Files {
- }
- Source_Files {
- CIAO_ComponentServerC.cpp
- CIAO_CS_ClientC.cpp
- CIAO_ServerResourcesC.cpp
- CIAO_PropertiesC.cpp
- }
- Header_Files {
- CIAO_FTComponentServer_stub_export.h
- }
-}
-
-project(CIAO_FTCS_Client_svnt) : ccm_svnt, ccm_componentserver_svnt, ciao_ft_componentserver_stub, portableserver, ciao_client, ciao_lib {
- dynamicflags = CIAO_CS_CLIENT_SVNT_BUILD_DLL
- after += CIAO_FTCS_Client_IDL CIAO_FTComponentServer_stub
-
- IDL_Files {
- }
- Source_Files {
- CIAO_ServerActivator_Impl.cpp
- CIAO_CS_ClientS.cpp
- }
- Header_Files {
- CIAO_ServerActivator_Impl.h
- CIAO_CS_ClientS.h
- CIAO_CS_Client_svnt_export.h
- }
-}
-
-project(CIAO_FTComponentServer_svnt) : ccm_componentserver_svnt, ciao_ft_componentserver_stub, portableserver, ciao_ft_componentserver_configurator, ciao_ft_session_container, naming, ciao_server {
-
- dynamicflags = CIAO_FTCOMPONENTSERVER_SVNT_BUILD_DLL
-
- IDL_Files {
- }
- Source_Files {
- CIAO_FTComponentServer_Impl.cpp
- CIAO_ComponentServerS.cpp
- CIAO_ServerResourcesS.cpp
- CIAO_Container_Impl.cpp
- Configurator_Factory.cpp
- }
- Header_Files {
- CIAO_FTComponentServer_svnt_export.h
- }
-}
-
-project(CIAO_FTComponentServer_exe) : ccm_componentserver_svnt, portableserver, ciao_ft_componentserver_svnt, messaging, anytypecode, ciao_server, ciaoexe, ciao_ft_session_container, pi_server, iorinterceptor {// , rtcorba
- exename = ciao_ft_componentserver
- libs += CIAO_FT_Basic_Configurator CIAO_Logger LWFT_StateSyncAgent LWFT_ReplicationManager LWFT_Client LWFT_Server
- after += CIAO_FT_Basic_Configurator CIAO_Logger
- macros += CIAO_BUILD_COMPONENTSERVER_EXE
- includes += $(TAO_ROOT)/orbsvcs/orbsvcs/LWFT
-
- Source_Files {
- CIAO_FTComponentServer.cpp
- }
- IDL_Files {
- }
-}
diff --git a/CIAO/ciao/FTComponentServer/CIAO_Container_Impl.cpp b/CIAO/ciao/FTComponentServer/CIAO_Container_Impl.cpp
deleted file mode 100644
index 5a08aaea716..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_Container_Impl.cpp
+++ /dev/null
@@ -1,460 +0,0 @@
-// $Id$
-#include "CIAO_Container_Impl.h"
-
-#include "ace/Log_Msg.h"
-#include "ccm/CCM_HomeC.h"
-#include "ciao/CIAO_common.h"
-#include "ciao/Server_init.h"
-#include "ciao/Client_init.h"
-#include "CIAO_PropertiesC.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- // Constructor
- CIAO_Container_i::CIAO_Container_i (const Components::ConfigValues &config,
- const Static_Config_EntryPoints_Maps *static_entrypts,
- const char *name,
- const CORBA::PolicyList *policies,
- CORBA::ORB_ptr orb,
- PortableServer::POA_ptr poa)
- : orb_ (CORBA::ORB::_duplicate (orb)),
- poa_ (PortableServer::POA::_duplicate (poa)),
- config_ (config.length ()),
- static_entrypts_maps_ (static_entrypts)
- {
- CIAO_TRACE("CIAO_Container_i::CIAO_Container_i");
-
- for (CORBA::ULong i = 0; i < config.length (); ++i)
- {
- this->config_[i] = config[i];
- }
-
- try
- {
- if (this->static_entrypts_maps_ == 0)
- {
- CIAO_DEBUG((LM_DEBUG, CLINFO "CIAO_Container_i: creating FT Session container with dynamic linkage\n"));
- this->container_ = new CIAO::FT_Session_Container (this->orb_.in (), this, false,
- 0, name, policies);
- }
- else
- {
- CIAO_DEBUG((LM_DEBUG, CLINFO "CIAO_Container_i: creating FT Session container with static linkage\n"));
- this->container_ = new CIAO::FT_Session_Container (this->orb_.in (), this, true,
- this->static_entrypts_maps_,
- name, policies);
- }
- }
- catch (...)
- {
- CIAO_ERROR((LM_ERROR, CLINFO "CIAO_Container_i::CIAO_Container_i - "
- "Caught exception while allocating container implementation\n"));
- throw;
- }
- }
-
-
- // Destructor
- CIAO_Container_i::~CIAO_Container_i (void)
- {
- CIAO_TRACE("CIAO_Container_i::~CIAO_Container_i");
- }
-
- ::Components::CCMObject_ptr
- CIAO_Container_i::install_component (const char * id,
- const char * entrypt,
- const ::Components::ConfigValues & config)
- {
- CIAO_TRACE("CIAO_Container_i::install_component");
-
- const char *tmp;
- CORBA::String_var name;
-
- CIAO::Utility::CONFIGVALUE_MAP cm;
- CIAO::Utility::build_config_values_map (cm, config);
- CORBA::Any val;
-
- if (cm.find (OBJECT_ID, val) == 0)
- {
- val >>= tmp;
- name = tmp;
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_component - "
- "Found ObjectId %C\n", name.in ()));
- }
- else
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_component - "
- "Found no ObjectId property, using component id instead\n"));
- name = id;
- }
-
- if (name == 0)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_Container_i::install_component - "
- "No home ID provided\n"));
- throw ::Components::Deployment::InvalidConfiguration ();
- }
-
- Components::CCMObject_var comp;
-
- if (this->component_map_.find (name.in (), comp) == 0)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_Container_i::install_component - "
- "Component with id %C already installed, aborting\n",
- name.in ()));
- throw Components::CreateFailure ();
- }
-
- if (entrypt == 0)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_Container_i::install_component - "
- "No executor entrypoint found.\n"));
- throw ::Components::Deployment::InvalidConfiguration ();
- }
-
- CIAO_DEBUG ((LM_INFO, CLINFO "CIAO_Container_i::install_component - "
- "Attempting to install home with id [%C]\n",
- name.in ()));
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_component - "
- "Extracting ConfigValues from sequence of length [%u]\n",
- config.length ()));
-
- CORBA::String_var exec_art, svnt_art, svnt_entry;
-
- if (cm.find (SVNT_ENTRYPT, val) == 0)
- {
- val >>= tmp;
- svnt_entry = tmp;
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_component - "
- "Found Servant entrypoint %C\n", svnt_entry.in ()));
- }
- else
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_component - "
- "Error: No Servant entrypoint porovided, aborting installation\n"));
- throw Components::InvalidConfiguration ();
- }
-
- if (cm.find (SVNT_ARTIFACT, val) == 0)
- {
- val >>= tmp;
- svnt_art = tmp;
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_component - "
- "Found Servant artifact %C\n", svnt_art.in ()));
- }
- else
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_component - "
- "Error: No Servant artifact porovided, aborting installation\n"));
- throw Components::InvalidConfiguration ();
- }
-
-
- if (cm.find (EXEC_ARTIFACT, val) == 0)
- {
- val >>= tmp;
- exec_art = tmp;
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_component - "
- "Found executor artifact: %C\n", exec_art.in ()));
- }
- else
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_component - "
- "Error: No Executor artifact porovided, aborting installation\n"));
- }
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_component - "
- "Extraction resulted in map of [%u] values\n", cm.current_size ()));
-
- comp = this->container_->install_component (exec_art,
- entrypt,
- svnt_art,
- svnt_entry,
- name.in ());
-
- if (this->component_map_.bind (name.in (),
- Components::CCMObject::_duplicate (comp.in ())) == -1)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_component - "
- "Unable to bind componnet into component map\n"));
- }
-
-
- return comp._retn ();
- }
-
- void
- CIAO_Container_i::remove_component (::Components::CCMObject_ptr /*cref*/)
- {
- CIAO_TRACE("CIAO_Container_i::remove_component");
- throw CORBA::NO_IMPLEMENT ();
- }
-
- ::Components::CCMObjectSeq *
- CIAO_Container_i::get_components (void)
- {
- CIAO_TRACE("CIAO_Container_i::get_components");
- throw CORBA::NO_IMPLEMENT ();
- return 0;
- }
-
- ::Components::ConfigValues *
- CIAO_Container_i::configuration (void)
- {
- CIAO_TRACE("CIAO_Container_i::configuration");
- throw CORBA::NO_IMPLEMENT ();
- return 0;
- }
-
- ::Components::Deployment::ComponentServer_ptr
- CIAO_Container_i::get_component_server (void)
- {
- CIAO_TRACE("CIAO_Container_i::get_component_server");
- throw CORBA::NO_IMPLEMENT ();
- return 0;
- }
-
- ::Components::CCMHome_ptr
- CIAO_Container_i::install_home (const char * id,
- const char * entrypt,
- const ::Components::ConfigValues & config)
- {
- CIAO_TRACE("CIAO_Container_i::install_home");
-
- if (id == 0)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_Container_i::install_home - "
- "No home ID provided\n"));
- throw ::Components::Deployment::InvalidConfiguration ();
- }
-
- Components::CCMHome_var home;
-
- if (this->home_map_.find (id, home) == 0)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_Container_i::install_home - "
- "Home with id %C already installed, aborting\n",
- id));
- throw Components::CreateFailure ();
- }
-
- if (entrypt == 0)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_Container_i::install_home - "
- "No executor entrypoint found.\n"));
- throw ::Components::Deployment::InvalidConfiguration ();
- }
-
- CIAO_DEBUG ((LM_INFO, CLINFO "CIAO_Container_i::install_home - "
- "Attempting to install home with id [%C]\n", id));
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_home - "
- "Extracting ConfigValues from sequence of length [%u]\n",
- config.length ()));
-
- CIAO::Utility::CONFIGVALUE_MAP cm;
- CIAO::Utility::build_config_values_map (cm, config);
- CORBA::Any val;
-
- const char *tmp = 0;
- CORBA::String_var exec_art, svnt_art, svnt_entry;
- if (cm.find (SVNT_ENTRYPT, val) == 0)
- {
- val >>= tmp;
- svnt_entry = tmp;
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_home - "
- "Found Servant entrypoint %C\n", svnt_entry.in ()));
- }
- else
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_home - "
- "Error: No Servant entrypoint porovided, aborting installation\n"));
- throw Components::InvalidConfiguration ();
- }
-
- if (cm.find (SVNT_ARTIFACT, val) == 0)
- {
- val >>= tmp;
- svnt_art = tmp;
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_home - "
- "Found Servant artifact %C\n", svnt_art.in ()));
- }
- else
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_home - "
- "Error: No Servant artifact porovided, aborting installation\n"));
- throw Components::InvalidConfiguration ();
- }
-
-
- if (cm.find (EXEC_ARTIFACT, val) == 0)
- {
- val >>= tmp;
- exec_art = tmp;
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_home - "
- "Found executor artifact: %C\n", exec_art.in ()));
- }
- else
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_home - "
- "Error: No Executor artifact porovided, aborting installation\n"));
- }
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_Container_i::install_home - "
- "Extraction resulted in map of [%u] values\n", cm.current_size ()));
-
-
- // extract config values here...
-
- //CIAO_DEBUG ((LM_DEBUG, CLINFO "CIAO_Container_i::install_home - ",
- //"Executor entrypoint [%C], servant entrypoint [%C], servant library [%C]\n",
- //entrypt, svnt_entrypt.in (), svnt_library.in ()));
-
- home = this->container_->install_home (exec_art,
- entrypt,
- svnt_art,
- svnt_entry,
- id);
-
- if (this->home_map_.bind (id,
- Components::CCMHome::_duplicate (home.in ())) == -1)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_Container_i::install_home - "
- "Unable to bind home into home map\n"));
- }
-
- return home._retn ();
- }
-
- void
- CIAO_Container_i::remove_home (::Components::CCMHome_ptr href)
- {
- CIAO_TRACE("CIAO_Container_i::remove_home");
-
- ::Components::CCMHome_var home (href);
-
- Home_Iterator i = this->home_map_.begin ();
- while (!i.done ())
- {
- if (i->item ()->_is_equivalent (home.in ()))
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_Container_i::remove_home - "
- "Successfully found matching home\n"));
- break;
- }
- i.advance ();
- }
-
- if (i.done ())
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_Container_i::remove_home - "
- "Unable to find matching home managed by this container, throwing RemoveFailure\n"));
- throw Components::RemoveFailure ();
- }
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_Container_i::remove_home - "
- "Invoking remove on the container impl for home %C.\n",
- i->key ().c_str ()));
- this->container_->uninstall_home (home.in ());
- CIAO_DEBUG ((LM_INFO, CLINFO "CIAO_Container_i::remove_home - "
- "Successfully removed home %C\n",
- i->key ().c_str ()));
-
- if (this->home_map_.unbind (i->key ()) != 0)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_Container_i::remove_home - "
- "Unable to unbind removed home with id %C from home map\n",
- i->key ().c_str ()));
- }
- }
-
- ::Components::CCMHomes *
- CIAO_Container_i::get_homes (void)
- {
- CIAO_TRACE("CIAO_Container_i::get_homes");
-
- ::Components::CCMHomes *tmp_homes = 0;
-
- ACE_NEW_THROW_EX (tmp_homes,
- ::Components::CCMHomes (this->home_map_.current_size ()),
- CORBA::NO_MEMORY ());
-
- ::Components::CCMHomes_var retval (tmp_homes);
- retval->length (this->home_map_.current_size ());
- Home_Iterator i = this->home_map_.begin ();
- CORBA::ULong pos = 0;
- while (!i.done ())
- {
- retval[pos++] = ::Components::CCMHome::_duplicate (i->item ().in ());
- i.advance ();
- }
-
- return retval._retn ();
- }
-
- void
- CIAO_Container_i::remove (void)
- {
- CIAO_TRACE("CIAO_Container_i::remove");
-
- if (this->home_map_.current_size () != 0 ||
- this->component_map_.current_size () != 0)
- {
- CIAO_ERROR ((LM_WARNING, CLINFO "CIAO_Container_i::remove - "
- "Attempting to remove container that still has %u homes and %u components installed\n",
- this->home_map_.current_size (),
- this->component_map_.current_size ()));
- }
-
- //this->container_->_remove_ref ();
- }
-
- void
- CIAO_Container_i::activate_component (::Components::CCMObject_ptr comp)
- {
- CIAO_TRACE ("CIAO_Container_i::activate_component");
-
- this->container_->activate_component (comp);
- }
-
-
- void
- CIAO_Container_i::passivate_component (::Components::CCMObject_ptr comp)
- {
- CIAO_TRACE ("CIAO_Container_i::passivate_component");
-
- this->container_->passivate_component (comp);
- }
-
-
- PortableServer::POA_ptr
- CIAO_Container_i::_default_POA (void)
- {
- CIAO_TRACE ("CIAO_Container_i::_default_POA");
- return PortableServer::POA::_duplicate (this->poa_.in ());
- }
- }
-}
diff --git a/CIAO/ciao/FTComponentServer/CIAO_Container_Impl.h b/CIAO/ciao/FTComponentServer/CIAO_Container_Impl.h
deleted file mode 100644
index 87c9977cdb1..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_Container_Impl.h
+++ /dev/null
@@ -1,115 +0,0 @@
-// $Id$
-/**
- * @file CIAO_Container_Impl.h
- * @author William R. Otte <wotte@dre.vanderbilt.edu>
- */
-
-#ifndef CIAO_CONTAINER_H_
-#define CIAO_CONTAINER_H_
-
-#include "CIAO_ComponentServerS.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-#pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "ciao/Containers/FTSession/FT_Session_Container.h"
-
-#include "CIAO_FTComponentServer_svnt_export.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- /**
- * @class CIAO_Container
- * @brief Implements external interface for CIAO container.
- */
- class CIAO_FTComponentServer_svnt_Export CIAO_Container_i
- : public virtual POA_CIAO::Deployment::Container
- {
- public:
- /// Constructor
- CIAO_Container_i (const Components::ConfigValues &config,
- const Static_Config_EntryPoints_Maps *,
- const char *,
- const CORBA::PolicyList *,
- CORBA::ORB_ptr,
- PortableServer::POA_ptr);
-
- /// Destructor
- virtual ~CIAO_Container_i (void);
-
- virtual ::Components::CCMObject_ptr install_component (
- const char * id,
- const char * entrypt,
- const ::Components::ConfigValues & config);
-
- virtual void remove_component (::Components::CCMObject_ptr cref);
-
- virtual ::Components::CCMObjectSeq * get_components (void);
-
- virtual ::Components::ConfigValues * configuration (void);
-
- virtual
- ::Components::Deployment::ComponentServer_ptr get_component_server (void);
-
- virtual ::Components::CCMHome_ptr install_home (const char * id,
- const char * entrypt,
- const ::Components::ConfigValues & config);
-
- virtual void remove_home (::Components::CCMHome_ptr href);
-
- virtual ::Components::CCMHomes * get_homes (void);
-
- virtual void remove (void);
-
- virtual void activate_component (::Components::CCMObject_ptr comp);
-
- virtual void passivate_component (::Components::CCMObject_ptr comp);
-
- virtual PortableServer::POA_ptr _default_POA (void);
-
- private:
- /// Keep a pointer to the managing ORB serving this servant.
- CORBA::ORB_var orb_;
-
- PortableServer::POA_var poa_;
-
- CIAO::Container_var container_;
-
- Components::ConfigValues config_;
-
- const Static_Config_EntryPoints_Maps* static_entrypts_maps_;
-
- /// To store all created CCMHome object
- typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
- Components::CCMHome_var,
- ACE_Hash<ACE_CString>,
- ACE_Equal_To<ACE_CString>,
- ACE_Null_Mutex> CCMHome_Map;
-
- typedef CCMHome_Map::iterator Home_Iterator;
- CCMHome_Map home_map_;
-
- /// To store all created Component object.
- // @@Gan, see how this caching is duplicated..
- typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
- Components::CCMObject_var,
- ACE_Hash<ACE_CString>,
- ACE_Equal_To<ACE_CString>,
- ACE_Null_Mutex> CCMComponent_Map;
-
- typedef CCMComponent_Map::iterator Component_Iterator;
- CCMComponent_Map component_map_;
-
- typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
- ACE_CString,
- ACE_Hash<ACE_CString>,
- ACE_Equal_To<ACE_CString>,
- ACE_Null_Mutex> CCMNaming_Map;
- CCMNaming_Map naming_map_;
- };
- }
-}
-#endif /* CIAO_CONTAINER_H_ */
diff --git a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp b/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp
deleted file mode 100644
index 8dcef805233..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.cpp
+++ /dev/null
@@ -1,590 +0,0 @@
-/**
- * @file CIAO_ComponentServer.cpp
- * @author William R. Otte
- *
- * Implementation and main for CIAO_ComponentServer.
- */
-
-#include "CIAO_FTComponentServer.h"
-
-#include <sstream>
-#include "ace/OS_NS_string.h"
-#include "ace/Log_Msg.h"
-#include "ace/Get_Opt.h"
-#include "ace/Sched_Params.h"
-#include "ace/Trace.h"
-#include "ace/Env_Value_T.h"
-#include "tao/ORB.h"
-#include "tao/Object.h"
-#include "tao/CORBA_methods.h"
-#include "tao/PortableServer/PortableServer.h"
-#include "tao/ORB_Core.h"
-#include "tao/ORBInitializer_Registry.h"
-#include "orbsvcs/orbsvcs/LWFT/StateSynchronizationAgent_i.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/AppSideMonitor_Thread.h"
-#include "orbsvcs/orbsvcs/LWFT/ReplicationManagerC.h"
-#include "ciao/CIAO_common.h"
-#include "ciao/Logger/Logger_Service.h"
-#include "ciao/Logger/Log_Macros.h"
-#include "ciao/Server_init.h"
-
-#include "Name_Helper_T.h"
-#include "CIAO_FTComponentServer_Impl.h"
-#include "CIAO_CS_ClientC.h"
-#include "Configurator_Factory.h"
-#include "Configurators/Server_Configurator.h"
-
-#ifdef CIAO_BUILD_COMPONENTSERVER_EXE
-
-int ACE_TMAIN (int argc, ACE_TCHAR **argv)
-{
- // Tracing disabled by default
- CIAO_DISABLE_TRACE ();
-
- CIAO_TRACE ("CIAO_ComponentServer::ACE_TMAIN");
-
- try
- {
- CIAO::Deployment::ComponentServer_Task cs (argc, argv);
- cs.run ();
- return 0;
- }
- catch (CIAO::Deployment::ComponentServer_Task::Error &e)
- {
- CIAO_DEBUG ((LM_ALERT, CLINFO "CIAO_ComponentServer main: Caught ComponentServer exception: %s\n",
- e.err_.c_str ()));
- }
- catch (...)
- {
- CIAO_DEBUG ((LM_ALERT, CLINFO "CIAO_ComponentServer main: Caught unknown exception.\n"));
- }
-
- return -1;
-}
-
-#endif /* CIAO_BUILD_COMPONENTSERVER_EXE */
-
-bool
-write_IOR (const char * ior_file_name, const char* ior)
-{
- FILE* ior_output_file_ =
- ACE_OS::fopen (ior_file_name, "w");
-
- if (ior_output_file_)
- {
- ACE_OS::fprintf (ior_output_file_,
- "%s",
- ior);
- ACE_OS::fclose (ior_output_file_);
- return true;
- }
- return false;
-}
-
-namespace CIAO
-{
- namespace Deployment
- {
- ComponentServer_Task::ComponentServer_Task (int argc, ACE_TCHAR **argv)
- : orb_ (0),
- uuid_ (""),
- callback_ior_str_ ("")
- {
- CIAO_TRACE ("CIAO_ComponentServer_Task::CIAO_ComponentServer_Task ()");
-
- Logger_Service
- *clf = ACE_Dynamic_Service<Logger_Service>::instance ("CIAO_Logger_Backend_Factory");
-
- if (!clf)
- clf = new Logger_Service;
-
- this->logger_.reset (clf);
-
- this->logger_->init (argc, argv);
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_ComponentServer_Task::CIAO_ComponentServer_Task - "
- "Creating server object\n"));
- Configurator_Factory cf;
- this->configurator_.reset (cf (argc, argv));
-
- if (!this->configurator_->create_config_managers ())
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "ComponentServer_Task::ComponentServer_Task - "
- "Error configuring ComponentServer configurator, exiting.\n"));
- throw Error ("Unable to load ComponentServer configurator.");
- }
-
- this->configurator_->pre_orb_initialize ();
-
- LWFT_Client_Init initializer;
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_ComponentServer_Task::CIAO_ComponentServer_Task - "
- "Creating ORB\n"));
- this->orb_ = initializer.init (argc, argv);
-
- AppOptions::instance ()->parse_args (argc, argv);
- AppOptions::instance ()->process_id (this->get_process_id ());
- AppOptions::instance ()->orb (CORBA::ORB::_duplicate (orb_.in ()));
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task - "
- "starting AppSideMonitor thread.\n"));
-
- int result = AppSideMonitor_Thread::instance ()->activate ();;
-
- if (result != 0)
- {
- CIAO_DEBUG ((LM_ERROR,
- CLINFO "CIAO_ComponentServer_Task::CIAO_ComponentServer_Task - "
- "AppSideMonitor_Thread::activate () returned %d\n",
- result));
- }
-
- this->configurator_->post_orb_initialize (this->orb_.in ());
-
- this->parse_args (argc, argv);
- this->configure_logging_backend ();
-
- CIAO::Server_init (this->orb_.in ());
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_ComponentServer_Task::CIAO_ComponentServer_Task - "
- "CIAO_ComponentServer object created.\n"));
- }
-
- int
- ComponentServer_Task::svc (void)
- {
- try
- {
- CIAO_TRACE ("ComponentServer_Task::svc");
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "Activating the root POA\n"));
-
- CORBA::Object_var object =
- this->orb_->resolve_initial_references ("RootPOA");
-
- PortableServer::POA_var root_poa =
- PortableServer::POA::_narrow (object.in ());
-
- PortableServer::POAManager_var poa_manager =
- root_poa->the_POAManager ();
-
- poa_manager->activate ();
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "Creating state synchronization servant\n"));
-
- // start up SSA
- StateSynchronizationAgent_i* ssa_servant = 0;
- ACE_NEW_NORETURN (ssa_servant, StateSynchronizationAgent_i (
- this->get_hostname (), // this has to be replaced by the
- this->get_process_id ())); // real hostname and process id
-
- if (ssa_servant == 0)
- {
- CIAO_ERROR ((LM_CRITICAL, "ComponentServer_Task::run - "
- "Out of memory error while allocating ssa servant."));
- throw Error ("Out of memory whilst allocating ssa servant.");
- }
-
- PortableServer::ServantBase_var safe_ssa (ssa_servant);
-
- // activate servant here
- StateSynchronizationAgent_var ssa (ssa_servant->_this ());
-
- 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 ());
-
- ReplicationManager_var rm = rmh.resolve ("ReplicationManager");
-
- rm->register_state_synchronization_agent (this->get_hostname ().c_str (),
- this->get_process_id ().c_str (),
- ssa);
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "Creating server implementation object\n"));
- CIAO::Deployment::CIAO_ComponentServer_i *ci_srv = 0;
- ACE_NEW_NORETURN (ci_srv, CIAO_ComponentServer_i (this->uuid_, this->orb_.in (), root_poa.in ()));
-
- if (ci_srv == 0)
- {
- CIAO_ERROR ((LM_CRITICAL, "ComponentServer_Task::run - "
- "Out of memory error while allocating servant."));
- throw Error ("Out of memory whilst allocating servant.");
- }
-
- PortableServer::ServantBase_var safe (ci_srv);
-
- ComponentServer_var cs (ci_srv->_this ());
-
- if (this->output_file_ != "")
- {
- CORBA::String_var ior = this->orb_->object_to_string (cs.in ());
- write_IOR (this->output_file_.c_str (), ior.in ());
- }
-
- if (this->callback_ior_str_ != "")
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO " resolving callback IOR\n"));
- CORBA::Object_ptr obj = this->orb_->string_to_object (this->callback_ior_str_.c_str ());
- ServerActivator_var sa (ServerActivator::_narrow (obj));
-
- if (CORBA::is_nil (sa.in ()))
- {
- CIAO_DEBUG ((LM_ERROR, CLINFO "ComponentServer_Task::svc - "
- "Failed to narrow callback IOR\n"));
- throw Error ("Failed to narrow callback IOR");
- }
-
- Components::ConfigValues_var config;
- {
- Components::ConfigValues *cf;
- ACE_NEW_NORETURN (cf, Components::ConfigValues (0));
-
- if (cf == 0)
- {
- CIAO_ERROR ((LM_CRITICAL, "ComponentServer_Task::run - "
- "Out of memory error while allocating config values\n"));
- }
- else config = cf;
- }
-
- // Make callback.
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "Making callback on my ServerActivator\n"));
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "Calling back to ServerActivator\n"));
-
- try
- {
- // Callback to NodeApplication to get configuration
- sa->component_server_callback (cs.in (),
- this->uuid_.c_str (),
- config.out ());
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "Configuration received\n"));
- // @@WO: Probably need to do something with these config values.
-
- ci_srv->init (sa.in (), config._retn ());
-
- CIAO_DEBUG ((LM_NOTICE, CLINFO "ComponentServer_Task::svc - "
- "Configuration complete for component server %s\n",
- this->uuid_.c_str ()));
-
- sa->configuration_complete (this->uuid_.c_str ());
- }
- catch (CORBA::BAD_PARAM &)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "ComponentServer_Task::svc - "
- "The Callback IOR provided pointed to the wrong ServerActivator\n"));
- throw Error ("Bad callback IOR");
- }
- catch (...)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "ComponentServer_Task::svc - "
- "Caught exception while calling back\n"));
- throw Error ("Caught exception while calling back");
- }
- }
- else
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "Initializing ComponentServer without ServantActivator callback\n"));
- ci_srv->init (0, 0);
- }
-
- this->orb_->run ();
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::svc - "
- "ORB Event loop completed.\n"));
-
- root_poa->destroy (1, 1);
-
- this->orb_->destroy ();
- return 0;
- }
- catch (CORBA::Exception & ex)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "ComponentServer_Task::svc - "
- "caught: %s.\n", ex._info ().c_str ()));
- }
- catch (Name_Helper_Exception & ex)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "ComponentServer_Task::svc - "
- "Name helper exception: %s\n", ex.what ()));
- }
-
- return -1;
- }
-
- void
- ComponentServer_Task::run (void)
- {
- CIAO_TRACE ("ComponentServer_Task::run");
-
- if (this->configurator_->rt_support ())
- {
- CIAO_DEBUG ((LM_DEBUG, CLINFO "ComponentServer_Task::run - Starting ORB with RT support\n"));
-
- this->check_supported_priorities ();
-
- // spawn a thread
- // Task activation flags.
- long flags =
- THR_NEW_LWP |
- THR_JOINABLE |
- this->orb_->orb_core ()->orb_params ()->thread_creation_flags ();
-
- // Activate task.
- int result =
- this->activate (flags);
- if (result == -1)
- {
- if (errno == EPERM)
- {
- CIAO_ERROR ((LM_EMERGENCY, CLINFO
- "ComponentServer_Task::run - Cannot create thread with scheduling policy %s\n"
- "because the user does not have the appropriate privileges, terminating program. "
- "Check svc.conf options and/or run as root\n",
- sched_policy_name (this->orb_->orb_core ()->orb_params ()->ace_sched_policy ())));
- throw Error ("Unable to start RT support due to permissions problem.");
- }
- else
- throw Error ("Unknown error while spawning ORB thread.");
- }
-
- // Wait for task to exit.
- result =
- this->wait ();
-
- if (result != -1)
- throw Error ("Unknown error waiting for ORB thread to complete");
-
- CIAO_DEBUG ((LM_INFO, CLINFO "ComponentServer_Task::run - ORB thread completed, terminating ComponentServer %s\n",
- this->uuid_.c_str ()));
- }
- else
- {
- CIAO_DEBUG ((LM_DEBUG, CLINFO "ComponentServer_Task::run - Starting ORB without RT support\n"));
- this->svc ();
- CIAO_DEBUG ((LM_INFO, CLINFO "ComponentServer_Task::run - ORB has shutdown, terminating ComponentServer \n"));
- }
- }
-
- void
- ComponentServer_Task::parse_args (int argc, ACE_TCHAR **argv)
- {
- CIAO_TRACE ("ComponentServer_Task::parse_args");
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::parse_args - parsing arguments...\n"));
-
- ACE_Get_Opt opts (argc, argv, "hu:c:", 1, 0,
- ACE_Get_Opt::RETURN_IN_ORDER);
- opts.long_option ("uuid", 'u', ACE_Get_Opt::ARG_REQUIRED);
- opts.long_option ("callback-ior", 'c', ACE_Get_Opt::ARG_REQUIRED);
- opts.long_option ("help", 'h');
- opts.long_option ("log-level",'l', ACE_Get_Opt::ARG_REQUIRED);
- opts.long_option ("trace",'t', ACE_Get_Opt::NO_ARG);
- opts.long_option ("output-ior",'o', ACE_Get_Opt::ARG_REQUIRED);
-
- //int j;
- char c;
- ACE_CString s;
-
- while ((c = opts ()) != -1)
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::parse_args - "
- "Found option: \"%s\" with argument \"%s\"\n",
- opts.last_option (), opts.opt_arg ()));
-
- switch (c)
- {
- case 'u':
- CIAO_DEBUG ((LM_DEBUG, CLINFO "ComponentServer_Task::parse_args - "
- "uuid is %s\n",
- opts.opt_arg ()));
- this->uuid_ = opts.opt_arg ();
- break;
-
- case 'c':
- CIAO_DEBUG ((LM_DEBUG, CLINFO "ComponentServer_Task::parse_args - "
- "callback ior is %s\n",
- opts.opt_arg ()));
- this->callback_ior_str_ = opts.opt_arg ();
- break;
-
- case 'l':
- {
- continue; // no-op, already taken care of
- }
-
- case 't':
- continue; // already taken care of
-
- case 'o':
- CIAO_DEBUG ((LM_DEBUG, CLINFO "ComponentServer_Task::parse_args - "
- "IOR Output file: %s\n",
- opts.opt_arg ()));
- this->output_file_ = opts.opt_arg ();
- break;
-
- case 'h':
- this->usage ();
- throw Error ("Command line help requested, bailing out....");
-
- default:
- CIAO_ERROR ((LM_ERROR, CLINFO " Unknown option: %s\n",
- opts.last_option ()));
- this->usage ();
- ACE_CString err ("Unknown option ");
- err += opts.last_option ();
- throw Error (err);
- }
- }
-
- // check required options.
- if (this->uuid_ == "")
- throw Error ("Option required: -u|--uuid");
- if (this->callback_ior_str_ == "")
- CIAO_ERROR ((LM_WARNING, CLINFO
- "ComponentServer_Task::parse_args - Starting ComponentServer without a callback IOR\n"));
- }
-
- void
- ComponentServer_Task::usage (void)
- {
- CIAO_TRACE ("ComponentServer_Task::usage");
- // Shouldn't be subject to CIAO's logging policy
- ACE_ERROR ((LM_EMERGENCY, "Usage: CIAO_ComponentServer <options>\n"
- "Options: \n"
- "\t-h|--help\t\t\t\tShow help\n"
- "\t-l|--log-level <level>\t\t\tSets log level (default 5). 1 - most detailed.\n"
- "\t-u|--uuid <uuid> \t\t\tSets UUID of spawned component server (required)\n"
- "\t-c|--callback-ior <string ior>\t\tSets callback url for the spawning ServerActivator.\n"
- "\t-o|--output-ior <filename>\t\tOutputs the IOR of the component server object to file\n"
- ));
-
- }
-
- const char *
- ComponentServer_Task::sched_policy_name (int sched_policy)
- {
- const char *name = 0;
-
- switch (sched_policy)
- {
- case ACE_SCHED_OTHER:
- name = "SCHED_OTHER";
- break;
- case ACE_SCHED_RR:
- name = "SCHED_RR";
- break;
- case ACE_SCHED_FIFO:
- name = "SCHED_FIFO";
- break;
- }
-
- return name;
- }
-
- /// The following check is taken from $(TAO_ROOT)/tests/RTCORBA/
- void
- ComponentServer_Task::check_supported_priorities (void)
- {
- CIAO_TRACE ("ComponentServer_Task::check_supported_priorities");
-
- int const sched_policy =
- this->orb_->orb_core ()->orb_params ()->ace_sched_policy ();
-
- // Check that we have sufficient priority range to run,
- // i.e., more than 1 priority level.
- int const max_priority =
- ACE_Sched_Params::priority_max (sched_policy);
- int const min_priority =
- ACE_Sched_Params::priority_min (sched_policy);
-
- if (max_priority == min_priority)
- {
- CIAO_DEBUG ((LM_DEBUG, CLINFO "ComponentServer_Task::check_supported_priorities - "
- " Not enough priority levels with the %s scheduling policy\n"
- "on this platform to run, terminating ....\n"
- "Check svc.conf options\n",
- sched_policy_name (sched_policy)));
-
- throw Error ("Bad scheduling policy.");
- }
- }
-
- void
- ComponentServer_Task::configure_logging_backend (void)
- {
- Logger_Service
- *clf = ACE_Dynamic_Service<Logger_Service>::instance ("CIAO_Logger_Backend_Factory");
- if (clf)
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Task::configure_logging_backend - "
- "Replacing logger backend\n"));
- ACE_Log_Msg_Backend * backend = clf->get_logger_backend(this->orb_);
- backend->open(0);
- ACE_Log_Msg::msg_backend (backend);
- ACE_Log_Msg * ace = ACE_Log_Msg::instance();
- ace->clr_flags(ace->flags());
- ace->set_flags(ACE_Log_Msg::CUSTOM);
- }
- }
-
- std::string
- ComponentServer_Task::get_hostname ()
- {
- char hostname [100];
- gethostname (hostname, sizeof (hostname));
-
- return std::string (hostname);;
- }
-
- std::string
- ComponentServer_Task::get_process_id ()
- {
- pid_t pid = ACE_OS::getpid ();
- std::stringstream ss;
- ss << pid;
-
- return ss.str ();
- }
-
- std::string
- ComponentServer_Task::get_obj_path ()
- {
- std::string path;
- path += ("FLARe/");
- std::string hostname = this->get_hostname ();
-
- // replace all dots in the hostname with escaped dots for
- //to_name conversion.
- for (size_t pos = hostname.find ('.', 0);
- pos < hostname.length ();
- pos = hostname.find ('.', pos))
- {
- hostname.replace (pos, 1, "\\.");
- pos += 2;
- }
-
- path += hostname;
- path += "/";
- path += this->get_process_id ();
-
- return path;
- }
-
- }
-}
-
-
diff --git a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.h b/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.h
deleted file mode 100644
index 24a8ca4f484..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer.h
+++ /dev/null
@@ -1,78 +0,0 @@
-/**
- * @file CIAO_ComponentServer.h
- * @author William R. Otte
- *
- * Defines interface for the bootstrap element of the CIAO Component
- * Server.
- */
-
-#ifndef CIAO_COMPONENTSERVER_H_
-#define CIAO_COMPONENTSERVER_H_
-
-#include "ace/String_Base.h"
-#include "ace/Task.h"
-#include "tao/ORB.h"
-#include "ciao/Logger/Logger_Service.h"
-#include "orbsvcs/CosNamingC.h"
-
-class StateSynchronizationAgent;
-
-namespace CIAO
-{
- namespace Deployment
- {
- class ComponentServer_Configurator;
-
-
- class ComponentServer_Task : ACE_Task_Base
- {
- public:
- ComponentServer_Task (int argc, ACE_TCHAR **argv);
-
- int svc (void);
-
- struct Error
- {
- Error (const ACE_CString &err) : err_(err) {}
-
- ACE_CString err_;
- };
-
- void run (void);
-
- private:
- void parse_args (int argc, ACE_TCHAR **argv);
-
- void get_log_level (int argc, ACE_TCHAR **argv);
-
- void set_log_level (void);
-
- void configure_logging_backend (void);
-
- void usage (void);
-
- const char * sched_policy_name (int sched_policy);
-
- void check_supported_priorities (void);
-
- /// helper functions for naming service operations
- std::string get_hostname ();
-
- std::string get_process_id ();
-
- std::string get_obj_path ();
-
- CORBA::ORB_var orb_;
-
- auto_ptr<CIAO::Logger_Service> logger_;
-
- ACE_CString uuid_;
- ACE_CString callback_ior_str_;
- ACE_CString output_file_;
- auto_ptr<ComponentServer_Configurator> configurator_;
-
- };
- }
-}
-
-#endif
diff --git a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_Impl.cpp b/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_Impl.cpp
deleted file mode 100644
index bd0cd957d99..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_Impl.cpp
+++ /dev/null
@@ -1,269 +0,0 @@
-#include "CIAO_FTComponentServer_Impl.h"
-
-#include "ciao/CIAO_common.h"
-
-#include "CIAO_CS_ClientC.h"
-#include "CIAO_Container_Impl.h"
-//#include "tao/RTCORBA/RTCORBA.h"
-
-const size_t CS_DEFAULT_PRIORITY = 0;
-
-namespace CIAO
-{
- namespace Deployment
- {
- CIAO_ComponentServer_i::CIAO_ComponentServer_i (const ACE_CString &uuid,
- CORBA::ORB_ptr orb,
- PortableServer::POA_ptr poa)
- : uuid_ (uuid),
- orb_ (CORBA::ORB::_duplicate (orb)),
- poa_ (PortableServer::POA::_duplicate (poa)),
- containers_ ()
- {
- CIAO_TRACE("CIAO_ComponentServer_i::CIAO_ComponentServer_i");
- }
-
- // Destructor
- CIAO_ComponentServer_i::~CIAO_ComponentServer_i (void)
- {
- CIAO_TRACE("CIAO_ComponentServer_i::~CIAO_ComponentServer_i");
- }
-
-
- void
- CIAO_ComponentServer_i::shutdown (void)
- {
- CIAO_TRACE("CIAO_ComponentServer_i::shutdown");
-
- CIAO_DEBUG ((LM_DEBUG, CLINFO "CIAO_ComponentServer_i::shutdown - ORB shutdown request received at %s.\n",
- this->uuid_.c_str ()));
-
- if (!this->containers_.is_empty ())
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_ComponentServer_i::shutdown - ComponentServer %s still containers!\n",
- this->uuid_.c_str ()));
-
- this->orb_->shutdown ();
- }
-
-
- ::Components::ConfigValues *
- CIAO_ComponentServer_i::configuration (void)
- {
- CIAO_TRACE("CIAO_ComponentServer_i::configuration");
- return this->config_values_.out ();
- }
-
-
- ::Components::Deployment::ServerActivator_ptr
- CIAO_ComponentServer_i::get_server_activator (void)
- {
- CIAO_TRACE("CIAO_ComponentServer_i::get_server_activator");
- return this->serv_act_.in ();
- }
-
-
- ::Components::Deployment::Container_ptr
- CIAO_ComponentServer_i::create_container (const ::Components::ConfigValues & config)
- {
- CIAO_TRACE("CIAO_ComponentServer_i::create_container");
-
- try
- {
- CIAO_DEBUG ((LM_INFO, CLINFO "CIAO_ComponentServer_i::create_container - Request received with %u config values\n",
- config.length ()));
-
- CORBA::PolicyList policies (0);
-
- // get RT ORB and set client_propagated priority
- /*
- CORBA::Object_var obj = orb_->resolve_initial_references ("RTORB");
- RTCORBA::RTORB_var rtorb = RTCORBA::RTORB::_narrow (obj);
-
- CORBA::PolicyList policies (1);
-
- if (!CORBA::is_nil (rtorb))
- {
- policies.length (1);
- policies[0] = RTCORBA::PriorityModelPolicy::_duplicate (rtorb->create_priority_model_policy (
- RTCORBA::CLIENT_PROPAGATED,
- CS_DEFAULT_PRIORITY));
- }
- */
- const char *name = 0;
-
- CIAO_Container_i *cont = 0;
- ACE_NEW_THROW_EX (cont,
- CIAO_Container_i (config, 0, name, &policies, this->orb_.in (), this->poa_.in ()),
- CORBA::NO_MEMORY ());
-
- CIAO_DEBUG ((LM_DEBUG, CLINFO "CIAO_ComponentServer_i::create_container - "
- "Container servant successfully allocated.\n"));
-
- PortableServer::ServantBase_var safe_config = cont;
- CIAO::Deployment::Container_var cont_var = cont->_this ();
-
- this->containers_.insert (CIAO::Deployment::Container::_duplicate(cont_var.in ()));
-
- CIAO_DEBUG ((LM_INFO, CLINFO "CIAO_ComponentServer_i::create_container - Container successfully activated and stored,"
- "now manage %u containers\n",
- this->containers_.size ()));
-
- return cont_var._retn ();
- }
- catch (CORBA::NO_MEMORY &)
- {
- CIAO_ERROR ((LM_CRITICAL, CLINFO "CIAO_ComponentServer_Impl: Out of memory exception whilst creating container.\n"));
- throw;
- }
- catch (...)
- {
- CIAO_ERROR ((LM_ERROR, "CIAO_ComponentServer_Impl: Caught unknown exception\n"));
- }
-
- throw Components::CreateFailure ();
- }
-
-
-
- void
- CIAO_ComponentServer_i::remove_container (::Components::Deployment::Container_ptr cref)
- {
- CIAO_TRACE("CIAO_ComponentServer_i::remove_container");
-
- CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_ComponentServer_i::remove_container - remove request received.\n"));
-
- if (CORBA::is_nil (cref))
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ComponentServer_i::remove_container - "
- "Error: Received nil container reference\n"));
- throw Components::RemoveFailure ();
- }
-
-
- if (this->containers_.is_empty ())
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ComponentServer_i::remove_container - "
- "Error: I don't manage any containers!\n"));
- throw Components::RemoveFailure ();
- }
-
-
- try
- {
- CONTAINERS::ITERATOR i (this->containers_.begin ());
-
- // @@ TODO: artifact from when this was a sequence, should probably use .find,
- // which will work properly with the new parameterized set class.
- for (CONTAINERS::iterator i = this->containers_.begin ();
- i.done () != 1; i.advance ())
- {
- if (CORBA::is_nil (*i))
- {
- ACE_ERROR ((LM_WARNING, CLINFO
- "CIAO_ComponentServer_i::remove_container - "
- "Managed container reference is nil, skipping.\n"));
- continue;
- }
-
- if ((*i)->_is_equivalent (cref))
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_ComponentServer_i::remove_container - Found container, invoking remove....\n"));
- cref->remove ();
- if (this->containers_.remove (*i) != 0)
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ComponentServer_i::remove_container - Unable to remove "
- "container reference from internal structure....\n"));
- CIAO_DEBUG ((LM_TRACE, CLINFO "CIAO_ComponentServer_i::remove_container - Remove completed, destroying object, "
- "now manage %u containers\n", this->containers_.size ()));
- return;
- }
- }
- }
- catch (CORBA::Exception &ex)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_ComponentServer_i::remove_container - "
- "Caught CORBA exception whilst removing container: %s\n",
- ex._info ().c_str ()));
- }
-
- catch (...)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO "CIAO_ComponentServer_i::remove_container - Error: Unknown exception caught while removing a container.\n"));
- }
- throw Components::RemoveFailure ();
- }
-
-
- ::Components::Deployment::Containers *
- CIAO_ComponentServer_i::get_containers (void)
- {
- CIAO_TRACE("CIAO_ComponentServer_i::get_containers");
-
- ::Components::Deployment::Containers *tmp(0);
- // tmp = new ::Components::Deployment::Containers ();
- ACE_NEW_THROW_EX (tmp,
- ::Components::Deployment::Containers (this->containers_.size ()),
- CORBA::NO_MEMORY ());
-
- ::Components::Deployment::Containers_var retval (tmp);
- CORBA::ULong pos (0);
- retval->length (this->containers_.size ());
-
- for (CONTAINERS::iterator i = this->containers_.begin ();
- i.done () != 1; i.advance ())
- {
- retval[pos++] = ::CIAO::Deployment::Container::_duplicate (*i);
- }
-
- return retval._retn ();
- }
-
-
- void
- CIAO_ComponentServer_i::remove (void)
- {
- CIAO_TRACE("CIAO_ComponentServer_i::remove");
-
- bool successful = true;
-
- for (CONTAINERS::iterator i = this->containers_.begin ();
- i.done () != 1; i.advance ())
- {
- try
- {
- (*i)->remove ();
- }
- catch (CORBA::Exception &ex)
- {
- successful = false;
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ComponentServer_i::remove - "
- "Intercepted CORBA exception while trying to remove a container:%s\n",
- ex._info ().c_str ()));
- }
- catch (...)
- {
- successful = false;
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ComponentServer_i::remove - "
- "Intercepted exception while trying to remove a container\n"));
- }
- }
-
- this->containers_.reset ();
-
- if (!successful)
- throw ::Components::RemoveFailure ();
- }
-
- void
- CIAO_ComponentServer_i::init (::Components::Deployment::ServerActivator_ptr sa,
- Components::ConfigValues *cvs)
- {
- this->serv_act_ = ::Components::Deployment::ServerActivator::_duplicate(sa);
- this->config_values_ = cvs;
- }
- }
-}
diff --git a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_Impl.h b/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_Impl.h
deleted file mode 100644
index 63ed835a644..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_Impl.h
+++ /dev/null
@@ -1,78 +0,0 @@
-/**
- * @file CIAO_ComponentServer.h
- * @author William R. Otte <wotte@dre.vanderbilt.edu>
- */
-
-#ifndef CIAO_COMPONENTSERVER_IMPL_H_
-#define CIAO_COMPONENTSERVER_IMPL_H_
-
-#include "ciao/ComponentServer/CIAO_ComponentServerS.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-#pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "ace/String_Base.h"
-#include "ace/Unbounded_Set_Ex.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- class CIAO_ComponentServer_svnt_Export CIAO_ComponentServer_i
- : public virtual POA_CIAO::Deployment::ComponentServer
- {
- public:
- // Constructor
- CIAO_ComponentServer_i (const ACE_CString &uuid, CORBA::ORB_ptr orb, PortableServer::POA_ptr poa);
-
- // Destructor
- virtual ~CIAO_ComponentServer_i (void);
-
- virtual void shutdown (void);
-
- virtual ::Components::ConfigValues * configuration (void);
-
- virtual
- ::Components::Deployment::ServerActivator_ptr get_server_activator (void);
-
- virtual
- ::Components::Deployment::Container_ptr create_container (const ::Components::ConfigValues & config);
-
- virtual
- void remove_container (::Components::Deployment::Container_ptr cref);
-
- virtual
- ::Components::Deployment::Containers * get_containers (void);
-
- virtual
- void remove (void);
-
- void init (::Components::Deployment::ServerActivator_ptr sa,
- Components::ConfigValues *cvs);
-
- private:
- ACE_CString uuid_;
- CORBA::ORB_var orb_;
- PortableServer::POA_var poa_;
- ::Components::Deployment::ServerActivator_var serv_act_;
- Components::ConfigValues_var config_values_;
-
- template<typename T>
- struct _is_equivalent
- {
- bool operator() (const T &a, const T &b) const
- {
- return a->_is_equivalent (const_cast <T&> (b));
- }
- };
-
- typedef ACE_Unbounded_Set_Ex <Container_var,
- _is_equivalent<Container_var> > CONTAINERS;
-
- CONTAINERS containers_;
- };
- }
-}
-
-#endif
diff --git a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_stub_export.h b/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_stub_export.h
deleted file mode 100644
index 8f5dddc8c9e..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_stub_export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl CIAO_FTComponentServer_stub
-// ------------------------------
-#ifndef CIAO_FTCOMPONENTSERVER_STUB_EXPORT_H
-#define CIAO_FTCOMPONENTSERVER_STUB_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL)
-# define CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL */
-
-#if !defined (CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL)
-# define CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL 1
-#endif /* ! CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL */
-
-#if defined (CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL) && (CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL == 1)
-# if defined (CIAO_FTCOMPONENTSERVER_STUB_BUILD_DLL)
-# define CIAO_FTComponentServer_stub_Export ACE_Proper_Export_Flag
-# define CIAO_FTCOMPONENTSERVER_STUB_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define CIAO_FTCOMPONENTSERVER_STUB_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* CIAO_FTCOMPONENTSERVER_STUB_BUILD_DLL */
-# define CIAO_FTComponentServer_stub_Export ACE_Proper_Import_Flag
-# define CIAO_FTCOMPONENTSERVER_STUB_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define CIAO_FTCOMPONENTSERVER_STUB_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* CIAO_FTCOMPONENTSERVER_STUB_BUILD_DLL */
-#else /* CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL == 1 */
-# define CIAO_FTComponentServer_stub_Export
-# define CIAO_FTCOMPONENTSERVER_STUB_SINGLETON_DECLARATION(T)
-# define CIAO_FTCOMPONENTSERVER_STUB_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* CIAO_FTCOMPONENTSERVER_STUB_HAS_DLL == 1 */
-
-// Set CIAO_FTCOMPONENTSERVER_STUB_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (CIAO_FTCOMPONENTSERVER_STUB_NTRACE)
-# if (ACE_NTRACE == 1)
-# define CIAO_FTCOMPONENTSERVER_STUB_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define CIAO_FTCOMPONENTSERVER_STUB_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !CIAO_FTCOMPONENTSERVER_STUB_NTRACE */
-
-#if (CIAO_FTCOMPONENTSERVER_STUB_NTRACE == 1)
-# define CIAO_FTCOMPONENTSERVER_STUB_TRACE(X)
-#else /* (CIAO_FTCOMPONENTSERVER_STUB_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define CIAO_FTCOMPONENTSERVER_STUB_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (CIAO_FTCOMPONENTSERVER_STUB_NTRACE == 1) */
-
-#endif /* CIAO_FTCOMPONENTSERVER_STUB_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_svnt_export.h b/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_svnt_export.h
deleted file mode 100644
index ecd2a4ba8e4..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_FTComponentServer_svnt_export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl CIAO_FTComponentServer_svnt
-// ------------------------------
-#ifndef CIAO_FTCOMPONENTSERVER_SVNT_EXPORT_H
-#define CIAO_FTCOMPONENTSERVER_SVNT_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL)
-# define CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL */
-
-#if !defined (CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL)
-# define CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL 1
-#endif /* ! CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL */
-
-#if defined (CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL) && (CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL == 1)
-# if defined (CIAO_FTCOMPONENTSERVER_SVNT_BUILD_DLL)
-# define CIAO_FTComponentServer_svnt_Export ACE_Proper_Export_Flag
-# define CIAO_FTCOMPONENTSERVER_SVNT_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define CIAO_FTCOMPONENTSERVER_SVNT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* CIAO_FTCOMPONENTSERVER_SVNT_BUILD_DLL */
-# define CIAO_FTComponentServer_svnt_Export ACE_Proper_Import_Flag
-# define CIAO_FTCOMPONENTSERVER_SVNT_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define CIAO_FTCOMPONENTSERVER_SVNT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* CIAO_FTCOMPONENTSERVER_SVNT_BUILD_DLL */
-#else /* CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL == 1 */
-# define CIAO_FTComponentServer_svnt_Export
-# define CIAO_FTCOMPONENTSERVER_SVNT_SINGLETON_DECLARATION(T)
-# define CIAO_FTCOMPONENTSERVER_SVNT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* CIAO_FTCOMPONENTSERVER_SVNT_HAS_DLL == 1 */
-
-// Set CIAO_FTCOMPONENTSERVER_SVNT_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (CIAO_FTCOMPONENTSERVER_SVNT_NTRACE)
-# if (ACE_NTRACE == 1)
-# define CIAO_FTCOMPONENTSERVER_SVNT_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define CIAO_FTCOMPONENTSERVER_SVNT_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !CIAO_FTCOMPONENTSERVER_SVNT_NTRACE */
-
-#if (CIAO_FTCOMPONENTSERVER_SVNT_NTRACE == 1)
-# define CIAO_FTCOMPONENTSERVER_SVNT_TRACE(X)
-#else /* (CIAO_FTCOMPONENTSERVER_SVNT_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define CIAO_FTCOMPONENTSERVER_SVNT_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (CIAO_FTCOMPONENTSERVER_SVNT_NTRACE == 1) */
-
-#endif /* CIAO_FTCOMPONENTSERVER_SVNT_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/CIAO_Properties.idl b/CIAO/ciao/FTComponentServer/CIAO_Properties.idl
deleted file mode 100644
index 6f0cf0e47e1..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_Properties.idl
+++ /dev/null
@@ -1,29 +0,0 @@
-/**
- * @file CIAO_Properties.idl
- * @author William R. Otte
- * $Id$
- * Standardizes names of configvalues used by CIAO.
- */
-
-#ifndef CIAO_PROPERTIES_IDL
-#define CIAO_PROPERTIES_IDL
-
-module CIAO
-{
- module Deployment
- {
- const string SVNT_ENTRYPT = "edu.vanderbilt.dre.CIAO.ServantEntrypoint";
- const string SVNT_ARTIFACT = "edu.vanderbilt.dre.CIAO.ServantArtifact";
- const string EXEC_ARTIFACT = "edu.vanderbilt.dre.CIAO.ExecutorArtifact";
- const string SERVER_RESOURCES = "edu.vanderbilt.dre.CIAO.ServerResources";
- const string SERVER_UUID = "edu.vanderbilt.dre.CIAO.ServerUUID";
- const string SERVER_EXECUTABLE = "edu.vanderbilt.dre.CIAO.ComponentServerExecutable";
- const string SERVER_ARGUMENTS = "edu.vanderbilt.dre.CIAO.ComponentServerArgs";
- const string SERVER_TIMEOUT = "edu.vanderbilt.dre.CIAO.ServerTimeout";
- const string SERVER_MULTITHREAD = "edu.vanderbilt.dre.CIAO.Multithreaded";
- const string REGISTER_NAMING = "edu.vanderbilt.dre.CIAO.RegisterNaming";
- const string OBJECT_ID = "edu.vanderbilt.dre.CIAO.ObjectId";
-
- };
-};
-#endif /* CIAO_PROPERTIES_IDL */
diff --git a/CIAO/ciao/FTComponentServer/CIAO_ServerActivator_Impl.cpp b/CIAO/ciao/FTComponentServer/CIAO_ServerActivator_Impl.cpp
deleted file mode 100644
index cb4e5c5a9a0..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_ServerActivator_Impl.cpp
+++ /dev/null
@@ -1,530 +0,0 @@
-// $Id$
-#include "CIAO_ServerActivator_Impl.h"
-
-#include "ace/Log_Msg.h"
-#include "ace/UUID.h"
-#include "ciao/CIAO_common.h"
-#include "ciao/Client_init.h"
-#include "ciao/CIAO_FailureReasonsC.h"
-
-#include "CIAO_ServerResourcesC.h"
-#include "CIAO_ComponentServerC.h"
-#include "CIAO_PropertiesC.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- CIAO_ServerActivator_i::CIAO_ServerActivator_i (CORBA::ULong def_spawn_delay,
- const char * default_cs_path,
- const char * cs_args,
- bool multithreaded,
- CORBA::ORB_ptr orb,
- PortableServer::POA_ptr poa)
- : spawn_delay_ (def_spawn_delay),
- multithreaded_ (multithreaded),
- orb_ (CORBA::ORB::_duplicate (orb)),
- poa_ (PortableServer::POA::_duplicate (poa)),
- cs_path_ (default_cs_path),
- cs_args_ (cs_args),
- mutex_ (),
- condition_ (mutex_)
- {
- CIAO_TRACE (CLINFO "CIAO_ServerActivator_i::CIAO_ServerActivator_i");
- }
-
- CIAO_ServerActivator_i::~CIAO_ServerActivator_i(void)
- {
- }
-
- void
- CIAO_ServerActivator_i::component_server_callback (::Components::Deployment::ComponentServer_ptr serverref,
- const char * server_UUID,
- ::Components::ConfigValues_out config)
- {
- CIAO_TRACE(CLINFO "CIAO_ServerActivator_i::component_server_callback");
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::component_server_callback - "
- "Received callback from ComponentServer %C\n",
- server_UUID));
-
- if (this->server_infos_.is_empty ())
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::component_server_callback - "
- "Received callback from ComponentServer %C, but I don't manage any.\n",
- server_UUID));
- throw CORBA::BAD_PARAM ();
- }
-
- //SERVER_INFOS::iterator i (this->server_infos_.begin ());
- //i.first ();
- Server_Info *info = 0;
-
- for (SERVER_INFOS::iterator i (this->server_infos_.begin ());
- !i.done (); ++i)
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::component_server_callback - "
- "Comparing %C with %C\n", (*i)->uuid_.c_str (), server_UUID));
- if ((*i)->uuid_ == server_UUID)
- {
- info = (*i).get ();
- }
- }
-
- if (info == 0)
- { CIAO_ERROR ((LM_WARNING, CLINFO
- "CIAO_ServerActivator_i::component_server_callback - "
- "Received callback from ComponentServer %C, which doesn't belong to me.\n",
- server_UUID));
- throw CORBA::BAD_PARAM ();
- }
-
- if (info->activated_)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::component_server_callback - "
- "Received callback from ComponentServer %C, which has already been configured.\n",
- server_UUID));
- throw CORBA::BAD_INV_ORDER ();
- }
-
- if (!CORBA::is_nil (info->ref_))
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::component_server_callback - "
- "Received callback from ComponentServer %C, which has already called back.\n",
- server_UUID));
- throw CORBA::BAD_INV_ORDER ();
- }
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::component_server_callback - "
- "Received callback from ComponentServer %C\n",
- server_UUID));
-
- info->ref_ = ::Components::Deployment::ComponentServer::_duplicate (serverref);
-
- this->create_component_server_config_values (*info, config);
-
- // @@TODO: May want to print out configvalues here.
- CIAO_DEBUG ((LM_DEBUG, CLINFO
- "CIAO_ServerActivator_i::component_server_callback - "
- "Generated %u ConfigValues for ComponentServer %C\n",
- config->length (), server_UUID));
- }
-
- void
- CIAO_ServerActivator_i::configuration_complete (const char *server_UUID)
- {
- CIAO_TRACE (CLINFO "CIAO_ServerActivator_i::configuration_complete");
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::configuration_complete - "
- "Received configuration_complete from ComponentServer %C\n",
- server_UUID));
-
- try
- {
- if (this->server_infos_.is_empty ())
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::configuration_complete - "
- "Received callback from ComponentServer %C, but I don't manage any.\n",
- server_UUID));
- throw CORBA::BAD_PARAM ();
- }
-
- Server_Info *info = 0;
-
- for (SERVER_INFOS::ITERATOR j (this->server_infos_);
- !j.done (); ++j)
- {
- if ((*j)->uuid_ == server_UUID)
- {
- info = (*j).get ();
- }
- }
-
- if (info == 0)
- {
- CIAO_ERROR ((LM_WARNING, CLINFO
- "CIAO_ServerActivator_i::configuration_complete - "
- "Received configuration_complete from ComponentServer %C, which doesn't belong to me.\n",
- server_UUID));
- throw CORBA::BAD_PARAM ();
- }
-
- if (info->activated_)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::configuration_complete - "
- "Received configuration_complete from ComponentServer %C, which has already been completed.\n",
- server_UUID));
- throw CORBA::BAD_INV_ORDER ();
- }
-
- if (CORBA::is_nil (info->ref_.in ()))
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::configuration_complete - "
- "Received configuration_complete from ComponentServer %C, which has not called back.\n",
- server_UUID));
- throw CORBA::BAD_INV_ORDER ();
- }
-
- info->activated_ = true;
- }
- catch (...)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::configuration_complete - "
- "Caught unknown exception while processing configuration_complete\n"));
- throw;
- }
- }
-
- ::Components::Deployment::ComponentServer_ptr
- CIAO_ServerActivator_i::create_component_server (const ::Components::ConfigValues & config)
- {
- CIAO_TRACE(CLINFO "CIAO_ServerActivator_i::create_component_server");
-
- Safe_Server_Info server (new Server_Info (config.length () + 1));
-
- CIAO::Utility::build_config_values_map (*server->cmap_, config);
-
- ACE_CString cmd_options = this->construct_command_line (*server);
-
- CIAO_DEBUG ((LM_DEBUG, CLINFO
- "CIAO_ServerActivator_i::create_component_server - ComponentServer arguments: %C\n",
- cmd_options.c_str ()));
-
- server_infos_.insert_tail (server);
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::create_component_server - "
- "Attempting to spawn ComponentServer with UUID %C\n",
- server->uuid_.c_str ()));
- // Now we need to get a copy of the one that was inserted...
- pid_t pid = this->spawn_component_server (*server, cmd_options);
- ACE_UNUSED_ARG (pid);
-
- ACE_Time_Value timeout (this->spawn_delay_);
-
- CORBA::Any val;
-
- if (server->cmap_->find (SERVER_TIMEOUT, val) == 0)
- {
- CORBA::ULong t;
- if (val >>= t)
- {
- CIAO_DEBUG ((LM_DEBUG, CLINFO "CIAO_ServerActivator_i::create_component_server - "
- "Using provided non-default server timeout of %u\n", t));
- timeout = ACE_Time_Value (t);
- }
- else
- {
- CIAO_ERROR ((LM_WARNING, CLINFO "CIAO_ServerActivator_i::create_component_server - "
- "Failed to extract provided non-default server timeout from property '%C', "
- "falling back to default timeout of %u\n",
- this->spawn_delay_));
- }
- }
-
- if (this->multithreaded_)
- this->multi_threaded_wait_for_callback (*server, timeout/*, pid*/);
- else
- this->single_threaded_wait_for_callback (*server, timeout/*, pid*/);
-
- CIAO_DEBUG ((LM_DEBUG, CLINFO
- "CIAO_ServerActivator_i::create_component_server - "
- "ComponentServer %C successfully spawned and configured!\n",
- server->uuid_.c_str ()));
-
- return ::Components::Deployment::ComponentServer::_duplicate (server->ref_.in ());
- }
-
- ACE_CString
- CIAO_ServerActivator_i::construct_command_line (Server_Info &server)
- {
- CIAO_TRACE (CLINFO "CIAO_ServerActivator_i::construct_command_line");
- // Build our command line to launch the compoent server
- ACE_CString cmd_options (this->cs_args_);
-
- CORBA::Any val;
-
- if (server.cmap_->find (SERVER_UUID, val) == 0)
- {
- // Nodeapplication has requested a custom uuid
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::construct_command_line - Using provided UUID\n"));
- const char *uuid = 0;
- val >>= uuid;
- server.uuid_ = uuid;
- }
- else
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::construct_command_line - Using generated UUID\n"));
- ACE_Utils::UUID uuid;
- ACE_Utils::UUID_GENERATOR::instance ()->generate_UUID (uuid);
- server.uuid_ = *uuid.to_string ();
- }
-
- CIAO_DEBUG ((LM_DEBUG, CLINFO
- "CIAO_ServerActivator_i::construct_command_line - Creating component server "
- " with UUID %C\n", server.uuid_.c_str ()));
-
- cmd_options += " -u ";
- cmd_options += server.uuid_;
-
- if (server.cmap_->find (SERVER_RESOURCES, val) == 0)
- {
- // There may be command line arguments specified in the plan
- ServerResource_var sr;
- val >>= sr;
-
- // If command line options are specified through RTCCM descriptors,
- // then we should honor these command line options as well.
- for (CORBA::ULong arg_i = 0;
- arg_i < sr->args.length ();
- ++arg_i)
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::construct_command_line - Adding argument %C from ServerResource\n ",
- sr->args[arg_i].in ()));
- cmd_options += " "; // space between command line args
- cmd_options += sr->args[arg_i];
- }
-
- // If service configuration file is specified through RTCCM
- // descriptors, then we should honor it as well.
- if (ACE_OS::strcmp (sr->svcconf.in (),
- "") != 0)
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::construct_command_line - Using SvcConf file %C\n ",
- sr->svcconf.in ()));
- cmd_options += " -ORBSvcConf ";
- cmd_options += sr->svcconf;
- }
- }
-
- return cmd_options;
- }
-
- pid_t
- CIAO_ServerActivator_i::spawn_component_server (const Server_Info &si,
- const ACE_CString &cmd_line)
- {
- CIAO_TRACE ("CIAO_ServerActivator_i::spawn_component_server");
-
- ACE_Process_Options options;
-
- // Get my object reference
- CORBA::Object_var obj = this->poa_->servant_to_reference (this);
- CORBA::String_var ior = this->orb_->object_to_string (obj.in ());
- CORBA::Any val;
-
- const char *path = this->cs_path_.c_str ();
-
- if (si.cmap_->find (SERVER_EXECUTABLE, val) == 0)
- {
- val >>= path;
- CIAO_DEBUG ((LM_DEBUG, CLINFO "CIAO_ServerActivator_i::spawn_component_server - "
- "Using provided component server executable:%C\n", path));
- }
- else
- {
- CIAO_DEBUG ((LM_DEBUG, CLINFO "CIAO_ServerActivator_i::spawn_component_server - "
- "Using default component server execuable\n"));
- }
-
- options.command_line ("%s %s -c %s",
- path,
- cmd_line.c_str (),
- ior.in ());
-
- options.avoid_zombies (0);
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::spawn_component_server - Spawning process, command line is %C\n",
- options.command_line_buf ()));
-
- pid_t const pid = this->process_manager_.spawn (options,
- &this->child_handler_);
-
- if (pid == ACE_INVALID_PID)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "Failed to spawn a ComponentServer process\n"));
- throw Components::CreateFailure (CIAO::SERVER_SPAWN_FAILURE);
- }
-
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::spawn_component_server - Process successfully spawned with pid %u\n",
- pid));
- return pid;
- }
-
- void
- CIAO_ServerActivator_i::
- single_threaded_wait_for_callback (const Server_Info &si,
- ACE_Time_Value &timeout)
- {
- CIAO_TRACE (CLINFO "CIAO_ServerActivator_i::single_threaded_wait_for_callback");
- // Below code is broken for thread-per-connection concurrency model,
- // since the main thread is running ORB event loop and will spawn
- // a different thread to handle the call <register_node_application>,
- // the <perform_work> operation will not be invoked and finally
- // a timeout will occur. For a similar reason, it won't work
- // for thread-pool concurrency model.
- while (true)
- {
- this->orb_->perform_work (timeout);
-
- if (timeout == ACE_Time_Value::zero)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::single_threaded_wait_for_callback - "
- "Timed out while waiting for ComponentServer %C to call back.\n",
- si.uuid_.c_str ()));
- throw ::Components::CreateFailure (CIAO::CALLBACK_TIMEOUT_EXCEEDED);
- }
-
- if (si.activated_)
- {
- break;
- }
- }
- }
-
- void
- CIAO_ServerActivator_i::
- multi_threaded_wait_for_callback (const Server_Info &si,
- ACE_Time_Value &timeout)
- {
- CIAO_TRACE (CLINFO "CIAO_ServerActivator_i::multi_threaded_wait_for_callback");
-
- // Wait for a conditional variable
- ACE_GUARD_THROW_EX ( ACE_SYNCH_MUTEX,
- guard,
- this->mutex_,
- CORBA::NO_RESOURCES ());
-
- while (! si.activated_ )
- if (this->condition_.wait (&timeout) == -1)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::multi_threaded_wait_for_callback - "
- "Timed out while waiting for ComponentServer %C to call back.\n",
- si.uuid_.c_str ()));
- throw Components::CreateFailure (CIAO::CALLBACK_TIMEOUT_EXCEEDED);
- }
- }
-
- void
- CIAO_ServerActivator_i::remove_component_server (::Components::Deployment::ComponentServer_ptr server)
- {
- CIAO_TRACE(CLINFO "CIAO_ServerActivator_i::remove_component_server");
-
- if (this->server_infos_.is_empty ())
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::remove_component_server - "
- "I don't manage any ComponentServers.\n"));
- throw CORBA::BAD_PARAM ();
- }
-
- Server_Info *info = 0;
-
- for (SERVER_INFOS::ITERATOR i (this->server_infos_);
- !i.done (); ++i)
- {
- if ((*i)->ref_->_is_equivalent (server))
- {
- info = (*i).get ();
- }
- }
-
- if (info == 0)
- {
- CIAO_ERROR ((LM_ERROR, CLINFO
- "CIAO_ServerActivator_i::remove_component_server - "
- "Failed to find equivalent ComponentServer under my management.\n"));
- throw ::Components::RemoveFailure ();
- }
-
- try
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::remove_component_server - "
- "Calling remove () on ComponentServer %C\n",
- info->uuid_.c_str ()));
- server->remove ();
- }
- catch (::Components::RemoveFailure &)
- {
- CIAO_ERROR ((LM_WARNING, CLINFO
- "CIAO_ServerActivator_i::remove_component_server - "
- "Received RemoveFailure exception from ComponentServer %C\n",
- info->uuid_.c_str ()));
- }
-
- // If this is a CIAO component server, call shutdown
- CIAO::Deployment::ComponentServer_var ccs =
- CIAO::Deployment::ComponentServer::_narrow (server);
- if (!CORBA::is_nil (ccs))
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::remove_component_server - "
- "Calling shutdown () on ComponentServer %C\n",
- info->uuid_.c_str ()));
- ccs->shutdown ();
- }
- else
- CIAO_DEBUG ((LM_TRACE, CLINFO
- "CIAO_ServerActivator_i::remove_component_server - "
- "ComponentServer %C is not a CIAO_ComponentServer, not calling shutdown.\n",
- info->uuid_.c_str ()));
-
- CIAO_DEBUG ((LM_INFO, CLINFO
- "CIAO_ServerActivator_i::remove_component_server - "
- "ComponentServer %C successfully shut down.\n",
- info->uuid_.c_str ()));
- }
-
- ::Components::Deployment::ComponentServers *
- CIAO_ServerActivator_i::get_component_servers (void)
- {
- CIAO_TRACE(CLINFO "CIAO_ServerActivator_i::get_component_servers");
-
- ::Components::Deployment::ComponentServers_var retval = new
- Components::Deployment::ComponentServers (this->server_infos_.size ());
-
- CORBA::ULong pos = 0;
-
- for (SERVER_INFOS::ITERATOR i (this->server_infos_);
- !i.done (); ++i)
- {
- retval[pos++] =
- ::Components::Deployment::ComponentServer::_duplicate ((*i)->ref_);
- }
-
- return retval._retn ();
- }
-
- void
- CIAO_ServerActivator_i::create_component_server_config_values (
- const Server_Info &,
- Components::ConfigValues_out &config)
- {
- ACE_NEW_THROW_EX (config,
- Components::ConfigValues (0),
- CORBA::NO_MEMORY ());
- }
- }
-}
-
diff --git a/CIAO/ciao/FTComponentServer/CIAO_ServerActivator_Impl.h b/CIAO/ciao/FTComponentServer/CIAO_ServerActivator_Impl.h
deleted file mode 100644
index 83a41b813ff..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_ServerActivator_Impl.h
+++ /dev/null
@@ -1,194 +0,0 @@
-// $Id$
-/**
- * @file CIAO_ServerActivator.h
- * @author William R. Otte
- */
-
-#ifndef CIAO_SERVERACTIVATOR_H_
-#define CIAO_SERVERACTIVATOR_H_
-
-#include "ace/Process_Manager.h"
-#include "ace/Event_Handler.h"
-#include "ace/Condition_T.h"
-#include "ace/OS_NS_sys_wait.h"
-#include "ace/Refcounted_Auto_Ptr.h"
-#include "ace/Unbounded_Set_Ex.h"
-#include "ace/Synch_Traits.h"
-#include "tao/PortableServer/PortableServer.h"
-#include "tao/orbconf.h"
-#include "ciao/Client_init.h"
-#include "ciao/FTComponentServer/CIAO_CS_ClientS.h"
-#include "ciao/FTComponentServer/CIAO_ComponentServerC.h"
-#include "ciao/FTComponentServer/CIAO_CS_Client_svnt_export.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-#pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-namespace CIAO
-{
- namespace Deployment
- {
- //namespace
- //{
- /**
- * @class Child_Handler
- * @brief The signal handler class for the SIGCHLD handling to avoid
- * zombies
- */
- class Child_Handler : public virtual ACE_Event_Handler
- {
- public:
- virtual int handle_signal (int,
- siginfo_t *,
- ucontext_t *)
- {
- // @@ Note that this code is not portable to all OS platforms
- // since it uses print statements within signal handler context.
- ACE_exitcode status;
- // makes a claal to the underlying os system call
- // -1 to wait for any child process
- // and WNOHANG so that it retuurns immediately
- ACE_OS::waitpid (-1 ,&status, WNOHANG, 0);
-
- return 0;
- }
- };
- // }
-
-
- /**
- * @author William R. Otte <wotte@dre.vanderbilt.edu>
- * @brief Default server activator for CIAO component servers.
- *
- * Implements the default component server activation strategy
- * which is to spawn new processes. This is not thread-safe,
- * nor is it intended to be. Containers are reated serially,
- * so there will be only one actor *modifying* data at a particular
- * point in time.
- */
- class CIAO_CS_Client_svnt_Export CIAO_ServerActivator_i
- : public virtual POA_CIAO::Deployment::ServerActivator
- {
- public:
- // Constructor
- CIAO_ServerActivator_i (CORBA::ULong def_spawn_delay,
- const char * default_cs_path,
- const char * cs_args,
- bool multithreaded,
- CORBA::ORB_ptr orb,
- PortableServer::POA_ptr poa_);
-
-
- // Destructor
- virtual ~CIAO_ServerActivator_i (void);
-
- virtual
- void component_server_callback (
- ::Components::Deployment::ComponentServer_ptr serverref,
- const char * server_UUID,
- ::Components::ConfigValues_out config);
-
- virtual void configuration_complete (const char *server_UUID);
-
- virtual
- ::Components::Deployment::ComponentServer_ptr
- create_component_server (const ::Components::ConfigValues & config);
-
- virtual
- void remove_component_server (
- ::Components::Deployment::ComponentServer_ptr server);
-
- virtual
- ::Components::Deployment::ComponentServers * get_component_servers (void);
-
- private:
- struct Server_Info;
-
- /// Builds command line options based on configuration information.
- /// May modify the uuid of the component server.
- ACE_CString construct_command_line (Server_Info &si);
-
- /// Spawns the component server process, but does not wait for it
- /// to call back.
- pid_t spawn_component_server (const Server_Info &si,
- const ACE_CString &cmd_line);
-
- /// This method is only applicable when our program is configured as
- /// singled threaded . Internally it uses a <perform_work> blocking
- /// call to wait for NA object to call back
- void single_threaded_wait_for_callback (const Server_Info &si,
- ACE_Time_Value &timeout);
-
- /// This method is only applicable when our program is configured as
- /// multiple threaded. Internally it waits on a conditional variable
- /// that could be modified by the callback servant which runs in
- /// another thread
- void multi_threaded_wait_for_callback (const Server_Info &si,
- ACE_Time_Value &timeout);
-
- void create_component_server_config_values (const Server_Info &info,
- Components::ConfigValues_out &config);
-
- struct Server_Info
- {
- Server_Info (size_t cmap_size_hint = 128)
- : cmap_ (new CIAO::Utility::CONFIGVALUE_MAP (cmap_size_hint)),
- ref_ (Components::Deployment::ComponentServer::_nil ()),
- pid_ (ACE_INVALID_PID),
- activated_ (false) {}
-
- typedef ACE_Refcounted_Auto_Ptr <CIAO::Utility::CONFIGVALUE_MAP,
- ACE_Null_Mutex> CONFIGVALUE_MAP_PTR;
-
- ACE_CString uuid_;
- CONFIGVALUE_MAP_PTR cmap_;
- Components::Deployment::ComponentServer_var ref_;
- pid_t pid_;
- bool activated_;
- };
-
- typedef ACE_Refcounted_Auto_Ptr<Server_Info, ACE_Null_Mutex> Safe_Server_Info;
-
- struct _server_info
- {
- bool operator() (const Safe_Server_Info &a, const Safe_Server_Info &b) const
- {
- return a->uuid_ == b->uuid_;
- }
- };
-
- // Presumably, there won't be too many component servers per node application
- typedef ACE_Unbounded_Set_Ex <Safe_Server_Info, _server_info> SERVER_INFOS;
-
- /// Default args to pass to all componentservers.
- ACE_CString default_args_;
-
- SERVER_INFOS server_infos_;
-
- ACE_Process_Manager process_manager_;
-
- Child_Handler child_handler_;
-
- CORBA::ULong spawn_delay_;
-
- /////*******NEW
- bool multithreaded_;
-
- CORBA::ORB_var orb_;
-
- PortableServer::POA_var poa_;
-
- ACE_CString cs_path_;
-
- ACE_CString cs_args_;
-
- ACE_Thread_Mutex mutex_;
-
- ACE_Condition<ACE_SYNCH_MUTEX> condition_;
- };
-
-
- }
-}
-#endif /* CIAO_SERVERACTIVATOR_H_ */
diff --git a/CIAO/ciao/FTComponentServer/CIAO_ServerResources.idl b/CIAO/ciao/FTComponentServer/CIAO_ServerResources.idl
deleted file mode 100644
index 5c00205a39b..00000000000
--- a/CIAO/ciao/FTComponentServer/CIAO_ServerResources.idl
+++ /dev/null
@@ -1,268 +0,0 @@
-// $Id$
-
-/**
- * @file CIAO_ServerResources.idl
- *
- * @brief A collection of IDL data types for
- *
- * @author Nanbor Wang
- */
-
-#if !defined (CIAO_SERVERRESOURCES_IDL)
-#define CIAO_SERVERRESOURCES_IDL
-
-#include <orb.idl>
-
-module CIAO
-{
- module Deployment
- {
- /**
- * @brief A single command line argument corresponds to a string as
- * in the case of "argv".
- */
- typedef string CommandlineArg;
- /**
- * @brief A list of command line arguments which a
- * NodeApplicationManager will use to start up the NodeApplication
- * this list is associated to. The command line arguments will be
- * appended to the command line in order.
- */
- typedef sequence<CommandlineArg> CommandlineArgs;
-
- /**
- * @brief A string containing the filename of the svc.conf file the
- * NodeApplication uses. The current approach of specifying
- * svc.conf filename directly some harder problems such as
- * distribution of svc.conf files and the relative/absolute path to
- * the svc.conf file (the ServerResrouces xml document will have to
- * assume the svc.conf file will be available at specific location.)
- */
- typedef string SvcconfURI;
-
- /**
- * @brief enumeration of ORB Resource Types (ORT) supported in RT
- * extension.
- */
- enum ORBResourceType
- {
- ORT_THREADPOOL,
- ORT_THREADPOOLWITHLANES,
- ORT_CONNECTIONBANDS
- };
-
- typedef short Priority;
-
- /**
- * @brief Define a threadpool resource that an ORB must provide
- */
- struct ORS_Threadpool
- {
- string Id;
- unsigned long stacksize;
- unsigned long static_threads;
- unsigned long dynamic_threads;
- Priority default_priority;
- boolean allow_request_buffering;
- unsigned long max_buffered_requests;
- unsigned long max_request_buffer_size;
- };
-
- typedef sequence<ORS_Threadpool> ORS_ThreadpoolSeq;
-
- /**
- * @brief Defines the configuration of a threadpool lane. We need
- * to redefine it here to avoid dependency to RTCORBA library.
- */
- struct ORS_ThreadpoolLane
- {
- Priority lane_priority;
- unsigned long static_threads;
- unsigned long dynamic_threads;
- };
-
- /**
- * @brief Defines a set of threadpool lanes. We need
- * to redefine it here to avoid dependency to RTCORBA library.
- */
- typedef sequence<ORS_ThreadpoolLane> ORS_ThreadpoolLanes;
-
- /**
- * @brief Defines a Threadpool with Lanes resource that an ORB
- * must provide.
- */
- struct ORS_ThreadpoolWithLanes
- {
- string Id;
- unsigned long stacksize;
- ORS_ThreadpoolLanes threadpool_lanes;
- boolean allow_borrowing;
- boolean allow_request_buffering;
- unsigned long max_buffered_requests;
- unsigned long max_request_buffer_size;
- };
-
- typedef sequence<ORS_ThreadpoolWithLanes> ORS_ThreadpoolWithLanesSeq;
-
- /**
- * @brief Define a priority band for BandedConnection policies.
- */
- struct ORS_PriorityBand
- {
- Priority low;
- Priority high;
- };
- /**
- * @brief Define a list of priority bands for BandedConnection
- * policies.
- */
- typedef sequence<ORS_PriorityBand> ORS_PriorityBands;
-
- /**
- * @brief Define the information needed to create a
- * BandedConnection policy. This info can be referred to via its
- * name (Id).
- */
- struct ORS_ConnectionBands
- {
- string Id;
- ORS_PriorityBands bands;
- };
-
- typedef sequence<ORS_ConnectionBands> ORS_ConnectionBandsSeq;
-
- /**
- * @brief Collection of resources managed by the NodeApplication
- * ORB.
- */
- struct ORBResource
- {
- ORS_ThreadpoolSeq threadpool_list;
-
- ORS_ThreadpoolWithLanesSeq threadpool_with_lanes_list;
-
- ORS_ConnectionBandsSeq connection_bands_list;
- };
-
- typedef sequence<ORBResource, 1> ORBResources;
-
- // =================================================================
-
- /**
- * @brief PolicyType supported by DAnCE extension. Again, we are
- * redefining these value to avoid dependencies to various ORB
- * modules such as RTCORBA and DiffServ policy libraries.
- * @JW This is a bad thing to redefine. Maybe we have to make a seperate
- * IDL lib for these libraries, but redefinition is really a bad thing
- */
- const CORBA::PolicyType PRIORITY_MODEL_POLICY_TYPE = 40;
- const CORBA::PolicyType THREADPOOL_POLICY_TYPE = 41;
- const CORBA::PolicyType PRIORITY_BANDED_CONNECTION_POLICY_TYPE = 45;
- const CORBA::PolicyType CLIENT_NETWORK_PRIORITY_TYPE = 86;
- const CORBA::PolicyType NETWORK_PRIORITY_TYPE = 87;
-
- enum PriorityModel
- {
- CLIENT_PROPAGATED,
- SERVER_DECLARED
- };
-
- enum NWPriorityModel
- {
- CLIENT_PROPAGATED_NWPRIORITY,
- SERVER_DECLARED_NWPRIORITY
- };
-
- /**
- * @brief Defines data required for creating a PriorityModel Policy
- */
- struct PriorityModelPolicyDef
- {
- PriorityModel priority_model;
- Priority server_priority;
- };
-
- /**
- * @brief Defines data required for creating a server side DiffServ policy
- */
- struct NWPriorityModelPolicyDef
- {
- NWPriorityModel nw_priority_model;
- long request_dscp;
- long reply_dscp;
- };
-
- /**
- * @brief Defines data required for creating a client side DiffServ policy
- */
- struct CNWPriorityModelPolicyDef
- {
- long request_dscp;
- long reply_dscp;
- };
-
- /**
- * @brief Define data required for creating a Threadpool policy
- */
- struct ThreadpoolPolicyDef
- {
- // Threadpool name defined in ORBResource
- string Id;
- };
-
- /**
- * @brief Define data required for creating a PriorityBandedConnection
- * policy
- */
- struct PriorityBandedConnectionPolicyDef
- {
- string Id; // PriorityBands name defined in
- // ORBResource
- };
-
- union PolicyDef switch (CORBA::PolicyType)
- {
- case PRIORITY_MODEL_POLICY_TYPE: PriorityModelPolicyDef PriorityModelDef;
- case THREADPOOL_POLICY_TYPE: ThreadpoolPolicyDef ThreadpoolDef;
- case PRIORITY_BANDED_CONNECTION_POLICY_TYPE: PriorityBandedConnectionPolicyDef PriorityBandedConnectionDef;
- case CLIENT_NETWORK_PRIORITY_TYPE: CNWPriorityModelPolicyDef CNWPriorityModelDef;
- case NETWORK_PRIORITY_TYPE: NWPriorityModelPolicyDef NWPriorityModelDef;
- };
-
- /**
- * @brief Define a set of policy definitions.
- */
- typedef sequence<PolicyDef> PolicyDefs;
-
- /**
- * @brief A policy set is named.
- */
- struct PolicySet
- {
- string Id; // Name of this policy set
- PolicyDefs policies;
- };
-
- /**
- * @brief A list of all policy sets.
- */
- typedef sequence<PolicySet> PolicySets;
-
- struct ORBConfigs
- {
- ORBResources orb_resources;
- PolicySets policy_set;
- };
-
- struct ServerResource
- {
- string Id;
-
- CommandlineArgs args;
- SvcconfURI svcconf;
- ORBConfigs orb_config;
- };
- };
-};
-
-#endif /* CIAO_SERVERRESOURCES_IDL */
diff --git a/CIAO/ciao/FTComponentServer/Configurator_Factory.cpp b/CIAO/ciao/FTComponentServer/Configurator_Factory.cpp
deleted file mode 100644
index 2db7cec6ef3..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurator_Factory.cpp
+++ /dev/null
@@ -1,49 +0,0 @@
-#include "Configurator_Factory.h"
-// $Id$
-#include "ace/Arg_Shifter.h"
-#include "ciao/CIAO_common.h"
-#include "Configurators/Server_Configurator.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- ComponentServer_Configurator *
- Configurator_Factory::operator() (int &argc, ACE_TCHAR **argv)
- {
- CIAO_TRACE ("Configurator_Factory::operator()");
- bool const rt = this->parse_args (argc, argv);
-
- ComponentServer_Configurator *ptr = 0;
- ACE_NEW_THROW_EX (ptr,
- ComponentServer_Configurator (rt),
- CORBA::NO_MEMORY (TAO::VMCID,
- CORBA::COMPLETED_NO));
-
- return ptr;
- }
-
- bool
- Configurator_Factory::parse_args (int &argc, ACE_TCHAR **argv)
- {
- CIAO_TRACE ("Configurator_Factory::parse_args");
- ACE_Arg_Shifter shifter (argc, argv);
- bool retval = false;
-
- while (shifter.is_anything_left ())
- {
- if (shifter.cur_arg_strncasecmp (ACE_TEXT("-r")) == 0)
- {
- retval = true;
- shifter.consume_arg ();
- }
- else
- {
- shifter.ignore_arg ();
- }
- }
-
- return retval;
- }
- }
-}
diff --git a/CIAO/ciao/FTComponentServer/Configurator_Factory.h b/CIAO/ciao/FTComponentServer/Configurator_Factory.h
deleted file mode 100644
index 5f62473a5da..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurator_Factory.h
+++ /dev/null
@@ -1,39 +0,0 @@
-// $Id$
-/**
- * @file Configurator_Factory.h
- * @author William R. Otte <wotte@dre.vanderbilt.edu>
- * @author Nanbor Wang <>
- *
- * Factory for creating configurators, based on old NodeApplication_Options
- * class
- */
-
-#ifndef CIAO_CONFIGURATOR_FACTORY_H
-#define CIAO_CONFIGURATOR_FACTORY_H
-#include /**/ "ace/pre.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "CIAO_FTComponentServer_svnt_export.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- class ComponentServer_Configurator;
-
- class CIAO_FTComponentServer_svnt_Export Configurator_Factory
- {
- public:
- ComponentServer_Configurator * operator () (int &argc, ACE_TCHAR **argv);
-
- private:
- bool parse_args (int &argc, ACE_TCHAR **argv);
- };
- }
-}
-#include /**/ "ace/post.h"
-
-#endif
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.cpp b/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.cpp
deleted file mode 100644
index a34353fe5c7..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.cpp
+++ /dev/null
@@ -1,240 +0,0 @@
-// $Id$
-
-#include "Basic_Config_Manager.h"
-#include "ciao/CIAO_common.h"
-#include "ace/SString.h"
-#include "tao/SystemException.h"
-#include "tao/DiffServPolicy/DiffServPolicy.h"
-#include "tao/DiffServPolicy/Client_Network_Priority_Policy.h"
-#include "tao/DiffServPolicy/Server_Network_Priority_Policy.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
-
- void
- Basic_Config_Manager::init (CORBA::ORB_ptr orb)
- {
- this->orb_ = CORBA::ORB::_duplicate (orb);
- }
-
- int
- Basic_Config_Manager::pre_orb_initialize (void)
- {
- return 0;
- }
-
- int
- Basic_Config_Manager::post_orb_initialize (CORBA::ORB_ptr)
- {
- return 0;
- }
-
- void
- Basic_Config_Manager::init_resources
- (const ServerResource &server_resource)
- {
- CIAO_DEBUG ((LM_DEBUG,"Basic_Config_Manager::init_resources\n"));
-
- if (CORBA::is_nil (this->orb_.in()))
- {
- CIAO_ERROR ((LM_ERROR,
- "Basic_Config_Manager has not been properly initialized\n"));
- throw CORBA::INTERNAL ();
- }
-
- const PolicySets &sets = server_resource.orb_config.policy_set;
- for (CORBA::ULong i = 0; i < sets.length (); ++i)
- {
- CORBA::ULong np = sets[i].policies.length ();
- if (np == 0)
- continue;
-
- CORBA::PolicyList_var policy_list = new CORBA::PolicyList (np);
- policy_list->length (np);
- CORBA::ULong index = 0;
- CORBA::ULong array_index = np;
-
- // Create a list of policies
- for (CORBA::ULong pc = 0; pc < np; ++pc)
- {
- CORBA::Policy_var temp_policy =
- this->create_single_policy (sets[i].policies[pc]);
-
- if (CORBA::is_nil (temp_policy.in ()))
- {
- array_index = array_index - 1;
- policy_list->length (array_index);
- }
- else
- {
- policy_list[index] = temp_policy;
- index = index + 1;
- }
- }
-
- // Bind the policy list to the name. The bind operation should
- // surrender the ownership of the newly created PolicyList
- // sequence to the map.
- if (array_index != 0)
- {
- if (this->policy_map_.bind (sets[i].Id.in (),
- policy_list) != 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Error binding Policy_Set with name: %s\n",
- sets[i].Id.in ()));
- throw CORBA::INTERNAL ();
- }
- else
- {
- CIAO_DEBUG ((LM_DEBUG,
- "Basic_Config_Manager::init_resource"
- " added policy set : %s with %d policies\n",
- sets[i].Id.in (), array_index));
- }
- }
- else
- {
- CIAO_DEBUG ((LM_DEBUG,
- "Basic_Config_Manager::init_resource"
- " added policy set : %s with %d policies\n",
- sets[i].Id.in (), array_index));
- }
- }
- }
-
- bool
- Basic_Config_Manager::policy_exists (const char *name)
- {
- if (name == 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Invalid name string found in "
- "Basic_Config_Manager::policy_exists\n"));
- throw CORBA::INTERNAL ();
- }
-
- POLICY_MAP::ENTRY *entry = 0;
-
- if (this->policy_map_.find (name, entry) != 0)
- {
- return false;
- }
-
- return true;
- }
-
- CORBA::PolicyList *
- Basic_Config_Manager::find_policies_by_name (const char *name)
- {
- if (name == 0)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "Invalid name string found in find_policies_by_name\n"));
- throw CORBA::INTERNAL ();
- }
-
- POLICY_MAP::ENTRY *entry = 0;
-
- CORBA::PolicyList_var retv;
-
- if (this->policy_map_.find (name, entry) != 0)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "Unable to find a PolicyList named %s\n",
- name));
- retv = 0;
- }
- else
- {
- retv = new CORBA::PolicyList (entry->int_id_.in ());
- }
- return retv._retn ();
- }
-
- CORBA::Policy_ptr
- Basic_Config_Manager::create_single_policy
- (const PolicyDef &policy_def)
- {
- CORBA::Policy_var retv;
-
- switch (policy_def._d ())
- {
- case TAO::NETWORK_PRIORITY_TYPE:
- {
- const NWPriorityModelPolicyDef &nw_tmp
- = policy_def.NWPriorityModelDef ();
- retv = this->orb_->_create_policy (TAO::NETWORK_PRIORITY_TYPE);
-
- TAO::NetworkPriorityPolicy_var nw_priority =
- TAO::NetworkPriorityPolicy::_narrow (retv.in ());
-
- nw_priority->network_priority_model (
- (TAO::NetworkPriorityModel) nw_tmp.nw_priority_model);
-
- nw_priority->request_diffserv_codepoint (
- (TAO::DiffservCodepoint) nw_tmp.request_dscp);
-
- nw_priority->reply_diffserv_codepoint (
- (TAO::DiffservCodepoint) nw_tmp.reply_dscp);
-
- retv = nw_priority._retn ();
-
- if (! CORBA::is_nil (retv.in ()))
- CIAO_DEBUG ((LM_DEBUG,
- "NAConfigManager::Create NetworkPriority policy: %d\n",
- nw_tmp.nw_priority_model));
- }
- break;
-
- case TAO::CLIENT_NETWORK_PRIORITY_TYPE:
- {
- const CNWPriorityModelPolicyDef &cnw_tmp
- = policy_def.CNWPriorityModelDef ();
- retv = this->orb_->_create_policy (TAO::CLIENT_NETWORK_PRIORITY_TYPE);
-
- TAO::NetworkPriorityPolicy_var cnw_priority =
- TAO::NetworkPriorityPolicy::_narrow (retv.in ());
-
- cnw_priority->request_diffserv_codepoint (
- (TAO::DiffservCodepoint) cnw_tmp.request_dscp);
-
- cnw_priority->reply_diffserv_codepoint (
- (TAO::DiffservCodepoint) cnw_tmp.reply_dscp);
-
- retv = cnw_priority._retn ();
-
- if (! CORBA::is_nil (retv.in ()))
- CIAO_DEBUG ((LM_DEBUG,
- "NAConfigManager::Create NetworkPriority policy \n"));
- }
- break;
-
- default:
- retv = 0;
- }
-
- return retv._retn ();
- }
-
- }
-}
-
-using CIAO::Deployment::Config_Manager;
-using CIAO::Deployment::Basic_Config_Manager;
-
-extern "C" Basic_Config_Manager_Export Config_Manager *create_basic_config_manager (void);
-
-extern "C"
-{
- Config_Manager *
- create_basic_config_manager (void)
- {
- Basic_Config_Manager *config;
- ACE_NEW_RETURN (config, Basic_Config_Manager, 0);
- return config;
- }
-}
-
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.h b/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.h
deleted file mode 100644
index 0f1f0b03b64..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.h
+++ /dev/null
@@ -1,79 +0,0 @@
-// -*- C++ -*-
-
-//=============================================================================
-/**
- * @file Basic_Config_Manager.h
- *
- * $Id$
- *
- */
-//=============================================================================
-
-
-#ifndef CIAO_NACONFIG_MANAGER_H
-#define CIAO_NACONFIG_MANAGER_H
-#include /**/ <ace/pre.h>
-
-#include "ace/config-all.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "ace/Null_Mutex.h"
-#include "ace/SString.h"
-#include "ace/Hash_Map_Manager_T.h"
-#include "ciao/ComponentServer/CIAO_ServerResourcesC.h"
-
-#include "Config_Manager.h"
-#include "Basic_Config_Manager_export.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- /**
- */
- class Basic_Config_Manager_Export Basic_Config_Manager
- : public Config_Manager
- {
- public:
- virtual ~Basic_Config_Manager (void) {}
-
- virtual int pre_orb_initialize (void);
-
- virtual int post_orb_initialize (CORBA::ORB_ptr o);
-
- virtual void init (CORBA::ORB_ptr orb);
-
- /// Initializing the NAResource_Config_Manager
- virtual void init_resources (const ServerResource &info);
-
- /// Query a policy set by name
- virtual CORBA::PolicyList *find_policies_by_name (const char *name);
-
- virtual bool policy_exists (const char *name);
-
- private:
- /// Cached an ORB reference.
- CORBA::ORB_var orb_;
-
- CORBA::Policy_ptr create_single_policy
- (const PolicyDef &policy_def);
-
- /// Hash_Map stuff.
- typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
- CORBA::PolicyList_var,
- ACE_Hash<ACE_CString>,
- ACE_Equal_To<ACE_CString>,
- ACE_Null_Mutex> POLICY_MAP;
-
- /// Internal TP names to id map.
- POLICY_MAP policy_map_;
- };
-}
- }
-
-#include /**/ "ace/post.h"
-#endif /* CIAO_NACONFIG_MANAGER_H */
-
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.inl b/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.inl
deleted file mode 100644
index 67203a91ff8..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager.inl
+++ /dev/null
@@ -1,12 +0,0 @@
-// $Id$
-
-ACE_INLINE
-CIAO::NAResource_Config_Manager::NAResource_Config_Manager ()
-{
-}
-
-ACE_INLINE
-CIAO::NAResource_Config_Manager::~NAResource_Config_Manager ()
-{
-}
-
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager_export.h b/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager_export.h
deleted file mode 100644
index 51cb9778168..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Basic_Config_Manager_export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl Basic_Config_Manager
-// ------------------------------
-#ifndef BASIC_CONFIG_MANAGER_EXPORT_H
-#define BASIC_CONFIG_MANAGER_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (BASIC_CONFIG_MANAGER_HAS_DLL)
-# define BASIC_CONFIG_MANAGER_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && BASIC_CONFIG_MANAGER_HAS_DLL */
-
-#if !defined (BASIC_CONFIG_MANAGER_HAS_DLL)
-# define BASIC_CONFIG_MANAGER_HAS_DLL 1
-#endif /* ! BASIC_CONFIG_MANAGER_HAS_DLL */
-
-#if defined (BASIC_CONFIG_MANAGER_HAS_DLL) && (BASIC_CONFIG_MANAGER_HAS_DLL == 1)
-# if defined (BASIC_CONFIG_MANAGER_BUILD_DLL)
-# define Basic_Config_Manager_Export ACE_Proper_Export_Flag
-# define BASIC_CONFIG_MANAGER_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define BASIC_CONFIG_MANAGER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* BASIC_CONFIG_MANAGER_BUILD_DLL */
-# define Basic_Config_Manager_Export ACE_Proper_Import_Flag
-# define BASIC_CONFIG_MANAGER_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define BASIC_CONFIG_MANAGER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* BASIC_CONFIG_MANAGER_BUILD_DLL */
-#else /* BASIC_CONFIG_MANAGER_HAS_DLL == 1 */
-# define Basic_Config_Manager_Export
-# define BASIC_CONFIG_MANAGER_SINGLETON_DECLARATION(T)
-# define BASIC_CONFIG_MANAGER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* BASIC_CONFIG_MANAGER_HAS_DLL == 1 */
-
-// Set BASIC_CONFIG_MANAGER_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (BASIC_CONFIG_MANAGER_NTRACE)
-# if (ACE_NTRACE == 1)
-# define BASIC_CONFIG_MANAGER_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define BASIC_CONFIG_MANAGER_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !BASIC_CONFIG_MANAGER_NTRACE */
-
-#if (BASIC_CONFIG_MANAGER_NTRACE == 1)
-# define BASIC_CONFIG_MANAGER_TRACE(X)
-#else /* (BASIC_CONFIG_MANAGER_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define BASIC_CONFIG_MANAGER_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (BASIC_CONFIG_MANAGER_NTRACE == 1) */
-
-#endif /* BASIC_CONFIG_MANAGER_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Basic_Configurator_export.h b/CIAO/ciao/FTComponentServer/Configurators/Basic_Configurator_export.h
deleted file mode 100644
index 098b4c87f0d..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Basic_Configurator_export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl Basic_Configurator
-// ------------------------------
-#ifndef BASIC_CONFIGURATOR_EXPORT_H
-#define BASIC_CONFIGURATOR_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (BASIC_CONFIGURATOR_HAS_DLL)
-# define BASIC_CONFIGURATOR_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && BASIC_CONFIGURATOR_HAS_DLL */
-
-#if !defined (BASIC_CONFIGURATOR_HAS_DLL)
-# define BASIC_CONFIGURATOR_HAS_DLL 1
-#endif /* ! BASIC_CONFIGURATOR_HAS_DLL */
-
-#if defined (BASIC_CONFIGURATOR_HAS_DLL) && (BASIC_CONFIGURATOR_HAS_DLL == 1)
-# if defined (BASIC_CONFIGURATOR_BUILD_DLL)
-# define Basic_Configurator_Export ACE_Proper_Export_Flag
-# define BASIC_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define BASIC_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* BASIC_CONFIGURATOR_BUILD_DLL */
-# define Basic_Configurator_Export ACE_Proper_Import_Flag
-# define BASIC_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define BASIC_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* BASIC_CONFIGURATOR_BUILD_DLL */
-#else /* BASIC_CONFIGURATOR_HAS_DLL == 1 */
-# define Basic_Configurator_Export
-# define BASIC_CONFIGURATOR_SINGLETON_DECLARATION(T)
-# define BASIC_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* BASIC_CONFIGURATOR_HAS_DLL == 1 */
-
-// Set BASIC_CONFIGURATOR_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (BASIC_CONFIGURATOR_NTRACE)
-# if (ACE_NTRACE == 1)
-# define BASIC_CONFIGURATOR_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define BASIC_CONFIGURATOR_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !BASIC_CONFIGURATOR_NTRACE */
-
-#if (BASIC_CONFIGURATOR_NTRACE == 1)
-# define BASIC_CONFIGURATOR_TRACE(X)
-#else /* (BASIC_CONFIGURATOR_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define BASIC_CONFIGURATOR_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (BASIC_CONFIGURATOR_NTRACE == 1) */
-
-#endif /* BASIC_CONFIGURATOR_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/Configurators/ComponentServer_Configurator_export.h b/CIAO/ciao/FTComponentServer/Configurators/ComponentServer_Configurator_export.h
deleted file mode 100644
index 9793cd0ed44..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/ComponentServer_Configurator_export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl ComponentServer_Configurator
-// ------------------------------
-#ifndef COMPONENTSERVER_CONFIGURATOR_EXPORT_H
-#define COMPONENTSERVER_CONFIGURATOR_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (COMPONENTSERVER_CONFIGURATOR_HAS_DLL)
-# define COMPONENTSERVER_CONFIGURATOR_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && COMPONENTSERVER_CONFIGURATOR_HAS_DLL */
-
-#if !defined (COMPONENTSERVER_CONFIGURATOR_HAS_DLL)
-# define COMPONENTSERVER_CONFIGURATOR_HAS_DLL 1
-#endif /* ! COMPONENTSERVER_CONFIGURATOR_HAS_DLL */
-
-#if defined (COMPONENTSERVER_CONFIGURATOR_HAS_DLL) && (COMPONENTSERVER_CONFIGURATOR_HAS_DLL == 1)
-# if defined (COMPONENTSERVER_CONFIGURATOR_BUILD_DLL)
-# define ComponentServer_Configurator_Export ACE_Proper_Export_Flag
-# define COMPONENTSERVER_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define COMPONENTSERVER_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* COMPONENTSERVER_CONFIGURATOR_BUILD_DLL */
-# define ComponentServer_Configurator_Export ACE_Proper_Import_Flag
-# define COMPONENTSERVER_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define COMPONENTSERVER_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* COMPONENTSERVER_CONFIGURATOR_BUILD_DLL */
-#else /* COMPONENTSERVER_CONFIGURATOR_HAS_DLL == 1 */
-# define ComponentServer_Configurator_Export
-# define COMPONENTSERVER_CONFIGURATOR_SINGLETON_DECLARATION(T)
-# define COMPONENTSERVER_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* COMPONENTSERVER_CONFIGURATOR_HAS_DLL == 1 */
-
-// Set COMPONENTSERVER_CONFIGURATOR_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (COMPONENTSERVER_CONFIGURATOR_NTRACE)
-# if (ACE_NTRACE == 1)
-# define COMPONENTSERVER_CONFIGURATOR_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define COMPONENTSERVER_CONFIGURATOR_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !COMPONENTSERVER_CONFIGURATOR_NTRACE */
-
-#if (COMPONENTSERVER_CONFIGURATOR_NTRACE == 1)
-# define COMPONENTSERVER_CONFIGURATOR_TRACE(X)
-#else /* (COMPONENTSERVER_CONFIGURATOR_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define COMPONENTSERVER_CONFIGURATOR_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (COMPONENTSERVER_CONFIGURATOR_NTRACE == 1) */
-
-#endif /* COMPONENTSERVER_CONFIGURATOR_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Config_Manager.cpp b/CIAO/ciao/FTComponentServer/Configurators/Config_Manager.cpp
deleted file mode 100644
index 47ee45a81a4..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Config_Manager.cpp
+++ /dev/null
@@ -1,11 +0,0 @@
-#include "Config_Manager.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- Config_Manager::~Config_Manager (void)
- {
- }
- }
-}
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Config_Manager.h b/CIAO/ciao/FTComponentServer/Configurators/Config_Manager.h
deleted file mode 100644
index 2ce46aa980f..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Config_Manager.h
+++ /dev/null
@@ -1,53 +0,0 @@
-// -*- C++ -*-
-
-//=============================================================================
-/**
- * @file Config_Manager.h
- *
- * $Id$
- *
- */
-//=============================================================================
-
-
-#ifndef CIAO_CONFIG_MANAGER_H
-#define CIAO_CONFIG_MANAGER_H
-#include /**/ "ace/pre.h"
-
-#include "ace/config-all.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "ciao/ComponentServer/CIAO_ServerResourcesC.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- /**
- */
- class Config_Manager
- {
- public:
- virtual ~Config_Manager (void) {};
-
- virtual int pre_orb_initialize (void) = 0;
-
- virtual int post_orb_initialize (CORBA::ORB_ptr o) = 0;
-
- virtual void init_resources (const ServerResource &info) = 0;
-
- virtual void init (CORBA::ORB_ptr orb) = 0;
-
- virtual CORBA::PolicyList *find_policies_by_name (const char *name)= 0;
-
- virtual bool policy_exists (const char *name) = 0;
- };
- }
-}
-
-#include /**/ "ace/post.h"
-#endif /* CIAO_CONFIG_MANAGER_H */
-
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Configurators.mpc b/CIAO/ciao/FTComponentServer/Configurators/Configurators.mpc
deleted file mode 100644
index dc072ddb6dc..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Configurators.mpc
+++ /dev/null
@@ -1,21 +0,0 @@
-project(CIAO_FT_Basic_Configurator) : ccm_stub, ciao_ft_componentserver_stub, ciao_lib {
- dynamicflags += COMPONENTSERVER_CONFIGURATOR_BUILD_DLL
- Source_Files {
- Server_Configurator.cpp
- }
- Header_Files {
- Server_Configurator.h
- }
-}
-
-project(CIAO_FT_Basic_Config_Manager) : ciao_lib, ciao_config_manager, ciao_ft_componentserver_stub, \
- diffservpolicy {
- dynamicflags += BASIC_CONFIG_MANAGER_BUILD_DLL
- Source_Files {
- Basic_Config_Manager.cpp
- }
- Header_Files {
- Basic_Config_Manager.h
- }
-}
-
diff --git a/CIAO/ciao/FTComponentServer/Configurators/NA_Configurator_Export.h b/CIAO/ciao/FTComponentServer/Configurators/NA_Configurator_Export.h
deleted file mode 100644
index 2e30fd59cc1..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/NA_Configurator_Export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl CIAO_NA_Configurator
-// ------------------------------
-#ifndef CIAO_NA_CONFIGURATOR_EXPORT_H
-#define CIAO_NA_CONFIGURATOR_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (CIAO_NA_CONFIGURATOR_HAS_DLL)
-# define CIAO_NA_CONFIGURATOR_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && CIAO_NA_CONFIGURATOR_HAS_DLL */
-
-#if !defined (CIAO_NA_CONFIGURATOR_HAS_DLL)
-# define CIAO_NA_CONFIGURATOR_HAS_DLL 1
-#endif /* ! CIAO_NA_CONFIGURATOR_HAS_DLL */
-
-#if defined (CIAO_NA_CONFIGURATOR_HAS_DLL) && (CIAO_NA_CONFIGURATOR_HAS_DLL == 1)
-# if defined (CIAO_NA_CONFIGURATOR_BUILD_DLL)
-# define CIAO_NA_Configurator_Export ACE_Proper_Export_Flag
-# define CIAO_NA_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define CIAO_NA_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* CIAO_NA_CONFIGURATOR_BUILD_DLL */
-# define CIAO_NA_Configurator_Export ACE_Proper_Import_Flag
-# define CIAO_NA_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define CIAO_NA_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* CIAO_NA_CONFIGURATOR_BUILD_DLL */
-#else /* CIAO_NA_CONFIGURATOR_HAS_DLL == 1 */
-# define CIAO_NA_Configurator_Export
-# define CIAO_NA_CONFIGURATOR_SINGLETON_DECLARATION(T)
-# define CIAO_NA_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* CIAO_NA_CONFIGURATOR_HAS_DLL == 1 */
-
-// Set CIAO_NA_CONFIGURATOR_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (CIAO_NA_CONFIGURATOR_NTRACE)
-# if (ACE_NTRACE == 1)
-# define CIAO_NA_CONFIGURATOR_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define CIAO_NA_CONFIGURATOR_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !CIAO_NA_CONFIGURATOR_NTRACE */
-
-#if (CIAO_NA_CONFIGURATOR_NTRACE == 1)
-# define CIAO_NA_CONFIGURATOR_TRACE(X)
-#else /* (CIAO_NA_CONFIGURATOR_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define CIAO_NA_CONFIGURATOR_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (CIAO_NA_CONFIGURATOR_NTRACE == 1) */
-
-#endif /* CIAO_NA_CONFIGURATOR_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/Configurators/NoOp/CIAO_FT_NoOp_Configurator.vcproj b/CIAO/ciao/FTComponentServer/Configurators/NoOp/CIAO_FT_NoOp_Configurator.vcproj
deleted file mode 100644
index 8e239e4c5c3..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/NoOp/CIAO_FT_NoOp_Configurator.vcproj
+++ /dev/null
@@ -1,402 +0,0 @@
-<?xml version="1.0" encoding="Windows-1252"?>
-<VisualStudioProject
- ProjectType="Visual C++"
- Version="9.00"
- Name="CIAO_FT_NoOp_Configurator"
- ProjectGUID="{F0D93435-FECA-1BAD-0AB8-C21871AADE92}"
- RootNamespace="CIAO_FT_NoOp_Configurator"
- Keyword="Win32Proj"
- SignManifests="true"
- >
- <Platforms>
- <Platform
- Name="Win32"
- />
- <Platform
- Name="x64"
- />
- </Platforms>
- <ToolFiles>
- </ToolFiles>
- <Configurations>
- <Configuration
- Name="Debug|Win32"
- OutputDirectory="$(ACE_ROOT)\lib"
- IntermediateDirectory="Debug\CIAO_FT_NoOp_Configurator\I386"
- ConfigurationType="2"
- CharacterSet="0"
-
- >
- <Tool
- Name="VCPreBuildEventTool"
- />
- <Tool
- Name="VCCustomBuildTool"
- />
- <Tool
- Name="VCXMLDataGeneratorTool"
- />
- <Tool
- Name="VCWebServiceProxyGeneratorTool"
- />
- <Tool
- Name="VCMIDLTool"
- AdditionalOptions=""
- AdditionalIncludeDirectories=""
- TypeLibraryName="$(InputName).tlb"
- HeaderFileName="$(InputName).h"
- InterfaceIdentifierFileName="$(InputName)_i.c"
- ProxyFileName="$(InputName)_p.c"
- />
- <Tool
- Name="VCCLCompilerTool"
- Optimization="0"
- AdditionalIncludeDirectories="$(ACE_ROOT),$(TAO_ROOT),..\..\..\..\ccm,..\..\..\..,..\..\..\..\DAnCE"
- PreprocessorDefinitions="_DEBUG;WIN32;_WINDOWS;_CRT_NONSTDC_NO_WARNINGS;_CRT_SECURE_NO_WARNINGS;_CRT_SECURE_NO_DEPRECATE;_CRT_NONSTDC_NO_DEPRECATE;CCM_LW;MPC_LIB_MODIFIER=\&quot;d\&quot;"
- MinimalRebuild="false"
- BasicRuntimeChecks="3"
- RuntimeLibrary="3"
- RuntimeTypeInfo="true"
- WarningLevel="3"
- Detect64BitPortabilityProblems="false"
- DebugInformationFormat="3"
- DisableSpecificWarnings="4355;4290;4996;4250"
- />
- <Tool
- Name="VCManagedResourceCompilerTool"
- />
- <Tool
- Name="VCResourceCompilerTool"
- PreprocessorDefinitions="_DEBUG;_CRT_SECURE_NO_WARNINGS;_CRT_SECURE_NO_DEPRECATE;_CRT_NONSTDC_NO_DEPRECATE;CCM_LW"
- Culture="1033"
- AdditionalIncludeDirectories="$(ACE_ROOT),$(TAO_ROOT),..\..\..\..\ccm,..\..\..\..,..\..\..\..\DAnCE"
- />
- <Tool
- Name="VCPreLinkEventTool"
- />
- <Tool
- Name="VCLinkerTool"
- AdditionalDependencies="ACEd.lib TAOd.lib TAO_AnyTypeCoded.lib TAO_IFR_Clientd.lib TAO_Valuetyped.lib TAO_CodecFactoryd.lib TAO_PId.lib CCM_stubd.lib CCM_ConfigValue_Factoryd.lib CCM_Cookie_Factoryd.lib CIAO_Clientd.lib CCM_ComponentServer_stubd.lib CIAO_FTComponentServer_stubd.lib CIAO_FT_Basic_Configuratord.lib"
- OutputFile="$(OutDir)\CIAO_FT_NoOp_Configuratord.dll"
- LinkIncremental="2"
- SuppressStartupBanner="true"
- AdditionalLibraryDirectories=".;$(ACE_ROOT)\lib"
- GenerateDebugInformation="true"
- SubSystem="2"
- ImportLibrary="$(ACE_ROOT)\lib\CIAO_FT_NoOp_Configuratord.lib"
- TargetMachine="1"
- />
- <Tool
- Name="VCALinkTool"
- />
- <Tool
- Name="VCXDCMakeTool"
- />
- <Tool
- Name="VCBscMakeTool"
- />
- <Tool
- Name="VCFxCopTool"
- />
- <Tool
- Name="VCPostBuildEventTool"
- />
- </Configuration>
- <Configuration
- Name="Release|Win32"
- OutputDirectory="$(ACE_ROOT)\lib"
- IntermediateDirectory="Release\CIAO_FT_NoOp_Configurator\I386"
- ConfigurationType="2"
- CharacterSet="0"
-
- >
- <Tool
- Name="VCPreBuildEventTool"
- />
- <Tool
- Name="VCCustomBuildTool"
- />
- <Tool
- Name="VCXMLDataGeneratorTool"
- />
- <Tool
- Name="VCWebServiceProxyGeneratorTool"
- />
- <Tool
- Name="VCMIDLTool"
- AdditionalOptions=""
- AdditionalIncludeDirectories=""
- TypeLibraryName="$(InputName).tlb"
- HeaderFileName="$(InputName).h"
- InterfaceIdentifierFileName="$(InputName)_i.c"
- ProxyFileName="$(InputName)_p.c"
- />
- <Tool
- Name="VCCLCompilerTool"
- Optimization="2"
- AdditionalIncludeDirectories="$(ACE_ROOT),$(TAO_ROOT),..\..\..\..\ccm,..\..\..\..,..\..\..\..\DAnCE"
- PreprocessorDefinitions="NDEBUG;WIN32;_WINDOWS;_CRT_NONSTDC_NO_WARNINGS;_CRT_SECURE_NO_WARNINGS;_CRT_SECURE_NO_DEPRECATE;_CRT_NONSTDC_NO_DEPRECATE;CCM_LW"
- RuntimeLibrary="2"
- RuntimeTypeInfo="true"
- WarningLevel="3"
- Detect64BitPortabilityProblems="false"
- DisableSpecificWarnings="4355;4290;4996;4250"
- />
- <Tool
- Name="VCManagedResourceCompilerTool"
- />
- <Tool
- Name="VCResourceCompilerTool"
- PreprocessorDefinitions="NDEBUG;_CRT_SECURE_NO_WARNINGS;_CRT_SECURE_NO_DEPRECATE;_CRT_NONSTDC_NO_DEPRECATE;CCM_LW"
- Culture="1033"
- AdditionalIncludeDirectories="$(ACE_ROOT),$(TAO_ROOT),..\..\..\..\ccm,..\..\..\..,..\..\..\..\DAnCE"
- />
- <Tool
- Name="VCPreLinkEventTool"
- />
- <Tool
- Name="VCLinkerTool"
- AdditionalDependencies="ACE.lib TAO.lib TAO_AnyTypeCode.lib TAO_IFR_Client.lib TAO_Valuetype.lib TAO_CodecFactory.lib TAO_PI.lib CCM_stub.lib CCM_ConfigValue_Factory.lib CCM_Cookie_Factory.lib CIAO_Client.lib CCM_ComponentServer_stub.lib CIAO_FTComponentServer_stub.lib CIAO_FT_Basic_Configurator.lib"
- OutputFile="$(OutDir)\CIAO_FT_NoOp_Configurator.dll"
- LinkIncremental="1"
- SuppressStartupBanner="true"
- AdditionalLibraryDirectories=".;$(ACE_ROOT)\lib"
- GenerateDebugInformation="false"
- SubSystem="2"
- OptimizeReferences="2"
- EnableCOMDATFolding="2"
- ImportLibrary="$(ACE_ROOT)\lib\CIAO_FT_NoOp_Configurator.lib"
- TargetMachine="1"
- />
- <Tool
- Name="VCALinkTool"
- />
- <Tool
- Name="VCXDCMakeTool"
- />
- <Tool
- Name="VCBscMakeTool"
- />
- <Tool
- Name="VCFxCopTool"
- />
- <Tool
- Name="VCPostBuildEventTool"
- />
- </Configuration>
- <Configuration
- Name="Debug|x64"
- OutputDirectory="$(ACE_ROOT)\lib"
- IntermediateDirectory="Debug\CIAO_FT_NoOp_Configurator\AMD64"
- ConfigurationType="2"
- CharacterSet="0"
-
- >
- <Tool
- Name="VCPreBuildEventTool"
- />
- <Tool
- Name="VCCustomBuildTool"
- />
- <Tool
- Name="VCXMLDataGeneratorTool"
- />
- <Tool
- Name="VCWebServiceProxyGeneratorTool"
- />
- <Tool
- Name="VCMIDLTool"
- AdditionalOptions=""
- AdditionalIncludeDirectories=""
- TypeLibraryName="$(InputName).tlb"
- HeaderFileName="$(InputName).h"
- InterfaceIdentifierFileName="$(InputName)_i.c"
- ProxyFileName="$(InputName)_p.c"
- />
- <Tool
- Name="VCCLCompilerTool"
- Optimization="0"
- AdditionalIncludeDirectories="$(ACE_ROOT),$(TAO_ROOT),..\..\..\..\ccm,..\..\..\..,..\..\..\..\DAnCE"
- PreprocessorDefinitions="_DEBUG;WIN32;_WINDOWS;_CRT_NONSTDC_NO_WARNINGS;_AMD64_;_WIN64;_CRT_SECURE_NO_WARNINGS;_CRT_SECURE_NO_DEPRECATE;_CRT_NONSTDC_NO_DEPRECATE;CCM_LW;MPC_LIB_MODIFIER=\&quot;d\&quot;"
- MinimalRebuild="false"
- BasicRuntimeChecks="3"
- RuntimeLibrary="3"
- RuntimeTypeInfo="true"
- WarningLevel="3"
- Detect64BitPortabilityProblems="false"
- DebugInformationFormat="3"
- DisableSpecificWarnings="4355;4290;4996;4250"
- />
- <Tool
- Name="VCManagedResourceCompilerTool"
- />
- <Tool
- Name="VCResourceCompilerTool"
- PreprocessorDefinitions="_DEBUG;_CRT_SECURE_NO_WARNINGS;_CRT_SECURE_NO_DEPRECATE;_CRT_NONSTDC_NO_DEPRECATE;CCM_LW;_WIN64"
- Culture="1033"
- AdditionalIncludeDirectories="$(ACE_ROOT),$(TAO_ROOT),..\..\..\..\ccm,..\..\..\..,..\..\..\..\DAnCE"
- />
- <Tool
- Name="VCPreLinkEventTool"
- />
- <Tool
- Name="VCLinkerTool"
- AdditionalOptions="/machine:AMD64"
- AdditionalDependencies="ACEd.lib TAOd.lib TAO_AnyTypeCoded.lib TAO_IFR_Clientd.lib TAO_Valuetyped.lib TAO_CodecFactoryd.lib TAO_PId.lib CCM_stubd.lib CCM_ConfigValue_Factoryd.lib CCM_Cookie_Factoryd.lib CIAO_Clientd.lib CCM_ComponentServer_stubd.lib CIAO_FTComponentServer_stubd.lib CIAO_FT_Basic_Configuratord.lib"
- OutputFile="$(OutDir)\CIAO_FT_NoOp_Configuratord.dll"
- LinkIncremental="2"
- SuppressStartupBanner="true"
- AdditionalLibraryDirectories=".;$(ACE_ROOT)\lib"
- GenerateDebugInformation="true"
- SubSystem="2"
- ImportLibrary="$(ACE_ROOT)\lib\CIAO_FT_NoOp_Configuratord.lib"
- TargetMachine="17"
- />
- <Tool
- Name="VCALinkTool"
- />
- <Tool
- Name="VCXDCMakeTool"
- />
- <Tool
- Name="VCBscMakeTool"
- />
- <Tool
- Name="VCFxCopTool"
- />
- <Tool
- Name="VCPostBuildEventTool"
- />
- </Configuration>
- <Configuration
- Name="Release|x64"
- OutputDirectory="$(ACE_ROOT)\lib"
- IntermediateDirectory="Release\CIAO_FT_NoOp_Configurator\AMD64"
- ConfigurationType="2"
- CharacterSet="0"
-
- >
- <Tool
- Name="VCPreBuildEventTool"
- />
- <Tool
- Name="VCCustomBuildTool"
- />
- <Tool
- Name="VCXMLDataGeneratorTool"
- />
- <Tool
- Name="VCWebServiceProxyGeneratorTool"
- />
- <Tool
- Name="VCMIDLTool"
- AdditionalOptions=""
- AdditionalIncludeDirectories=""
- TypeLibraryName="$(InputName).tlb"
- HeaderFileName="$(InputName).h"
- InterfaceIdentifierFileName="$(InputName)_i.c"
- ProxyFileName="$(InputName)_p.c"
- />
- <Tool
- Name="VCCLCompilerTool"
- Optimization="2"
- AdditionalIncludeDirectories="$(ACE_ROOT),$(TAO_ROOT),..\..\..\..\ccm,..\..\..\..,..\..\..\..\DAnCE"
- PreprocessorDefinitions="NDEBUG;WIN32;_WINDOWS;_CRT_NONSTDC_NO_WARNINGS;_AMD64_;_WIN64;_CRT_SECURE_NO_WARNINGS;_CRT_SECURE_NO_DEPRECATE;_CRT_NONSTDC_NO_DEPRECATE;CCM_LW"
- RuntimeLibrary="2"
- RuntimeTypeInfo="true"
- WarningLevel="3"
- Detect64BitPortabilityProblems="false"
- DisableSpecificWarnings="4355;4290;4996;4250"
- />
- <Tool
- Name="VCManagedResourceCompilerTool"
- />
- <Tool
- Name="VCResourceCompilerTool"
- PreprocessorDefinitions="NDEBUG;_CRT_SECURE_NO_WARNINGS;_CRT_SECURE_NO_DEPRECATE;_CRT_NONSTDC_NO_DEPRECATE;CCM_LW;_WIN64"
- Culture="1033"
- AdditionalIncludeDirectories="$(ACE_ROOT),$(TAO_ROOT),..\..\..\..\ccm,..\..\..\..,..\..\..\..\DAnCE"
- />
- <Tool
- Name="VCPreLinkEventTool"
- />
- <Tool
- Name="VCLinkerTool"
- AdditionalOptions="/machine:AMD64"
- AdditionalDependencies="ACE.lib TAO.lib TAO_AnyTypeCode.lib TAO_IFR_Client.lib TAO_Valuetype.lib TAO_CodecFactory.lib TAO_PI.lib CCM_stub.lib CCM_ConfigValue_Factory.lib CCM_Cookie_Factory.lib CIAO_Client.lib CCM_ComponentServer_stub.lib CIAO_FTComponentServer_stub.lib CIAO_FT_Basic_Configurator.lib"
- OutputFile="$(OutDir)\CIAO_FT_NoOp_Configurator.dll"
- LinkIncremental="1"
- SuppressStartupBanner="true"
- AdditionalLibraryDirectories=".;$(ACE_ROOT)\lib"
- GenerateDebugInformation="false"
- SubSystem="2"
- OptimizeReferences="2"
- EnableCOMDATFolding="2"
- ImportLibrary="$(ACE_ROOT)\lib\CIAO_FT_NoOp_Configurator.lib"
- TargetMachine="17"
- />
- <Tool
- Name="VCALinkTool"
- />
- <Tool
- Name="VCXDCMakeTool"
- />
- <Tool
- Name="VCBscMakeTool"
- />
- <Tool
- Name="VCFxCopTool"
- />
- <Tool
- Name="VCPostBuildEventTool"
- />
- </Configuration>
- </Configurations>
- <References>
- </References>
- <Files>
- <Filter
- Name="Source Files"
- Filter="cpp;cxx;cc;c;C">
- <File
- RelativePath="NoOp_Configurator.cpp">
- </File>
- </Filter>
- <Filter
- Name="Header Files"
- Filter="h;hpp;hxx;hh">
- <File
- RelativePath="NoOp_Configurator.h">
- </File>
- </Filter>
- <Filter
- Name="Build Files"
- Filter="mpc;mpb;mwc">
- <File
- RelativePath="FT_NoOp_Configurator.mpc">
- <FileConfiguration
- Name="Debug|Win32"
- ExcludedFromBuild="true"
- >
- </FileConfiguration>
- <FileConfiguration
- Name="Release|Win32"
- ExcludedFromBuild="true"
- >
- </FileConfiguration>
- <FileConfiguration
- Name="Debug|x64"
- ExcludedFromBuild="true"
- >
- </FileConfiguration>
- <FileConfiguration
- Name="Release|x64"
- ExcludedFromBuild="true"
- >
- </FileConfiguration>
- </File>
- </Filter>
- </Files>
- <Globals>
- </Globals>
-</VisualStudioProject>
diff --git a/CIAO/ciao/FTComponentServer/Configurators/NoOp/FT_NoOp_Configurator.mpc b/CIAO/ciao/FTComponentServer/Configurators/NoOp/FT_NoOp_Configurator.mpc
deleted file mode 100644
index 50cb9d50665..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/NoOp/FT_NoOp_Configurator.mpc
+++ /dev/null
@@ -1,12 +0,0 @@
-project(CIAO_FT_NoOp_Configurator) : ccm_stub, ciao_ft_componentserver_stub, ciao_ft_componentserver_configurator, ciao_lib {
-
- Source_Files {
- NoOp_Configurator.cpp
- }
-
- Header_Files {
- NoOp_Configurator.h
- }
-}
-
-
diff --git a/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.cpp b/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.cpp
deleted file mode 100644
index e4c377e436a..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.cpp
+++ /dev/null
@@ -1,46 +0,0 @@
-// $Id$
-
-#include "NoOp_Configurator.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
-
- NoOp_Configurator::~NoOp_Configurator (void)
- {
- // Not much to do.
- }
-
- int
- NoOp_Configurator::pre_orb_initialize ()
- {
- return 0;
- }
-
- int
- NoOp_Configurator::post_orb_initialize (CORBA::ORB_ptr)
- {
- return 0;
- }
-
- int
- NoOp_Configurator::init_resource_manager
- (const ::Components::ConfigValues & /*properties*/)
- {
- // @@ Currently do thing. We should go over the resource struct in
- // the future and throw exceptions if there are
- // un-recognizable/supported stuff in it.
- return 0;
- }
-
- CORBA::PolicyList *
- NoOp_Configurator::find_container_policies
- (const ::Components::ConfigValues & /*properties*/)
- {
- // Not much to do.
-
- return 0;
- }
- }
-}
diff --git a/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.h b/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.h
deleted file mode 100644
index d84715d5bca..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator.h
+++ /dev/null
@@ -1,66 +0,0 @@
-/** $Id$
- * @file NoOp_Configurator.h
- * @brief This file contains the noop configurator.
- */
-
-#ifndef NOOP_CONFIGURATOR_H
-#define NOOP_CONFIGURATOR_H
-
-#include /**/ "ace/pre.h"
-
-#include "ace/config-all.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include <ccm/CCM_StandardConfiguratorC.h>
-
-#include "ciao/ComponentServer/Configurators/Server_Configurator.h"
-#include "NoOp_Configurator_export.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- /**
- * @class NoOP_Configurator
- *
- * @brief The NoOp_Configurator doesn't do anything.
- */
- class NoOp_Configurator_Export NoOp_Configurator
- : public ComponentServer_Configurator
- {
- public:
- /// Default destructor.
- virtual ~NoOp_Configurator (void);
-
- /**
- * @brief "pre_orb_initialize" is called before ORB_init.
- */
- virtual int pre_orb_initialize (void);
-
- /**
- * @brief "post_orb_initialize" is called after NodeApplication
- * get a hold at this object.
- */
- virtual int post_orb_initialize (CORBA::ORB_ptr o);
-
- /**
- * @brief "init_resource_manager" is called by NodeApplication when
- * it receives an "install" commands.
- */
- virtual int
- init_resource_manager (const ::Components::ConfigValues &properties);
-
- /**
- * @brief get a policyset by its name.
- */
- virtual CORBA::PolicyList *
- find_container_policies (const ::Components::ConfigValues &properties);
- };
- }
-}
-
-#include /**/ "ace/post.h"
-#endif /* NOOP_CONFIGURATOR_H */
diff --git a/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator_export.h b/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator_export.h
deleted file mode 100644
index b6b3a9ec841..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/NoOp/NoOp_Configurator_export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl NoOp_Configurator
-// ------------------------------
-#ifndef NOOP_CONFIGURATOR_EXPORT_H
-#define NOOP_CONFIGURATOR_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (NOOP_CONFIGURATOR_HAS_DLL)
-# define NOOP_CONFIGURATOR_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && NOOP_CONFIGURATOR_HAS_DLL */
-
-#if !defined (NOOP_CONFIGURATOR_HAS_DLL)
-# define NOOP_CONFIGURATOR_HAS_DLL 1
-#endif /* ! NOOP_CONFIGURATOR_HAS_DLL */
-
-#if defined (NOOP_CONFIGURATOR_HAS_DLL) && (NOOP_CONFIGURATOR_HAS_DLL == 1)
-# if defined (NOOP_CONFIGURATOR_BUILD_DLL)
-# define NoOp_Configurator_Export ACE_Proper_Export_Flag
-# define NOOP_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define NOOP_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* NOOP_CONFIGURATOR_BUILD_DLL */
-# define NoOp_Configurator_Export ACE_Proper_Import_Flag
-# define NOOP_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define NOOP_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* NOOP_CONFIGURATOR_BUILD_DLL */
-#else /* NOOP_CONFIGURATOR_HAS_DLL == 1 */
-# define NoOp_Configurator_Export
-# define NOOP_CONFIGURATOR_SINGLETON_DECLARATION(T)
-# define NOOP_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* NOOP_CONFIGURATOR_HAS_DLL == 1 */
-
-// Set NOOP_CONFIGURATOR_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (NOOP_CONFIGURATOR_NTRACE)
-# if (ACE_NTRACE == 1)
-# define NOOP_CONFIGURATOR_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define NOOP_CONFIGURATOR_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !NOOP_CONFIGURATOR_NTRACE */
-
-#if (NOOP_CONFIGURATOR_NTRACE == 1)
-# define NOOP_CONFIGURATOR_TRACE(X)
-#else /* (NOOP_CONFIGURATOR_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define NOOP_CONFIGURATOR_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (NOOP_CONFIGURATOR_NTRACE == 1) */
-
-#endif /* NOOP_CONFIGURATOR_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.cpp b/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.cpp
deleted file mode 100644
index 4ec837c06fe..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.cpp
+++ /dev/null
@@ -1,513 +0,0 @@
-// $Id$
-
-#include "RTConfig_Manager.h"
-#include "ciao/CIAO_common.h"
-#include "ace/SString.h"
-
-#if !defined (__ACE_INLINE__)
-# include "RTConfig_Manager.inl"
-#endif /* __ACE_INLINE__ */
-
-void
-CIAO::Deployment::RTResource_Config_Manager::init (CORBA::ORB_ptr orb)
-{
- CORBA::Object_var object =
- orb->resolve_initial_references ("RTORB");
- this->rtorb_ = RTCORBA::RTORB::_narrow (object.in ());
-}
-
-int
-CIAO::Deployment::RTResource_Config_Manager::pre_orb_initialize (void)
-{
- return 0;
-}
-
-int
-CIAO::Deployment::RTResource_Config_Manager::post_orb_initialize (CORBA::ORB_ptr)
-{
- return 0;
-}
-
-void
-CIAO::Deployment::RTResource_Config_Manager::print_resources
-(const ServerResource &server_resource)
-{
- const ORBResource &orb_resource
- = server_resource.orb_config.orb_resources[0];
-
- CORBA::ULong i;
-
- // Creating and binding name with RT Threadpool
- for (i = 0; i < orb_resource.threadpool_list.length (); ++i)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "-RTResource_Config_Manager::print_resource threadpool: %s\n"
- "\tStack size: %d\n"
- "\tStatic: %d\n"
- "\tDynamic %d\n"
- "\tDefault Prio: %d\n"
- "\tBuffering %s\n"
- "\tMax Buffered: %d\n"
- "\tBuffer Size %d\n",
- orb_resource.threadpool_list[i].Id.in (),
- orb_resource.threadpool_list[i].stacksize,
- orb_resource.threadpool_list[i].static_threads,
- orb_resource.threadpool_list[i].dynamic_threads,
- orb_resource.threadpool_list[i].default_priority,
- (orb_resource.threadpool_list[i].allow_request_buffering ? "Y" : "N"),
- orb_resource.threadpool_list[i].max_buffered_requests,
- orb_resource.threadpool_list[i].max_request_buffer_size));
- }
-
- for (i = 0; i < orb_resource.threadpool_with_lanes_list.length (); ++i)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "-RTResource_Config_Manager::print_resource threadpool_with %d, lanes: %s\n",
- orb_resource.threadpool_with_lanes_list[i].threadpool_lanes.length (),
- orb_resource.threadpool_with_lanes_list[i].Id.in ()));
-
- for (CORBA::ULong l = 0;
- l < orb_resource.threadpool_with_lanes_list[i].threadpool_lanes.length ();
- ++l)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "\tLane %d:\n"
- "\t\tPriority: %d\n"
- "\t\tStatic: %d\n"
- "\t\tDynamic: %d\n",
- l,
- orb_resource.threadpool_with_lanes_list[i].threadpool_lanes[l].lane_priority,
- orb_resource.threadpool_with_lanes_list[i].threadpool_lanes[l].static_threads,
- orb_resource.threadpool_with_lanes_list[i].threadpool_lanes[l].dynamic_threads));
- }
- CIAO_DEBUG ((LM_DEBUG,
- "\tStack size: %d\n"
- "\tBorrowing: %s\n"
- "\tBuffering %s\n"
- "\tMax Buffered: %d\n"
- "\tBuffer Size %d\n",
- orb_resource.threadpool_with_lanes_list[i].stacksize,
- (orb_resource.threadpool_with_lanes_list[i].allow_borrowing ? "Y" : "N"),
- (orb_resource.threadpool_with_lanes_list[i].allow_request_buffering ? "Y" : "N"),
- orb_resource.threadpool_with_lanes_list[i].max_buffered_requests,
- orb_resource.threadpool_with_lanes_list[i].max_request_buffer_size));
- }
-
- for (i = 0; i < orb_resource.connection_bands_list.length (); ++i)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "-RTResource_Config_Manager::print_resource connection %d bands: %s\n",
- orb_resource.connection_bands_list[i].bands.length (),
- orb_resource.connection_bands_list[i].Id.in ()));
-
- for (CORBA::ULong l = 0;
- l < orb_resource.connection_bands_list[i].bands.length ();
- ++l)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "\tBand %d Prio: %d -- %d\n",
- l,
- orb_resource.connection_bands_list[i].bands[l].low,
- orb_resource.connection_bands_list[i].bands[l].high));
- }
- }
-}
-
-void
-CIAO::Deployment::RTResource_Config_Manager::init_resources
-(const ServerResource &server_resource)
-{
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::init_resource.\n"));
-
- if (CORBA::is_nil (this->rtorb_.in()))
- {
- CIAO_ERROR ((LM_ERROR,
- "RTResource_Config_Manager has not been properly initialized.\n"));
- throw CORBA::INTERNAL ();
- }
-
- this->print_resources (server_resource);
- // return;
-
- const ORBResource &orb_resource
- = server_resource.orb_config.orb_resources[0];
-
- CORBA::ULong i;
-
- // Creating and binding name with RT Threadpool
- for (i = 0; i < orb_resource.threadpool_list.length (); ++i)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::init_resource threadpool: %s\n",
- orb_resource.threadpool_list[i].Id.in ()));
- RTCORBA::ThreadpoolId thr_id =
- this->rtorb_->create_threadpool
- (orb_resource.threadpool_list[i].stacksize,
- orb_resource.threadpool_list[i].static_threads,
- orb_resource.threadpool_list[i].dynamic_threads,
- orb_resource.threadpool_list[i].default_priority,
- orb_resource.threadpool_list[i].allow_request_buffering,
- orb_resource.threadpool_list[i].max_buffered_requests,
- orb_resource.threadpool_list[i].max_request_buffer_size);
- // Simply pass back the exception here
- // for now. We need to have a better way
- // to handle execption here.
- if (this->threadpool_map_.bind (orb_resource.threadpool_list[i].Id.in (),
- thr_id) != 0)
- {
- CIAO_ERROR ((LM_ERROR, "Error binding thread pool Id: %s to map when initializing RTNodeApplication resources.\n", orb_resource.threadpool_list[i].Id.in ()));
- throw CORBA::INTERNAL ();
- }
- else
- {
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::init_resource added thread pool: %s\n",
- orb_resource.threadpool_list[i].Id.in ()));
- }
- }
-
- for (i = 0; i < orb_resource.threadpool_with_lanes_list.length (); ++i)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::init_resource threadpool_with %d, lanes: %s\n",
- orb_resource.threadpool_with_lanes_list[i].threadpool_lanes.length (),
- orb_resource.threadpool_with_lanes_list[i].Id.in ()));
-
- // Duplicate RTCORBA lanes
- RTCORBA::ThreadpoolLanes lanes
- (orb_resource.threadpool_with_lanes_list[i].threadpool_lanes.length ());
- lanes.length (orb_resource.threadpool_with_lanes_list[i].threadpool_lanes.length ());
-
- for (CORBA::ULong l = 0;
- l < orb_resource.threadpool_with_lanes_list[i].threadpool_lanes.length ();
- ++l)
- {
- lanes[l].lane_priority
- = orb_resource.threadpool_with_lanes_list[i].threadpool_lanes[l].lane_priority;
- lanes[l].static_threads
- = orb_resource.threadpool_with_lanes_list[i].threadpool_lanes[l].static_threads;
- lanes[l].dynamic_threads
- = orb_resource.threadpool_with_lanes_list[i].threadpool_lanes[l].dynamic_threads;
- }
-
- RTCORBA::ThreadpoolId thr_id =
- this->rtorb_->create_threadpool_with_lanes
- (orb_resource.threadpool_with_lanes_list[i].stacksize,
- lanes,
- orb_resource.threadpool_with_lanes_list[i].allow_borrowing,
- orb_resource.threadpool_with_lanes_list[i].allow_request_buffering,
- orb_resource.threadpool_with_lanes_list[i].max_buffered_requests,
- orb_resource.threadpool_with_lanes_list[i].max_request_buffer_size);
- // Simply pass back the exception here
- // for now. We need to have a better way
- // to handle execption here.
-
- if (this->threadpool_map_.bind (orb_resource.threadpool_with_lanes_list[i].Id.in (),
- thr_id) != 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Error binding thread pool name: %s to map when "
- "initializing RTNodeApplication resources.\n",
- orb_resource.threadpool_with_lanes_list[i].Id.in ()));
- throw CORBA::INTERNAL ();
- }
-
- else
- {
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::init_resource added thread pool with lanes: %s\n",
- orb_resource.threadpool_with_lanes_list[i].Id.in ()));
- }
- }
-
- for (i = 0; i < orb_resource.connection_bands_list.length (); ++i)
- {
- RTCORBA::PriorityBands
- safebands(orb_resource.connection_bands_list[i].bands.length ());
- safebands.length (orb_resource.connection_bands_list[i].bands.length ());
-
- for (CORBA::ULong l = 0;
- l < orb_resource.connection_bands_list[i].bands.length ();
- ++l)
- {
- safebands[l].low = orb_resource.connection_bands_list[i].bands[l].low;
- safebands[l].high = orb_resource.connection_bands_list[i].bands[l].high;
- }
-
- if (this->priority_bands_map_.bind (orb_resource.connection_bands_list[i].Id.in (),
- safebands) != 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Error binding priority bands name: %s to map "
- "when initializing RTNodeApplication resources.\n",
- orb_resource.connection_bands_list[i].Id.in ()));
- throw CORBA::INTERNAL ();
- }
- else
- {
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::init_resource added connection bands: %s\n",
- orb_resource.connection_bands_list[i].Id.in ()));
- }
- }
-
- // now initialize the policy set part of it.
- // server_resource.orb_config.policy_set
- const PolicySets &sets = server_resource.orb_config.policy_set;
- for (CORBA::ULong i = 0; i < sets.length (); ++i)
- {
- CORBA::ULong const np = sets[i].policies.length ();
- if (np == 0)
- continue;
-
- CORBA::PolicyList_var policy_list = new CORBA::PolicyList (np);
- policy_list->length (np);
- CORBA::ULong index = 0;
- CORBA::ULong array_index = np;
-
- // Create a list of policies
- for (CORBA::ULong pc = 0; pc < np; ++pc)
- {
- CORBA::Policy_var temp_policy =
- this->create_single_policy (sets[i].policies[pc]);
- if (CORBA::is_nil (temp_policy.in ()))
- {
- array_index = array_index - 1;
- policy_list->length (array_index);
- }
- else
- {
- policy_list[index] = CORBA::Policy::_duplicate (temp_policy.in ());
- index = index + 1;
- }
- }
-
- // Bind the policy list to the name. The bind operation should
- // surrender the ownership of the newly created PolicyList
- // sequence to the map.
- if (array_index != 0)
- {
- if (this->policy_map_.bind (sets[i].Id.in (),
- policy_list._retn ()) != 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Error binding Policy_Set with name: %s\n",
- sets[i].Id.in ()));
- throw CORBA::INTERNAL ();
- }
- else
- {
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::init_resource "
- "added policy set: %s with %d policies\n",
- sets[i].Id.in (), array_index));
- }
- }
- else
- {
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::init_resource "
- "added policy set: %s with %d policies\n",
- sets[i].Id.in (), array_index));
- }
- }
-}
-
-void
-CIAO::Deployment::RTResource_Config_Manager::fini ()
-{
- TP_MAP::ITERATOR iter = this->threadpool_map_.begin ();
- TP_MAP::ITERATOR end = this->threadpool_map_.end ();
-
- for (; iter != end; ++iter)
- {
- this->rtorb_->destroy_threadpool ((*iter).int_id_);
- }
-
-}
-
-RTCORBA::ThreadpoolId
-CIAO::Deployment::RTResource_Config_Manager::find_threadpool_by_name (const char *name)
-{
- if (name == 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Invalid name string found in \"find_threadpool_by_name\"\n"));
- throw CORBA::BAD_PARAM ();
- }
-
-
- RTCORBA::ThreadpoolId ret_id = 0; // return id
-
- if (this->threadpool_map_.find (name, ret_id) != 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Unable to find a threadpool named %s\n",
- name));
- throw CORBA::INTERNAL ();
- }
-
- return ret_id;
-}
-
-RTCORBA::PriorityBands *
-CIAO::Deployment::RTResource_Config_Manager::find_priority_bands_by_name (const char *name)
-{
- if (name == 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Invalid name string found in \"find_priority_bands_by_name\"\n"));
- throw CORBA::BAD_PARAM ();
- }
-
- PB_MAP::ENTRY *entry = 0;
-
- if (this->priority_bands_map_.find (name, entry) != 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Unable to find a connection bands named %s\n",
- name));
- throw CORBA::INTERNAL ();
- }
-
- RTCORBA::PriorityBands_var retv = new RTCORBA::PriorityBands;
- (*retv.ptr ()) = (*entry->int_id_.ptr ());
- return retv._retn ();
-}
-
-bool
-CIAO::Deployment::RTResource_Config_Manager::policy_exists (const char *name)
-{
- if (name == 0)
- {
- CIAO_DEBUG ((LM_DEBUG,
- "Invalid name string found in "
- "CIAO::Deployment::NAResource_Config_Manager::policy_exists\n"));
- throw CORBA::INTERNAL ();
- }
-
- POLICY_MAP::ENTRY *entry = 0;
-
- if (this->policy_map_.find (name, entry) != 0)
- {
- return false;
- }
-
- return true;
-}
-
-CORBA::PolicyList *
-CIAO::Deployment::RTResource_Config_Manager::find_policies_by_name (const char *name)
-{
- if (name == 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Invalid name string found in \"find_policies_by_name\"\n"));
- throw CORBA::BAD_PARAM ();
- }
-
-
- CIAO_DEBUG ((LM_DEBUG, "RTResource_Config_Manager::find_policies_by_name: %s\n",
- name));
-
- POLICY_MAP::ENTRY *entry = 0;
-
- if (this->policy_map_.find (name, entry) != 0)
- {
- CIAO_ERROR ((LM_ERROR,
- "Unable to find a PolicyList named %s\n",
- name));
- throw CORBA::INTERNAL ();
- }
-
- // duplicate the sequence PolicyList.
- CORBA::PolicyList_var retv =
- new CORBA::PolicyList (entry->int_id_.in ());
-
- CIAO_DEBUG ((LM_DEBUG, "RTResource_Config_Manager::find_policies_by_name ok.\n"));
-
- return retv._retn ();
-}
-
-CORBA::Policy_ptr
-CIAO::Deployment::RTResource_Config_Manager::create_single_policy
-(const PolicyDef &policy_def)
-{
- // if (CIAO::Deployment::debug_level () > 9)
- CIAO_DEBUG ((LM_DEBUG,
- "RTResource_Config_Manager::create_single_policy: %d\n",
- policy_def._d ()));
-
- CORBA::Policy_var retv;
-
- switch (policy_def._d ())
- {
- case RTCORBA::PRIORITY_MODEL_POLICY_TYPE:
- {
- const PriorityModelPolicyDef &tmp
- = policy_def.PriorityModelDef ();
-
- retv = this->rtorb_->create_priority_model_policy ((RTCORBA::PriorityModel) tmp.priority_model,
- tmp.server_priority);
-
- if (! CORBA::is_nil (retv.in ()))
- CIAO_DEBUG ((LM_DEBUG,
- "Create PriorityModel policy: %d - %d\n",
- tmp.priority_model, tmp.server_priority));
- }
- break;
-
- case RTCORBA::THREADPOOL_POLICY_TYPE:
- {
- RTCORBA::ThreadpoolId tpid =
- this->find_threadpool_by_name (policy_def.ThreadpoolDef().Id.in ());
-
- retv = this->rtorb_->create_threadpool_policy (tpid);
-
- if (! CORBA::is_nil (retv.in ()))
- CIAO_DEBUG ((LM_DEBUG,
- "Create Threadpool policy: %s, TPid: %d\n",
- policy_def.ThreadpoolDef().Id.in (), tpid));
- }
- break;
-
- case RTCORBA::PRIORITY_BANDED_CONNECTION_POLICY_TYPE:
- {
- RTCORBA::PriorityBands_var bands =
- this->find_priority_bands_by_name (policy_def.PriorityBandedConnectionDef().Id.in ());
-
- retv =
- this->rtorb_->create_priority_banded_connection_policy (bands.in ());
-
- if (! CORBA::is_nil (retv.in ()))
- {
- CIAO_DEBUG ((LM_DEBUG,
- "Created Banded Connection policy: %s\n",
- policy_def.PriorityBandedConnectionDef().Id.in ()));
- }
- }
- break;
-
- default:
- retv = 0;
- }
-
- return retv._retn ();
-}
-
-CIAO::Deployment::RTResource_Config_Manager::~RTResource_Config_Manager ()
-{
- this->fini ();
-}
-
-extern "C" CIAO_RTNA_Configurator_Export CIAO::Deployment::Config_Manager
-*create_rt_config_manager (void);
-
-CIAO::Deployment::Config_Manager *
-create_rt_config_manager (void)
-{
- CIAO::Deployment::RTResource_Config_Manager *config;
- ACE_NEW_RETURN (config, CIAO::Deployment::RTResource_Config_Manager, 0);
- return config;
-}
diff --git a/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.h b/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.h
deleted file mode 100644
index fbbea84d706..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.h
+++ /dev/null
@@ -1,138 +0,0 @@
-// -*- C++ -*-
-
-//=============================================================================
-/**
- * @file RTConfig_Manager.h
- *
- * $Id$
- *
- * This file contains classes that manage name to configuration
- * mapping info in a RTComponentServer.
- *
- * @author Nanbor Wang <nanbor@cs.wustl.edu>
- */
-//=============================================================================
-
-
-#ifndef CIAO_RTCONFIG_MANAGER_H
-#define CIAO_RTCONFIG_MANAGER_H
-#include /**/ "ace/pre.h"
-
-#include "ace/config-all.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "ace/Null_Mutex.h"
-#include "ace/SString.h"
-#include "ace/Hash_Map_Manager_T.h"
-#include "tao/RTCORBA/RTCORBA.h"
-#include "ciao/ComponentServer/CIAO_ServerResourcesC.h"
-
-#include "ciao/ComponentServer/Configurators/Config_Manager.h"
-#include "RTNA_Configurator_Export.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- /**
- * @brief RTResource_Config_Manager maintains a collection of
- * RTCORBA related resources.
- *
- * This class is responsible to create and manage a list of RTCORBA
- * related resources that are global to an RT ComponentServer. The
- * information required to create and configure these resources are
- * passed in via the @a info argument in the @c init method. These
- * resources are identified by names and can be used to associate
- * these resources with related RTPolicies. These resources are
- * destoryed along with this class.
- *
- * Currently, the only resources supported (and managed) by this
- * class are Threadpool and Threadpool_with_Lanes.
- */
- class RTResource_Config_Manager : public Config_Manager
- {
- public:
- RTResource_Config_Manager (void);
- ~RTResource_Config_Manager (void);
-
- virtual void init (CORBA::ORB_ptr orb);
-
- virtual int pre_orb_initialize (void);
-
- virtual int post_orb_initialize (CORBA::ORB_ptr o);
-
- /// Initializing the RTResource_Config_Manager
- virtual void init_resources (const ServerResource &info);
-
- /// Finalizing the RTResource_Config_Manager and the resources it
- /// manages.
- void fini ();
-
- /// Query a policy set by name
- virtual CORBA::PolicyList *find_policies_by_name (const char *name);
-
- virtual bool policy_exists (const char *name);
-
- protected:
- void print_resources (const ServerResource &info);
-
- /// Query a thread pool by name.
- RTCORBA::ThreadpoolId find_threadpool_by_name (const char *name);
-
-
- /// Query a priority bands info by name.
- RTCORBA::PriorityBands *find_priority_bands_by_name (const char *name);
-
- private:
- /// Cached an ORB reference.
- CORBA::ORB_var orb_;
-
- // Cached an RTORB reference.
- RTCORBA::RTORB_var rtorb_;
-
- /// Hash_Map stuff.
- typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
- RTCORBA::ThreadpoolId,
- ACE_Hash<ACE_CString>,
- ACE_Equal_To<ACE_CString>,
- ACE_Null_Mutex> TP_MAP;
-
- typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
- RTCORBA::PriorityBands_var,
- ACE_Hash<ACE_CString>,
- ACE_Equal_To<ACE_CString>,
- ACE_Null_Mutex> PB_MAP;
-
- /// Internal TP name to id map.
- TP_MAP threadpool_map_;
-
- /// Internal PB name to priority bands map.
- PB_MAP priority_bands_map_;
-
- /// create a single policy
- CORBA::Policy_ptr create_single_policy
- (const PolicyDef &policy_def);
-
- /// Hash_Map stuff.
- typedef ACE_Hash_Map_Manager_Ex<ACE_CString,
- CORBA::PolicyList_var,
- ACE_Hash<ACE_CString>,
- ACE_Equal_To<ACE_CString>,
- ACE_Null_Mutex> POLICY_MAP;
-
- /// Internal TP names to id map.
- POLICY_MAP policy_map_;
-};
-}
-}
-
-#if defined (__ACE_INLINE__)
-# include "RTConfig_Manager.inl"
-#endif /* __ACE_INLINE__ */
-
-#include /**/ "ace/post.h"
-#endif /* CIAO_RTCONFIG_MANAGER_H */
-
diff --git a/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.inl b/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.inl
deleted file mode 100644
index 08aaef9f6ad..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/RT/RTConfig_Manager.inl
+++ /dev/null
@@ -1,8 +0,0 @@
-// $Id$
-
-
-ACE_INLINE
-CIAO::Deployment::RTResource_Config_Manager::RTResource_Config_Manager ()
-{
-}
-
diff --git a/CIAO/ciao/FTComponentServer/Configurators/RT/RTNA_Configurator_Export.h b/CIAO/ciao/FTComponentServer/Configurators/RT/RTNA_Configurator_Export.h
deleted file mode 100644
index 689a871c7e5..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/RT/RTNA_Configurator_Export.h
+++ /dev/null
@@ -1,58 +0,0 @@
-
-// -*- C++ -*-
-// $Id$
-// Definition for Win32 Export directives.
-// This file is generated automatically by generate_export_file.pl CIAO_RTNA_Configurator
-// ------------------------------
-#ifndef CIAO_RTNA_CONFIGURATOR_EXPORT_H
-#define CIAO_RTNA_CONFIGURATOR_EXPORT_H
-
-#include "ace/config-all.h"
-
-#if defined (ACE_AS_STATIC_LIBS) && !defined (CIAO_RTNA_CONFIGURATOR_HAS_DLL)
-# define CIAO_RTNA_CONFIGURATOR_HAS_DLL 0
-#endif /* ACE_AS_STATIC_LIBS && CIAO_RTNA_CONFIGURATOR_HAS_DLL */
-
-#if !defined (CIAO_RTNA_CONFIGURATOR_HAS_DLL)
-# define CIAO_RTNA_CONFIGURATOR_HAS_DLL 1
-#endif /* ! CIAO_RTNA_CONFIGURATOR_HAS_DLL */
-
-#if defined (CIAO_RTNA_CONFIGURATOR_HAS_DLL) && (CIAO_RTNA_CONFIGURATOR_HAS_DLL == 1)
-# if defined (CIAO_RTNA_CONFIGURATOR_BUILD_DLL)
-# define CIAO_RTNA_Configurator_Export ACE_Proper_Export_Flag
-# define CIAO_RTNA_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T)
-# define CIAO_RTNA_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# else /* CIAO_RTNA_CONFIGURATOR_BUILD_DLL */
-# define CIAO_RTNA_Configurator_Export ACE_Proper_Import_Flag
-# define CIAO_RTNA_CONFIGURATOR_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T)
-# define CIAO_RTNA_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-# endif /* CIAO_RTNA_CONFIGURATOR_BUILD_DLL */
-#else /* CIAO_RTNA_CONFIGURATOR_HAS_DLL == 1 */
-# define CIAO_RTNA_Configurator_Export
-# define CIAO_RTNA_CONFIGURATOR_SINGLETON_DECLARATION(T)
-# define CIAO_RTNA_CONFIGURATOR_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK)
-#endif /* CIAO_RTNA_CONFIGURATOR_HAS_DLL == 1 */
-
-// Set CIAO_RTNA_CONFIGURATOR_NTRACE = 0 to turn on library specific tracing even if
-// tracing is turned off for ACE.
-#if !defined (CIAO_RTNA_CONFIGURATOR_NTRACE)
-# if (ACE_NTRACE == 1)
-# define CIAO_RTNA_CONFIGURATOR_NTRACE 1
-# else /* (ACE_NTRACE == 1) */
-# define CIAO_RTNA_CONFIGURATOR_NTRACE 0
-# endif /* (ACE_NTRACE == 1) */
-#endif /* !CIAO_RTNA_CONFIGURATOR_NTRACE */
-
-#if (CIAO_RTNA_CONFIGURATOR_NTRACE == 1)
-# define CIAO_RTNA_CONFIGURATOR_TRACE(X)
-#else /* (CIAO_RTNA_CONFIGURATOR_NTRACE == 1) */
-# if !defined (ACE_HAS_TRACE)
-# define ACE_HAS_TRACE
-# endif /* ACE_HAS_TRACE */
-# define CIAO_RTNA_CONFIGURATOR_TRACE(X) ACE_TRACE_IMPL(X)
-# include "ace/Trace.h"
-#endif /* (CIAO_RTNA_CONFIGURATOR_NTRACE == 1) */
-
-#endif /* CIAO_RTNA_CONFIGURATOR_EXPORT_H */
-
-// End of auto generated file.
diff --git a/CIAO/ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.cpp b/CIAO/ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.cpp
deleted file mode 100644
index 5f199f366aa..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.cpp
+++ /dev/null
@@ -1,108 +0,0 @@
-// $Id$
-
-#include "RTNodeApp_Configurator.h"
-#include "DAnCE/Deployment/CIAO_ServerResourcesC.h"
-#include "tao/RTPortableServer/RTPortableServer.h"
-
-CIAO::RTNodeApp_Configurator::~RTNodeApp_Configurator ()
-{
-}
-
-int
-CIAO::RTNodeApp_Configurator::pre_orb_initialize ()
-{
- CIAO_DEBUG ((LM_DEBUG, "RTNodeApp_Configurator::pre_orb_init\n"));
-
- return 0;
-}
-
-int
-CIAO::RTNodeApp_Configurator::post_orb_initialize (CORBA::ORB_ptr o)
-{
- CIAO_DEBUG ((LM_DEBUG, "RTNodeApp_Configurator::post_orb_init\n"));
-
- this->orb_ = CORBA::ORB::_duplicate (o);
-
- CORBA::Object_var object =
- this->orb_->resolve_initial_references ("RTORB");
-
- this->rtorb_ =
- RTCORBA::RTORB::_narrow (object.in ());
-
- this->config_manager_.init (this->rtorb_.in ());
-
- return 0;
-}
-
-int
-CIAO::RTNodeApp_Configurator::init_resource_manager
-(const ::Deployment::Properties &properties)
-{
-
- // if (CIAO::debug_level () > 9)
- CIAO_DEBUG ((LM_DEBUG, "RTNodeApp_Configurator::init_resource_manager\n"));
- // @@ Should we cache the properties that we consumed here?
-
- for (CORBA::ULong i = 0; i < properties.length (); ++i)
- {
- // if (CIAO::debug_level () > 9)
- CIAO_DEBUG ((LM_DEBUG, "RTNodeApp_Configurator::init_resource_manager processing property: %s\n",
- properties[i].name.in ()));
-
- if (ACE_OS::strcmp ("CIAOServerResources", properties[i].name.in ()) == 0)
- {
- const CIAO::DAnCE::ServerResource *svr_resource;
- if (properties[i].value >>= svr_resource)
- {
- this->config_manager_.init_resources (*svr_resource);
- // Now we have the information to initialize the manager.
- }
- else
- CIAO_ERROR_RETURN ((LM_ERROR,
- "ERROR: RTNodeApp_Configurator::init_resource_manager unable to extract CIAOServerResources\n"), -1);
- }
-
- // Ignore other stuff
- }
-
- return 0;
-}
-
-CORBA::PolicyList *
-CIAO::RTNodeApp_Configurator::find_container_policies
-(const ::Deployment::Properties &properties)
-{
- CIAO_DEBUG ((LM_DEBUG, "RTNodeApp_Configurator::find_container_policies\n"));
- // @@ Should we cache the properties that we consumed here?
-
- for (CORBA::ULong i = 0; i < properties.length (); ++i)
- {
- CIAO_DEBUG ((LM_DEBUG, "RTNodeApp_Configurator::find_container_policies processing property: %s\n",
- properties[i].name.in ()));
-
- if (ACE_OS::strcmp ("ContainerPolicySet", properties[i].name) == 0)
- {
- const char *policy_name = 0;
- if (properties[i].value >>= policy_name)
- {
- return this->config_manager_.find_policies_by_name (policy_name);
- }
- else
- CIAO_ERROR_RETURN ((LM_ERROR,
- "ERROR: RTNodeApp_Configurator::find_container_policies unable to extract ContainerPolicySet\n"), 0);
- }
- }
-
- return 0;
-}
-
-
-extern "C" CIAO_RTNA_Configurator_Export CIAO::NodeApp_Configurator *create_nodeapp_configurator (void);
-
-CIAO::NodeApp_Configurator *
-create_nodeapp_configurator (void)
-{
- CIAO::RTNodeApp_Configurator *config = 0;
- ACE_NEW_RETURN (config, CIAO::RTNodeApp_Configurator, 0);
- return config;
-}
diff --git a/CIAO/ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.h b/CIAO/ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.h
deleted file mode 100644
index fc2388b6aff..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/RTNodeApp_Configurator.h
+++ /dev/null
@@ -1,78 +0,0 @@
-// $Id$
-/**========================================================
- *
- * @file RTNodeApp_Configurator.h
- *
- * @Brief This file contains the implementation of
- * the RTNodeApp_Configurator, a concrete NodeApp_Configurator for
- * setting up real-time support for NodeApplication.
- *
- *
- * @author Nanbor Wang <nanbor@exothermic.txcorp.com>
- *========================================================*/
-
-#ifndef RTNODEAPP_CONFIGURATOR_H
-#define RTNODEAPP_CONFIGURATOR_H
-#include /**/ "ace/pre.h"
-
-#include "ace/config-all.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "NodeApp_Configurator.h"
-#include "RTNA_Configurator_Export.h"
-#include "tao/RTCORBA/RTCORBA.h"
-#include "RTConfig_Manager.h"
-
-namespace CIAO
-{
- /**
- * @class RTNodeApp_Configurator
- *
- * @brief This class implements a concrete NodeApp_Configurator for
- * setting up the NodeApplication process for RT support.
- **/
- class CIAO_RTNA_Configurator_Export RTNodeApp_Configurator :
- public NodeApp_Configurator
- {
- public:
- /// Default destructor.
- virtual ~RTNodeApp_Configurator (void);
-
- /**
- * @brief "pre_orb_initialize" is called before ORB_init.
- */
- virtual int pre_orb_initialize (void);
-
- /**
- * @brief "initialize" is called after NodeApplication get a hold
- * at this object.
- */
- virtual int post_orb_initialize (CORBA::ORB_ptr o);
-
- /**
- * @brief "init_resource_manager" is called by NodeApplication when
- * it receives an "install" commands.
- */
- virtual int
- init_resource_manager (const ::Deployment::Properties &properties);
-
- /**
- * @brief get a policyset by its name.
- */
- virtual CORBA::PolicyList *
- find_container_policies (const ::Deployment::Properties &properties);
-
- protected:
- CORBA::ORB_var orb_;
-
- RTCORBA::RTORB_var rtorb_;
-
- RTResource_Config_Manager config_manager_;
- };
-}
-
-#include /**/ "ace/post.h"
-#endif /* RTNODEAPP_CONFIGURATOR_H */
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Server_Configurator.cpp b/CIAO/ciao/FTComponentServer/Configurators/Server_Configurator.cpp
deleted file mode 100644
index 406817972de..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Server_Configurator.cpp
+++ /dev/null
@@ -1,334 +0,0 @@
-// $Id$
-
-#include "Server_Configurator.h"
-#include "ace/Log_Msg.h"
-#include "ciao/CIAO_common.h"
-#include "ciao/ComponentServer/CIAO_ServerResourcesC.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
-
- ComponentServer_Configurator::ComponentServer_Configurator (bool rt)
- : rt_support_ (rt)
- {
- }
-
- ComponentServer_Configurator::~ComponentServer_Configurator (void)
- {
- // Not much to do.
- }
-
- void
- ComponentServer_Configurator::set_rt_support (void)
- {
- this->rt_support_ = 1;
- }
-
- bool
- ComponentServer_Configurator::rt_support (void)
- {
- return this->rt_support_;
- }
-
- bool
- ComponentServer_Configurator::create_config_managers (void)
- {
- typedef CIAO::Deployment::Config_Manager * (*na_intelligent_designer)(void);
- typedef CIAO::Deployment::Config_Manager * (*rtna_intelligent_designer)(void);
- CIAO::Deployment::Config_Manager* ptr = 0;
- CIAO::Deployment::Config_Manager* rt_ptr = 0;
-
- int retval = this->config_dll_.open (/*ACE_DLL_PREFIX*/ ACE_TEXT ("CIAO_Basic_Config_Manager"),
- ACE_DEFAULT_SHLIB_MODE,
- 0);
-
- if (0 != retval)
- {
- CIAO_ERROR_RETURN ((LM_ERROR,
- CLINFO "ComponentServer_Configurator - Error loading CIAO_Basic_Config_manager DLL: %p\n",
- "dll.open"),
- false);
- }
-
- // Cast the void* to non-pointer type first - it's not legal to
- // cast a pointer-to-object directly to a pointer-to-function.
- void *void_ptr =
- this->config_dll_.symbol (ACE_TEXT ("create_basic_config_manager"));
-
- ptrdiff_t tmp = reinterpret_cast<ptrdiff_t> (void_ptr);
-
- // "id" is for na_intelligent-designer.
- na_intelligent_designer config_id =
- reinterpret_cast<na_intelligent_designer> (tmp);
-
- if (0 == config_id)
- {
- CIAO_ERROR_RETURN ((LM_ERROR,
- CLINFO "ComponentServer_Configurator - Error loading CIAO_Basic_Configurator entrypoint: %p\n",
- "dll.symbol"),
- false);
- }
-
- ptr = config_id ();
-
- if (0 == ptr)
- {
- CIAO_ERROR_RETURN ((LM_ERROR,
- CLINFO "ComponentServer_Configurator: Error creating ComponentServer_Configurator\n"),
- false);
- }
-
- this->na_config_manager_.reset (ptr);
-
- if (this->rt_support_)
- {
- int rt_retval = this->config_dll_.open (ACE_DLL_PREFIX ACE_TEXT ("CIAO_RTNA_Configurator"),
- ACE_DEFAULT_SHLIB_MODE,
- false);
-
- if (0 != rt_retval)
- {
- CIAO_ERROR_RETURN ((LM_ERROR,
- "ComponentServer_Configurator - Error while loading CIAO_RTNA_Configurator: %p\n",
- "dll.open"),
- false);
- }
-
- // Cast the void* to non-pointer type first - it's not legal to
- // cast a pointer-to-object directly to a pointer-to-function.
- void *rt_void_ptr =
- this->config_dll_.symbol (ACE_TEXT ("create_rt_config_manager"));
- ptrdiff_t rt_tmp = reinterpret_cast<ptrdiff_t> (rt_void_ptr);
-
- // "id" is for na_intelligent-designer.
- rtna_intelligent_designer rt_config_id =
- reinterpret_cast<rtna_intelligent_designer> (rt_tmp);
-
- if (0 == rt_config_id)
- {
- CIAO_ERROR_RETURN ((LM_ERROR,
- CLINFO "ComponentServer_Configurator: Error while using RTNA entrypoint: %p",
- "dll.symbol"),
- false);
- }
-
- rt_ptr = rt_config_id ();
-
- if (0 == rt_ptr)
- {
- CIAO_ERROR_RETURN ((LM_ERROR,
- CLINFO "ComponentServer_Configurator: Error creating RTComponentServer_Configurator\n"),
- false);
- }
-
- this->rt_config_manager_.reset (rt_ptr);
- }
-
- return true;
- }
-
- int
- ComponentServer_Configurator::pre_orb_initialize ()
- {
- CIAO_DEBUG ((LM_TRACE,CLINFO "ComponentServer_Configurator::pre_orb_init\n"));
-
- (*this->na_config_manager_.get ()).pre_orb_initialize ();
- if (this->rt_support_)
- {
- (*this->rt_config_manager_.get ()).pre_orb_initialize ();
- }
-
- return 0;
- }
-
- int
- ComponentServer_Configurator::post_orb_initialize (CORBA::ORB_ptr o)
- {
- CIAO_DEBUG ((LM_TRACE, CLINFO "ComponentServer_Configurator::post_orb_init\n"));
- this->orb_ = CORBA::ORB::_duplicate (o);
-
- (*this->na_config_manager_.get ()).init (this->orb_.in ());
- if (this->rt_support_ == 1)
- {
- (*this->rt_config_manager_.get ()).init (this->orb_.in ());
- }
-
- (*this->na_config_manager_.get ()).post_orb_initialize (this->orb_.in ());
- if (this->rt_support_ == 1)
- {
- (*this->rt_config_manager_.get ()).post_orb_initialize (this->orb_.in ());
- }
-
- return 0;
- }
-
- int
- ComponentServer_Configurator::init_resource_manager
- (const ::Components::ConfigValues &properties)
- {
- for (CORBA::ULong i = 0; i < properties.length (); ++i)
- {
- if (ACE_OS::strcmp ("CIAOServerResources", properties[i]->name ()) == 0)
- {
- const ServerResource *svr_resource;
- if (properties[i]->value () >>= svr_resource)
- {
- (*this->na_config_manager_.get ()).
- init_resources (*svr_resource);
-
- if (this->rt_support_ == 1)
- {
- (*this->rt_config_manager_.get ()).
- init_resources (*svr_resource);
- }
- }
- else
- {
- CIAO_ERROR_RETURN ((LM_ERROR,
- CLINFO "ERROR: ComponentServer_Configurator::"
- "init_resource_manager unable to extract"
- "CIAOServerResources\n"), -1);
- }
- }
- }
-
- return 0;
- }
-
- CORBA::PolicyList *
- ComponentServer_Configurator::find_container_policies
- (const ::Components::ConfigValues &properties)
- {
- if (!this->na_config_manager_.get ())
- return 0;
-
- CORBA::PolicyList *configured_policies = 0;
- CORBA::PolicyList *rt_configured_policies = 0;
-
- for (CORBA::ULong i = 0; i < properties.length (); ++i)
- {
- if (ACE_OS::strcmp ("ContainerPolicySet", properties[i]->name ()) == 0)
- {
- const char *policy_name;
- if (properties[i]->value () >>= policy_name)
- {
- configured_policies = (*this->na_config_manager_.get ()).
- find_policies_by_name (policy_name);
-
- CORBA::ULong p_length = 0;
- if (configured_policies != 0)
- {
- p_length = configured_policies->length ();
- }
-
- if (this->rt_support_ == 1)
- {
- rt_configured_policies = (*this->rt_config_manager_.get ()).
- find_policies_by_name (policy_name);
- }
-
- CORBA::PolicyList_var temp_policies;
- CORBA::ULong rtp_length = 0;
- if (rt_configured_policies != 0)
- {
- rtp_length = rt_configured_policies->length ();
- temp_policies = rt_configured_policies;
- }
- else
- {
- return configured_policies;
- }
-
- CORBA::ULong final_length = p_length + rtp_length;
- temp_policies->length (final_length);
-
- for (CORBA::ULong i = 0; i < p_length; ++i)
- {
- temp_policies[i+rtp_length] =
- CORBA::Policy::_duplicate ((*configured_policies)[i]);
- }
- return temp_policies._retn ();
- }
- else
- {
- CIAO_ERROR_RETURN ((LM_ERROR,
- CLINFO "ERROR: ComponentServer_Configurator:"
- "find_container_policies unable to extract"
- "ContainerPolicySet\n"), 0);
- }
- }
- }
- return 0;
- }
-
- CORBA::PolicyList *
- ComponentServer_Configurator::find_policies_by_name (const char *policy_name)
- {
- if (!this->na_config_manager_.get ())
- return 0;
-
- CORBA::PolicyList *configured_policies = 0;
- CORBA::PolicyList *rt_configured_policies = 0;
-
- configured_policies = (*this->na_config_manager_.get ()).
- find_policies_by_name (policy_name);
-
- CORBA::ULong p_length = 0;
- if (configured_policies != 0)
- {
- p_length = configured_policies->length ();
- }
-
- if (this->rt_support_ == 1)
- {
- rt_configured_policies = (*this->rt_config_manager_.get ()).
- find_policies_by_name (policy_name);
- }
-
- CORBA::PolicyList_var temp_policies;
- CORBA::ULong rtp_length = 0;
- if (rt_configured_policies != 0)
- {
- rtp_length = rt_configured_policies->length ();
- temp_policies = rt_configured_policies;
- }
- else
- {
- return configured_policies;
- }
-
- CORBA::ULong final_length = p_length + rtp_length;
- temp_policies->length (final_length);
-
- for (CORBA::ULong i = 0; i < p_length; ++i)
- {
- temp_policies[i+rtp_length] =
- CORBA::Policy::_duplicate ((*configured_policies)[i]);
- }
- return temp_policies._retn ();
- }
-
- bool
- ComponentServer_Configurator::policy_exists (const char *policy_set_id)
- {
- if (!this->na_config_manager_.get ())
- return 0;
-
- bool result;
- result = (*this->na_config_manager_.get ()).
- policy_exists (policy_set_id);
-
- if (result == false)
- {
- if (this->rt_support_ == 1)
- {
- result = (*this->rt_config_manager_.get ()).
- policy_exists (policy_set_id);
- }
- }
- return result;
- }
- }
-}
diff --git a/CIAO/ciao/FTComponentServer/Configurators/Server_Configurator.h b/CIAO/ciao/FTComponentServer/Configurators/Server_Configurator.h
deleted file mode 100644
index 4a8074b083d..00000000000
--- a/CIAO/ciao/FTComponentServer/Configurators/Server_Configurator.h
+++ /dev/null
@@ -1,125 +0,0 @@
-//$Id$
-/**========================================================
- *
- * @file ComponentServer_Configurator.h
- *
- * @Brief This file contains the implementation of
- * the basic ComponentServer_Configurator interface, the one
- * that does nothing more
- *
- * @author Nanbor Wang <nanbor@exothermic.txcorp.com>
- *========================================================*/
-
-#ifndef COMPONENTSERVER_CONFIGURATOR_H
-#define COMPONENTSERVER_CONFIGURATOR_H
-#include /**/ "ace/pre.h"
-
-#include "ace/config-all.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "ace/DLL.h"
-#include "ace/Auto_Ptr.h"
-#include "ccm/CCM_StandardConfiguratorC.h"
-#include "ComponentServer_Configurator_export.h"
-#include "Config_Manager.h"
-
-namespace CIAO
-{
- namespace Deployment
- {
- /**
- *
- * @class ComponentServer_Configurator
- *
- * @brief This class defines and implements the default
- * ComponentServer_Configurator base class that's needed for configuring the
- * ComponentServer application process.
- **/
- class ComponentServer_Configurator_Export ComponentServer_Configurator
- {
- public:
-
- /// Default constructor.
- ComponentServer_Configurator (bool rt);
-
- /// Default destructor.
- virtual ~ComponentServer_Configurator (void);
-
- /**
- * @brief "pre_orb_initialize" is called before ORB_init.
- */
- virtual int pre_orb_initialize (void);
-
- /**
- * @brief "post_orb_initialize" is called after ComponentServer
- * get a hold at this object.
- */
- virtual int post_orb_initialize (CORBA::ORB_ptr o);
-
- /**
- * @brief "init_resource_manager" is called by ComponentServer when
- * it receives an "install" commands.
- */
- virtual int
- init_resource_manager (const ::Components::ConfigValues &properties);
-
- /**
- * @brief get a policyset by its name.
- */
- virtual CORBA::PolicyList *
- find_container_policies (const ::Components::ConfigValues &properties);
-
- /// @@ Perhaps we also need a finalizer method here. Perhaps we
- /// even need to differentiate finalizer before ORB is destroyed
- /// and the one after that.
-
- bool rt_support (void);
-
- void set_rt_support (void);
-
- virtual bool create_config_managers (void);
-
- bool policy_exists (const char *policy_set_id);
-
- CORBA::PolicyList *
- find_policies_by_name (const char *name);
-
- protected:
-
- int rt_support_;
-
- CORBA::ORB_var orb_;
-
- auto_ptr<Config_Manager> rt_config_manager_;
-
- auto_ptr<Config_Manager> na_config_manager_;
-
- ACE_DLL config_dll_;
- };
- }
-}
-
-/**
- * For dynamically linkable concrete ComponentServer_Configurator
- * implementation, remember to create a factory method using "C"
- * calling convention in the CPP file as follow:
-
- extern "C" EXPORT_MACRO CIAO::ComponentServer_Configurator *create_nodeapp_configurator (void);
-
- CIAO::ComponentServer_Configurator *
- create_nodeapp_configurator (void)
- {
- concrete_ComponentServer_Configurator *config;
- ACE_NEW_RETURN (config, concrete_ComponentServer_Configurator, 0);
- return config;
- }
-
-*/
-
-
-#include /**/ "ace/post.h"
-#endif /* NODEAPP_CONFIGURATOR_H */
-
diff --git a/CIAO/ciao/FTComponentServer/Name_Helper_T.h b/CIAO/ciao/FTComponentServer/Name_Helper_T.h
deleted file mode 100644
index 16da1d6c901..00000000000
--- a/CIAO/ciao/FTComponentServer/Name_Helper_T.h
+++ /dev/null
@@ -1,196 +0,0 @@
-#ifndef _NAME_HELPER_T_H_
-#define _NAME_HELPER_T_H_
-
-#include <stdexcept>
-#include <orbsvcs/CosNamingC.h>
-#include <ace/Env_Value_T.h>
-
-class Name_Helper_Exception : public std::domain_error
-{
- public:
- Name_Helper_Exception (const std::string & reason = "")
- : std::domain_error (reason) {}
-};
-
-template <typename T>
-class Name_Helper_T
-{
- public:
- Name_Helper_T (CORBA::ORB_ptr orb, bool use_env_var = false)
- {
- CORBA::Object_var ns_obj;
-
- if (use_env_var)
- {
- std::string ns_ior = ACE_Env_Value<std::string> ("NameServiceIOR",
- std::string ());
-
- if (ns_ior.empty ())
- {
- throw Name_Helper_Exception ("Name_Helper_T - no NameServiceIOR env variable");
- }
-
- ns_obj = orb->string_to_object (ns_ior.c_str ());
- }
- else
- {
- ns_obj = orb->resolve_initial_references ("NameService");
- }
-
- if (CORBA::is_nil (ns_obj.in ()))
- {
- throw Name_Helper_Exception ("Name_Helper_T - could not resolve NameService");
- }
-
- ns_ = CosNaming::NamingContextExt::_narrow (ns_obj.in ());
-
- if (CORBA::is_nil (ns_.in ()))
- {
- throw Name_Helper_Exception ("Name_Helper_T - could not narrow to NameContextExt");
- }
- }
-
- void bind (std::string path, typename T::_ptr_type obj)
- {
- size_t last_slash = path.find_last_of ('/');
-
- std::string obj_name;
- std::string obj_path;
-
- if (last_slash != std::string::npos)
- {
- obj_path = path.substr (0, last_slash);
- obj_name = path.substr (last_slash + 1);
- }
- else
- {
- obj_name = path;
- }
-
- if (obj_name.empty ())
- throw Name_Helper_Exception ("Name_Helper_T::bind - no object name.");
-
- ACE_DEBUG ((LM_INFO, "path=%s, name=%s\n", obj_path.c_str (), obj_name.c_str ()));
-
- CosNaming::Name_var name;
- CosNaming::NamingContext_var nc;
-
- if (!obj_path.empty ())
- {
- name = ns_->to_name (obj_path.c_str ());
-
- nc = CosNaming::NamingContext::_narrow (ns_.in ());
-
- CosNaming::Name entry;
- entry.length (1);
-
- for (size_t i = 0;
- i < name->length ();
- ++i)
- {
- entry[0] = CosNaming::NameComponent (name[i]);
- try
- {
- nc = nc->bind_new_context (entry);
- }
- catch (CosNaming::NamingContext::AlreadyBound & ex)
- {
- // if the entry is already there just go on
- nc = CosNaming::NamingContext::_narrow (nc->resolve (entry));
- }
- }
- }
-
- name = ns_->to_name (obj_name.c_str ());
-
- try
- {
- nc->bind (name, obj);
- }
- catch (CosNaming::NamingContext::AlreadyBound & e)
- {
- nc->rebind (name, obj);
- }
- }
-
- void unbind (const std::string & path, size_t depth = 0)
- {
- std::string current_path = path;
- size_t current_depth = 0;
- CosNaming::Name_var name;
-
- if (path.empty ())
- throw Name_Helper_Exception ("Name_Helper_T::unbind - empty path");
-
- do
- {
- name = ns_->to_name (current_path.c_str ());
-
- CosNaming::NamingContext_var nc =
- CosNaming::NamingContext::_narrow (
- ns_->resolve (name.in ()));
-
- bool no_more_entries = true;
-
- if (!CORBA::is_nil (nc.in ()))
- {
- CosNaming::BindingList_var bl;
- CosNaming::BindingIterator_var bit;
- nc->list (2, bl.out (), bit.out ());
-
- if (bl->length () > 0)
- no_more_entries = false;
- }
-
- if (no_more_entries)
- ns_->unbind (name.in ());
-
- if (current_depth < depth)
- {
- size_t pos = current_path.find_last_of ('/');
-
- if (pos == std::string::npos)
- break;
-
- current_path = current_path.substr (0, pos);
- ++current_depth;
- }
- }
- while (depth >= current_depth);
- }
-
- typename T::_ptr_type resolve (const std::string & path)
- {
- CORBA::Object_var obj = ns_->resolve_str (path.c_str ());
-
- typename T::_var_type ret = T::_narrow (obj.in ());
-
- if (CORBA::is_nil (ret.in ()))
- throw Name_Helper_Exception ("Name_Helper_T::resolve - could not narrow resolved obj");
-
- return ret._retn ();
- }
-
- std::string escape_dots (const std::string &path)
- {
- std::string esc_path (path);
-
- // replace all dots in the path with excaped dots for
- // to_name conversion.
- for (size_t pos = esc_path.find ('.', 0);
- pos < esc_path.length ();
- pos = esc_path.find ('.', pos))
- {
- esc_path.replace (pos, 1, "\\.");
- pos += 2;
- }
-
- return esc_path;
- }
-
- private:
- CORBA::ORB_var orb_;
- CosNaming::NamingContextExt_var ns_;
-};
-
-#endif /* _NAME_HELPER_T_H_ */