summaryrefslogtreecommitdiff
path: root/TAO/CIAO/tools/RTComponentServer/RTServer_Impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/CIAO/tools/RTComponentServer/RTServer_Impl.cpp')
-rw-r--r--TAO/CIAO/tools/RTComponentServer/RTServer_Impl.cpp261
1 files changed, 0 insertions, 261 deletions
diff --git a/TAO/CIAO/tools/RTComponentServer/RTServer_Impl.cpp b/TAO/CIAO/tools/RTComponentServer/RTServer_Impl.cpp
deleted file mode 100644
index 7b549a1ec2c..00000000000
--- a/TAO/CIAO/tools/RTComponentServer/RTServer_Impl.cpp
+++ /dev/null
@@ -1,261 +0,0 @@
-// $Id$
-
-#include "RTServer_Impl.h"
-#include "ciao/CIAO_common.h"
-
-#if !defined (__ACE_INLINE__)
-# include "RTServer_Impl.inl"
-#endif /* __ACE_INLINE__ */
-
-CIAO::RTServer::RTComponentServer_Impl::~RTComponentServer_Impl ()
-{
-}
-
-int
-CIAO::RTServer::RTComponentServer_Impl::init (Components::ConfigValues &options
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::InvalidConfiguration))
-{
- // @@ Initialize ComponentServer and create the internal container
- // implementation that actually interacts with installed
- // homes/components.
-
- ACE_NEW_THROW_EX (this->config_,
- ::Components::ConfigValues (),
- CORBA::INTERNAL ());
- ACE_CHECK_RETURN (-1);
-
- *this->config_ = options;
-
- this->parse_server_config_values (options
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- // We will probably need two ORBs in this process. One for the
- // deployment framework, and one for the actual components.
- return 0;
-}
-
-Components::Deployment::Container_ptr
-CIAO::RTServer::RTComponentServer_Impl::create_container
-(const Components::ConfigValues & config
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::CreateFailure,
- Components::InvalidConfiguration))
-{
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG, "RTComponentServer_Impl::create_container\n"));
-
- CIAO::RTServer::RTContainer_Impl *container_servant = 0;
-
- ACE_NEW_THROW_EX (container_servant,
- CIAO::RTServer::RTContainer_Impl (this->orb_.in (),
- this->poa_.in (),
- this->get_objref (),
- this->policy_set_manager_,
- this->static_config_flag_,
- this->static_entrypts_maps_),
- CORBA::INTERNAL ());
- ACE_CHECK_RETURN (0);
-
- PortableServer::ServantBase_var safe_servant (container_servant);
- container_servant->init (config,
- this->get_component_installation ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- PortableServer::ObjectId_var oid
- = this->poa_->activate_object (container_servant
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- CORBA::Object_var obj
- = this->poa_->id_to_reference (oid.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- Components::Deployment::Container_var ci
- = Components::Deployment::Container::_narrow (obj.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- // Cached the objref in its servant.
- container_servant->set_objref (ci.in () ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- {
- ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->lock_, 0);
-
- this->container_set_.add (ci.in ());
- }
-
- return ci._retn ();
-}
-
-void
-CIAO::RTServer::RTComponentServer_Impl::
-parse_server_config_values (const Components::ConfigValues &options
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::InvalidConfiguration))
-{
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG, "RTComponentServer_Impl::parse_server_config_values\n"));
-
- for (CORBA::ULong i = 0; i < options.length (); ++i)
- {
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG, "parse_server_options: %s\n",
- options[i]->name ()));
-
- if (ACE_OS::strcmp (options[i]->name (), "CIAO-RTResources") == 0)
- {
- CIAO::RTConfiguration::RTORB_Resource_Info *resource_info;
- if (options[i]->value () >>= resource_info)
- {
- // initialize the resource manager with resource defintions.
- this->resource_manager_.init (*resource_info
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- }
- }
- else if (ACE_OS::strcmp (options[i]->name (), "CIAO-RTPolicySets") == 0)
- {
- CIAO::RTConfiguration::Policy_Sets * policy_sets;
- if (options[i]->value () >>= policy_sets)
- {
- // initialize the policyset manager with policy set defintions.
- this->policy_set_manager_.init (*policy_sets
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
- }
- }
- else
- {
- Components::InvalidConfiguration *exc = 0;
-
- ACE_NEW_THROW_EX (exc,
- Components::InvalidConfiguration,
- CORBA::NO_MEMORY ());
-
- exc->name = CORBA::string_dup (options[i]->name ());
- exc->reason = Components::InvalidConfigValueType;
-#if defined (ACE_HAS_EXCEPTIONS)
- auto_ptr<Components::InvalidConfiguration> safety (exc);
-
- // Direct throw because we don't have the ACE_TRY_ENV.
- exc->_raise ();
-#else
- // We can not use ACE_THROW here.
- ACE_TRY_ENV.exception (exc);
-#endif
- }
- }
-}
-
-// ============================================================
-
-CIAO::RTServer::RTContainer_Impl::~RTContainer_Impl ()
-{
-}
-
-int
-CIAO::RTServer::RTContainer_Impl::init (const Components::ConfigValues &options,
- Components::Deployment::ComponentInstallation_ptr inst
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::InvalidConfiguration))
-{
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG, "RTContainer_Impl::init\n"));
-
- this->config_ = options;
- this->parse_container_config_values (options
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- this->installation_ =
- Components::Deployment::ComponentInstallation::_duplicate (inst);
-
- // @@ Initialize container and create the internal container
- // implementation that actually interacts with installed
- // homes/components.
-
- // @@ We will need a container factory here later on when we support
- // more kinds of container implementations.
-
- // @@ Fish out the ComponentServer object reference from <options>.
-
- ACE_NEW_THROW_EX (this->container_,
- CIAO::Session_Container (this->orb_.in (),
- this->static_config_flag_,
- this->static_entrypts_maps_),
- CORBA::INTERNAL ());
- ACE_CHECK_RETURN (-1);
-
- return this->container_->init (0,
- this->Policies_.ptr ()
- ACE_ENV_ARG_PARAMETER);
-}
-
-void
-CIAO::RTServer::RTContainer_Impl::
-parse_container_config_values (const Components::ConfigValues &options
- ACE_ENV_ARG_DECL)
- ACE_THROW_SPEC ((CORBA::SystemException,
- Components::InvalidConfiguration))
-{
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG, "parse_container_config_values"));
-
- for (CORBA::ULong i = 0; i < options.length (); ++i)
- {
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG, "options.name= %s\n", options[i]->name ()));
-
- if (ACE_OS::strcmp (options[i]->name (), "CIAO-RTPolicySet") == 0)
- {
- const char *ps_name;
- if (options[i]->value () >>= ps_name)
- {
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG,
- "-Using RTPolicySet named: %s\n",
- ps_name));
- CORBA::PolicyList_var policies =
- // initialize the policyset manager with policy set defintions.
- this->policyset_manager_.find_policies_by_name (ps_name
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- this->Policies_ = policies;
- if (CIAO::debug_level () > 10)
- ACE_DEBUG ((LM_DEBUG,
- "Found RTPolicySet named: %s\n",
- ps_name));
- }
- }
- else
- {
- Components::InvalidConfiguration *exc = 0;
-
- ACE_NEW_THROW_EX (exc,
- Components::InvalidConfiguration,
- CORBA::NO_MEMORY ());
-
- exc->name = CORBA::string_dup (options[i]->name ());
- exc->reason = Components::InvalidConfigValueType;
-#if defined (ACE_HAS_EXCEPTIONS)
- auto_ptr<Components::InvalidConfiguration> safety (exc);
-
- // Direct throw because we don't have the ACE_TRY_ENV.
- exc->_raise ();
-#else
- // We can not use ACE_THROW here.
- ACE_TRY_ENV.exception (exc);
-#endif
- }
- }
-}
View Lorry Controller Status