diff options
Diffstat (limited to 'modules/CIAO/DAnCE/NodeApplicationManager')
4 files changed, 0 insertions, 338 deletions
diff --git a/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager.mpc b/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager.mpc deleted file mode 100644 index 8ce4f18aa89..00000000000 --- a/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager.mpc +++ /dev/null @@ -1,13 +0,0 @@ -// -*- MPC -*- -// $Id$ - -project: dance_lib, naming, dance_nodeapplicationmanager_skel, \ - dynamicinterface, ccm_componentserver_svnt, ciao_cs_client, \ - dance_nodeapplication, avoids_ace_for_tao { - sharedname = DAnCE_NodeApplicationManager - dynamicflags = NODEAPPLICATIONMANAGER_BUILD_DLL - - Source_Files { - NodeApplicationManager_Impl.cpp - } -} diff --git a/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Export.h b/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Export.h deleted file mode 100644 index b86e93b49ab..00000000000 --- a/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_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 NodeApplicationManager -// ------------------------------ -#ifndef NODEAPPLICATIONMANAGER_EXPORT_H -#define NODEAPPLICATIONMANAGER_EXPORT_H - -#include "ace/config-all.h" - -#if defined (ACE_AS_STATIC_LIBS) && !defined (NODEAPPLICATIONMANAGER_HAS_DLL) -# define NODEAPPLICATIONMANAGER_HAS_DLL 0 -#endif /* ACE_AS_STATIC_LIBS && NODEAPPLICATIONMANAGER_HAS_DLL */ - -#if !defined (NODEAPPLICATIONMANAGER_HAS_DLL) -# define NODEAPPLICATIONMANAGER_HAS_DLL 1 -#endif /* ! NODEAPPLICATIONMANAGER_HAS_DLL */ - -#if defined (NODEAPPLICATIONMANAGER_HAS_DLL) && (NODEAPPLICATIONMANAGER_HAS_DLL == 1) -# if defined (NODEAPPLICATIONMANAGER_BUILD_DLL) -# define NodeApplicationManager_Export ACE_Proper_Export_Flag -# define NODEAPPLICATIONMANAGER_SINGLETON_DECLARATION(T) ACE_EXPORT_SINGLETON_DECLARATION (T) -# define NODEAPPLICATIONMANAGER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_EXPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) -# else /* NODEAPPLICATIONMANAGER_BUILD_DLL */ -# define NodeApplicationManager_Export ACE_Proper_Import_Flag -# define NODEAPPLICATIONMANAGER_SINGLETON_DECLARATION(T) ACE_IMPORT_SINGLETON_DECLARATION (T) -# define NODEAPPLICATIONMANAGER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) ACE_IMPORT_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) -# endif /* NODEAPPLICATIONMANAGER_BUILD_DLL */ -#else /* NODEAPPLICATIONMANAGER_HAS_DLL == 1 */ -# define NodeApplicationManager_Export -# define NODEAPPLICATIONMANAGER_SINGLETON_DECLARATION(T) -# define NODEAPPLICATIONMANAGER_SINGLETON_DECLARE(SINGLETON_TYPE, CLASS, LOCK) -#endif /* NODEAPPLICATIONMANAGER_HAS_DLL == 1 */ - -// Set NODEAPPLICATIONMANAGER_NTRACE = 0 to turn on library specific tracing even if -// tracing is turned off for ACE. -#if !defined (NODEAPPLICATIONMANAGER_NTRACE) -# if (ACE_NTRACE == 1) -# define NODEAPPLICATIONMANAGER_NTRACE 1 -# else /* (ACE_NTRACE == 1) */ -# define NODEAPPLICATIONMANAGER_NTRACE 0 -# endif /* (ACE_NTRACE == 1) */ -#endif /* !NODEAPPLICATIONMANAGER_NTRACE */ - -#if (NODEAPPLICATIONMANAGER_NTRACE == 1) -# define NODEAPPLICATIONMANAGER_TRACE(X) -#else /* (NODEAPPLICATIONMANAGER_NTRACE == 1) */ -# if !defined (ACE_HAS_TRACE) -# define ACE_HAS_TRACE -# endif /* ACE_HAS_TRACE */ -# define NODEAPPLICATIONMANAGER_TRACE(X) ACE_TRACE_IMPL(X) -# include "ace/Trace.h" -#endif /* (NODEAPPLICATIONMANAGER_NTRACE == 1) */ - -#endif /* NODEAPPLICATIONMANAGER_EXPORT_H */ - -// End of auto generated file. diff --git a/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp b/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp deleted file mode 100644 index 40be1bca281..00000000000 --- a/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.cpp +++ /dev/null @@ -1,207 +0,0 @@ -// $Id$ - -#include "ace/Log_Msg.h" -#include "ace/streams.h" -#include "DAnCE/Deployment/DAnCE_PropertiesC.h" -#include "DAnCE/Logger/Log_Macros.h" - -#include "NodeApplicationManager_Impl.h" -#include "NodeApplication/NodeApplication_Impl.h" -#include "NodeManager/NodeManager_Impl.h" - -using namespace DAnCE; - -NodeApplicationManager_Impl::NodeApplicationManager_Impl (CORBA::ORB_ptr orb, - PortableServer::POA_ptr poa, - const Deployment::DeploymentPlan& plan, -// RedirectionService & redirection, - const ACE_CString& node_name, - const PROPERTY_MAP &properties) - : plan_ (plan), - orb_ (CORBA::ORB::_duplicate (orb)), - poa_ (PortableServer::POA::_duplicate (poa)), - application_ (0), - //redirection_ (redirection), - node_name_ (node_name), - properties_ () -{ - DANCE_TRACE ("NodeApplicationManager_Impl::NodeApplicationManager_Impl"); - - DANCE_DEBUG((LM_DEBUG, DLINFO ACE_TEXT(" NodeApplicationManager_Impl::NodeApplicationManager_Impl - ") - ACE_TEXT("Initializing for node '%C' and plan '%C' starting...\n"), - node_name.c_str(), - plan_.UUID.in())); - this->register_plan(); - - PROPERTY_MAP::const_iterator i = properties.begin (); - while (!i.done ()) - { - DANCE_DEBUG ((LM_DEBUG, DLINFO ACE_TEXT("NodeApplicationManager_Impl::NodeApplicationManager_Impl - ") - ACE_TEXT("Binding value for property %C\n"), i->key ().c_str ())); - this->properties_.bind (i->key (), i->item ()); - i.advance (); - } -} - -NodeApplicationManager_Impl::~NodeApplicationManager_Impl() -{ - DANCE_TRACE ("NodeApplicationManager_Impl::~NodeApplicationManager_Impl"); - - try - { - if (this->application_ != 0) - { - CORBA::Object_var app = - this->poa_->servant_to_reference (this->application_); - PortableServer::ObjectId_var id = this->poa_->reference_to_id (app); - this->poa_->deactivate_object (id); - - delete this->application_; - this->application_ = 0; - } - } - catch (...) - { - DANCE_ERROR ((LM_WARNING, DLINFO - ACE_TEXT("NodeApplicationManager_Impl::~NodeApplicationManager_Impl - ") - ACE_TEXT("Caught exception in NodeApplicationManager destructor\n"))); - } -} - -Deployment::Application_ptr -NodeApplicationManager_Impl::startLaunch (const Deployment::Properties &, - Deployment::Connections_out providedReference) -{ - DANCE_TRACE ("NodeApplicationManager_Impl::startLaunch"); - - // Creating NodeApplication object - DANCE_DEBUG((LM_TRACE, DLINFO ACE_TEXT("NodeApplicationManager_impl::startLaunch - ") - ACE_TEXT("Initializing NodeApplication\n"))); - ACE_NEW_THROW_EX (this->application_, - NodeApplication_Impl (this->orb_.in(), - this->poa_.in(), - this->plan_, -// this->redirection_, - this->node_name_, - this->properties_), - CORBA::NO_MEMORY ()); - - DANCE_DEBUG((LM_TRACE, DLINFO ACE_TEXT("NodeApplicationManager_impl::startLaunch - ") - ACE_TEXT("Instructing NodeApplication to initialize components.\n"))); - this->application_->init_components(); - - DANCE_DEBUG((LM_TRACE, DLINFO ACE_TEXT("NodeApplicationManager_impl::startLaunch - ") - ACE_TEXT("Collecting connection references\n"))); - providedReference = this->application_->getAllConnections(); - //this->parent_.registerConnections(this->plan_.UUID.in(), *providedReference); - - DANCE_DEBUG((LM_DEBUG, DLINFO ACE_TEXT("NodeApplicationManager_impl::startLaunch - ") - ACE_TEXT("Activating NodeApplication servant\n"))); - PortableServer::ObjectId_var as_id = - this->poa_->activate_object (this->application_); - - CORBA::Object_var as_obj = this->poa_->id_to_reference (as_id.in ()); - Deployment::Application_var app = Deployment::Application::_narrow (as_obj.in ()); - - return app._retn (); -} - -void -NodeApplicationManager_Impl::destroyApplication (Deployment::Application_ptr application) -{ - DANCE_TRACE ("NodeApplicationManager_Impl::destroyApplication"); - - try - { - if (!application->_is_equivalent (this->poa_->servant_to_reference (this->application_))) - { - DANCE_ERROR((LM_ERROR, DLINFO ACE_TEXT("NodeApplicationManager_Impl::destroyApplication - ") - ACE_TEXT("application is equivalent to current application\n"))); - throw ::Deployment::StopError(); - } -// this->redirection_.unregister (this->node_name_, this->plan_.UUID.in()); - - CORBA::Any val; - - if (this->properties_.find (DAnCE::STANDALONE_NM, val) == 0) - { - DANCE_DEBUG ((LM_TRACE, DLINFO ACE_TEXT("NodeApplicationManager_Impl::destroyApplication - ") - ACE_TEXT("Found STANDALONE_NM property\n"))); - - CORBA::Boolean standalone (false); - - val >>= CORBA::Any::to_boolean (standalone); - - this->application_->passivate_components (); - this->application_->remove_components (); - } - - - PortableServer::ObjectId_var id = this->poa_->reference_to_id (application); - this->poa_->deactivate_object (id); - - delete this->application_; - this->application_ = 0; - } - catch (const CORBA::SystemException &) - { - throw; - } - catch (const Deployment::StopError &) - { - throw; - } - catch (const CORBA::UserException &e) - { - DANCE_ERROR((LM_ERROR, DLINFO ACE_TEXT("NodeApplicationManager_Impl::destroyApplication failed with UserException %C(%C) \"%C\"\n"), - e._name(), e._rep_id(), e._info().c_str())); - throw Deployment::StopError(e._name(), e._info().c_str()); - } - catch (...) - { - DANCE_ERROR((LM_ERROR, DLINFO ACE_TEXT("NodeApplicationManager_Impl::destroyApplication failed with unknown exception.\n"))); - throw Deployment::StopError(); - } -} - -void -NodeApplicationManager_Impl::register_plan(void) -{ - DANCE_TRACE("NodeApplicationManager_Impl::register_plan()"); - -// this->redirection_.registration_start (this->node_name_, this->plan_.UUID.in()); - DANCE_DEBUG((LM_TRACE, DLINFO - ACE_TEXT("NodeApplicationManager_Impl::register_plan - registering objects...\n"))); - for (CORBA::ULong i = 0; i < this->plan_.instance.length(); i++) - { -// this->redirection_.registration (this->node_name_, - // this->plan_.UUID.in(), - // this->plan_.instance[i].name.in(), - // CORBA::Object::_nil()); - } - - DANCE_DEBUG((LM_TRACE, DLINFO ACE_TEXT("NodeApplicationManager_Impl::register_plan - registering endpoints...\n"))); - for (CORBA::ULong i = 0; i < this->plan_.connection.length(); i++) - { - for (CORBA::ULong j = 0; j < this->plan_.connection[i].internalEndpoint.length(); j++) - { - if (this->plan_.connection[i].internalEndpoint[j].provider) - { - DANCE_DEBUG ((LM_TRACE, DLINFO ACE_TEXT("NodeApplicationManager_Impl::register_plan - "), - ACE_TEXT("Registering Port '%s' on instance '%s' on node '%s'\n"), - this->plan_.connection[i].internalEndpoint[j].portName.in(), - this->plan_.instance[this->plan_.connection[i].internalEndpoint[j].instanceRef].name.in(), - this->node_name_.c_str ())); -// this->redirection_.registration (this->node_name_, - // this->plan_.UUID.in(), - // this->plan_.instance[this->plan_.connection[i].internalEndpoint[j].instanceRef].name.in(), - // this->plan_.connection[i].internalEndpoint[j].portName.in(), - // CORBA::Object::_nil()); - } - } - } - DANCE_DEBUG ((LM_TRACE, DLINFO - ACE_TEXT("NodeApplicationManager_Impl::register_plan - ") - ACE_TEXT("Finishing registration\n"))); - //this->redirection_.registration_finish (this->node_name_, this->plan_.UUID.in()); -} diff --git a/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.h b/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.h deleted file mode 100644 index 22add49ee62..00000000000 --- a/modules/CIAO/DAnCE/NodeApplicationManager/NodeApplicationManager_Impl.h +++ /dev/null @@ -1,60 +0,0 @@ -// -*- C++ -*- - -//============================================================================= -/** - * @file NodeApplicationManager_Impl.h - * - * $Id$ - * - * @Brief Implementation of POA_Deployment::NodeApplicationManager - * - * @author Erwin Gottlieb <eg@prismtech.com> - */ -//============================================================================= - -#ifndef NODEAPPLICATIONMANAGER_IMPL_H_ -#define NODEAPPLICATIONMANAGER_IMPL_H_ - -#include "NodeApplicationManager_Export.h" -#include "Deployment/Deployment_DeploymentPlanC.h" -#include "Deployment/Deployment_NodeApplicationManagerS.h" -#include "Deployment/Deployment_NodeApplicationC.h" -#include "NodeApplication/NodeApplication_Impl.h" -//#include "RedirectionService/RedirectionService.h" - -namespace DAnCE - { - - class NodeManager_Impl; - - class NodeApplicationManager_Export NodeApplicationManager_Impl : - public virtual POA_Deployment::NodeApplicationManager - { - public: - NodeApplicationManager_Impl (CORBA::ORB_ptr orb, - PortableServer::POA_ptr poa, - const Deployment::DeploymentPlan& plan, -// RedirectionService & redirection, - const ACE_CString& name, - const PROPERTY_MAP &properties); - - virtual ~NodeApplicationManager_Impl(); - - virtual Deployment::Application_ptr - startLaunch (const Deployment::Properties & configProperty, - Deployment::Connections_out providedReference); - - virtual void destroyApplication (Deployment::Application_ptr); - private: - void register_plan(); - - Deployment::DeploymentPlan plan_; - CORBA::ORB_var orb_; - PortableServer::POA_var poa_; - NodeApplication_Impl* application_; -// RedirectionService & redirection_; - ACE_CString node_name_; - PROPERTY_MAP properties_; - }; -} -#endif /*NODEAPPLICATIONMANAGER_IMPL_H_*/ |