diff options
Diffstat (limited to 'DAnCE/dance/LocalityManager/Scheduler/Plugin_Manager.cpp')
| -rw-r--r-- | DAnCE/dance/LocalityManager/Scheduler/Plugin_Manager.cpp | 378 |
1 files changed, 0 insertions, 378 deletions
diff --git a/DAnCE/dance/LocalityManager/Scheduler/Plugin_Manager.cpp b/DAnCE/dance/LocalityManager/Scheduler/Plugin_Manager.cpp deleted file mode 100644 index c62212271bf..00000000000 --- a/DAnCE/dance/LocalityManager/Scheduler/Plugin_Manager.cpp +++ /dev/null @@ -1,378 +0,0 @@ -#include "Plugin_Manager.h" -#include "dance/Logger/Log_Macros.h" -#include "dance/Deployment/Deployment_PlanErrorC.h" -#include "dance/DAnCE_LocalityManagerC.h" -#include "dance/DAnCE_DeploymentInterceptorsC.h" - -namespace DAnCE -{ - namespace - { - template <typename PLUGIN> - typename PLUGIN::_ptr_type - load_plugin (const ACE_TCHAR *artifact, - const ACE_TCHAR *entrypoint, - int open_mode) - { - if (!artifact || !entrypoint) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::load_plugin - ") - ACE_TEXT ("Must provide non-nil artifact and entrypoint names\n"))); - throw ::Deployment::PlanError ("", - "Invalid parameters for plug-in installation"); - } - - DANCE_DEBUG (DANCE_LOG_MINOR_EVENT, - (LM_DEBUG, DLINFO - ACE_TEXT ("Plugin_Manager::load_plugin - ") - ACE_TEXT ("Loading plugin from <%s>:<%s>\n"), - artifact, - entrypoint)); - - ACE_DLL plugin_dll; - - if (plugin_dll.open (artifact, - open_mode, - false) != 0) - { - const ACE_TCHAR *error = plugin_dll.error (); - - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::load_plugin - ") - ACE_TEXT ("Error while loading artifact <%s> with mode <%d>: %s\n"), - artifact, - open_mode, - error)); - - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - ACE_TEXT_ALWAYS_CHAR (error)); - } - - DANCE_DEBUG (DANCE_LOG_EVENT_TRACE, - (LM_TRACE, DLINFO - ACE_TEXT ("Plugin_Manager::load_plugin - ") - ACE_TEXT ("Loading artifact <%s> successfully loaded.\n"), - artifact)); - - void *void_ptr = plugin_dll.symbol (entrypoint); - ptrdiff_t tmp_ptr = reinterpret_cast <ptrdiff_t> (void_ptr); - - typedef typename PLUGIN::_ptr_type (*PluginFactory) (void); - PluginFactory pcreator = reinterpret_cast<PluginFactory> (tmp_ptr); - - if (!pcreator) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::load_plugin - ") - ACE_TEXT ("Unable to load plugin <%s>:<%s>\n"), - artifact, - entrypoint)); - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - "Invalid entrypoint"); - } - - typename PLUGIN::_var_type plugin = pcreator (); - - if (CORBA::is_nil (plugin)) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::load_plugin - ") - ACE_TEXT ("Unable to load plugin <%s>:<%s>, nil result from factory\n"), - artifact, - entrypoint)); - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - "Nil result from factory"); - } - - DANCE_DEBUG (DANCE_LOG_MINOR_EVENT, - (LM_TRACE, DLINFO - ACE_TEXT ("Plugin_Manager::load_plugin - ") - ACE_TEXT ("Successfully created plugin from <%s> with mode <%d>:<%s>.\n"), - artifact, - open_mode, - entrypoint)); - - return plugin._retn (); - } - } - - Plugin_Manager::Plugin_Manager (void) : - config_ (0) - { - DANCE_DEBUG (DANCE_LOG_MINOR_EVENT, - (LM_INFO, DLINFO - ACE_TEXT ("Plugin_Manager::Plugin_Manager") - ACE_TEXT ("\n"))); - } - - void - Plugin_Manager::set_orb (CORBA::ORB_ptr orb) - { - this->orb_ = CORBA::ORB::_duplicate (orb); - } - - CORBA::ORB_ptr - Plugin_Manager::get_orb (void) - { - return CORBA::ORB::_duplicate (this->orb_); - } - - template<typename T> - struct Closer - { - void operator() (T& item) - { - item.second->close (); - } - }; - - Plugin_Manager::~Plugin_Manager (void) - { - try - { - std::for_each (handler_map_.begin (), - handler_map_.end (), - Closer<HANDLER_MAP::value_type> ()); - - for (INTERCEPTORS::iterator i = this->interceptors_.begin (); - i != this->interceptors_.end (); - ++i) - *i = ::DAnCE::DeploymentInterceptor::_nil (); - } - catch (...) - { - DANCE_ERROR (DANCE_LOG_NONFATAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::~Plugin_Manager - ") - ACE_TEXT ("Caught unknown C++ exception while closing plugin manager\n"))); - } - } - - void - Plugin_Manager::set_configuration (const Deployment::Properties &config) - { - this->config_ = &config; - } - - char * - Plugin_Manager::register_installation_handler (const ACE_TCHAR *artifact, - const ACE_TCHAR *entrypoint, - const Plugin_Manager::IH_DEPS &depends, - int open_mode) - { - ::DAnCE::InstanceDeploymentHandler_var plugin = - load_plugin< ::DAnCE::InstanceDeploymentHandler > (artifact, - entrypoint, - open_mode); - - try - { - plugin->configure (*this->config_); - - CORBA::String_var instance_type = plugin->instance_type (); - - DANCE_DEBUG (DANCE_LOG_MINOR_EVENT, - (LM_INFO, DLINFO - ACE_TEXT ("Plugin_Manager::register_installation_handler - ") - ACE_TEXT ("Successfully created installation handler for instance type <%C>\n"), - instance_type.in ())); - - this->ih_dep_.add_dependency (instance_type.in (), depends); - - ::CORBA::StringSeq_var deps = plugin->dependencies (); - - if (!CORBA::is_nil (deps)) - { - for (CORBA::ULong i = 0; i < deps->length (); ++i) - { - this->ih_dep_.add_dependency (instance_type.in (), - deps[i].in ()); - } - } - - this->handler_map_[instance_type.in ()] = plugin._retn (); - - return instance_type._retn (); - } - catch (const CORBA::Exception &ex) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::register_installation_handler - ") - ACE_TEXT ("CORBA Exception caught while loading artifact <%s>:<%s> - %C\n"), - artifact, - entrypoint, - ex._info ().c_str ())); - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - ex._info ().c_str ()); - } - catch (...) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::register_installation_handler - ") - ACE_TEXT ("Unknown C++ exception while configuring plugin from <%s>:<%s>\n"), - artifact, - entrypoint)); - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - "Unknown C++ exception during handler configuration\n"); - } - } - - void - Plugin_Manager::get_installation_order (Plugin_Manager::INSTALL_ORDER &io) - { - this->ih_dep_.calculate_order (io); - } - - void - Plugin_Manager::register_interceptor (const ACE_TCHAR *artifact, - const ACE_TCHAR *entrypoint, - int open_mode) - { - ::DAnCE::DeploymentInterceptor_var plugin = - load_plugin< ::DAnCE::DeploymentInterceptor > (artifact, - entrypoint, - open_mode); - try - { - plugin->configure (*this->config_); - - DANCE_DEBUG (DANCE_LOG_MINOR_EVENT, - (LM_INFO, DLINFO - ACE_TEXT ("Plugin_Manager::register_interceptor - ") - ACE_TEXT ("Successfully created deployment interceptor\n"))); - - this->interceptors_.push_back (plugin._retn ()); - } - catch (const CORBA::Exception &ex) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::register_interceptor - ") - ACE_TEXT ("CORBA Exception caught while loading artifact <%s>:<%s> - %C\n"), - artifact, - entrypoint, - ex._info ().c_str ())); - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - ex._info ().c_str ()); - } - catch (...) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::register_interceptor - ") - ACE_TEXT ("Unknown C++ exception while configuring plugin from <%s>:<%s>\n"), - artifact, - entrypoint)); - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - "Unknown C++ exception during handler configuration\n"); - } - } - - ::DAnCE::InstanceDeploymentHandler_ptr - Plugin_Manager::fetch_installation_handler (const char *instance_type) - { - if (instance_type == 0) - { - return 0; - } - HANDLER_MAP::iterator i; - - if ((i = this->handler_map_.find (instance_type)) == - this->handler_map_.end ()) - { - DANCE_ERROR (DANCE_LOG_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::fetch_installation_handler - ") - ACE_TEXT ("No installation handler for type %C found\n"), - instance_type)); - - return 0; - } - - return ::DAnCE::InstanceDeploymentHandler::_duplicate (i->second); - } - - const - Plugin_Manager::INTERCEPTORS & - Plugin_Manager::fetch_interceptors (void) - { - return this->interceptors_; - } - - void - Plugin_Manager::register_configuration_plugin (const ACE_TCHAR *artifact, - const ACE_TCHAR *entrypoint, - int open_mode) - { - DAnCE::LocalityConfiguration_var plugin = - load_plugin< DAnCE::LocalityConfiguration > (artifact, - entrypoint, - open_mode); - - try - { - CORBA::String_var id = plugin->type (); - - this->config_plugins_[id.in ()] = plugin._retn (); - } - catch (const CORBA::Exception &ex) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::register_configuration_plugin - ") - ACE_TEXT ("CORBA Exception caught while loading artifact <%s>:<%s> - %C\n"), - artifact, - entrypoint, - ex._info ().c_str ())); - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - ex._info ().c_str ()); - } - catch (...) - { - DANCE_ERROR (DANCE_LOG_TERMINAL_ERROR, - (LM_ERROR, DLINFO - ACE_TEXT ("Plugin_Manager::register_configuration_plugin - ") - ACE_TEXT ("Unknown C++ exception while configuring plugin from <%s>:<%s>\n"), - artifact, - entrypoint)); - throw ::Deployment::PlanError (ACE_TEXT_ALWAYS_CHAR (artifact), - "Unknown C++ exception during plugin configuration\n"); - } - } - - ::DAnCE::LocalityConfiguration_ptr - Plugin_Manager::get_configuration_handler (const char *id) - { - if (id == 0) - { - return 0; - } - - CONFIG_MAP::iterator i; - - if ((i = this->config_plugins_.find (id)) == - this->config_plugins_.end ()) - { - DANCE_ERROR (DANCE_LOG_MAJOR_DEBUG_INFO, - (LM_TRACE, DLINFO - ACE_TEXT ("Plugin_Manager::get_configuration_handler - ") - ACE_TEXT ("No configuration plugin for type %C found\n"), - id)); - - return 0; - } - - return ::DAnCE::LocalityConfiguration::_duplicate (i->second); - } - -} - -ACE_SINGLETON_TEMPLATE_INSTANTIATE(ACE_Singleton, DAnCE::Plugin_Manager, TAO_SYNCH_MUTEX); - |