diff options
Diffstat (limited to 'TAO/tao/RTCORBA/RT_Thread_Lane_Resources_Manager.cpp')
-rw-r--r-- | TAO/tao/RTCORBA/RT_Thread_Lane_Resources_Manager.cpp | 155 |
1 files changed, 0 insertions, 155 deletions
diff --git a/TAO/tao/RTCORBA/RT_Thread_Lane_Resources_Manager.cpp b/TAO/tao/RTCORBA/RT_Thread_Lane_Resources_Manager.cpp deleted file mode 100644 index 496092041c2..00000000000 --- a/TAO/tao/RTCORBA/RT_Thread_Lane_Resources_Manager.cpp +++ /dev/null @@ -1,155 +0,0 @@ -// $Id$ - -#include "tao/RTCORBA/RT_Thread_Lane_Resources_Manager.h" - -#if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0 - -ACE_RCSID (RTCORBA, - RT_Thread_Lane_Resources_Manager, - "$Id$") - -#include "tao/ORB_Core.h" -#include "tao/Acceptor_Registry.h" -#include "tao/Thread_Lane_Resources.h" -#include "tao/RTCORBA/Thread_Pool.h" -#include "tao/LF_Follower.h" -#include "tao/Leader_Follower.h" - -TAO_RT_Thread_Lane_Resources_Manager::TAO_RT_Thread_Lane_Resources_Manager (TAO_ORB_Core &orb_core) - : TAO_Thread_Lane_Resources_Manager (orb_core), - default_lane_resources_ (0), - tp_manager_ (0) -{ - // Create the default resources. - ACE_NEW (this->default_lane_resources_, - TAO_Thread_Lane_Resources (orb_core)); - - // Create the thread-pool manager. - ACE_NEW (this->tp_manager_, - TAO_Thread_Pool_Manager (orb_core)); - -} - -TAO_RT_Thread_Lane_Resources_Manager::~TAO_RT_Thread_Lane_Resources_Manager (void) -{ - // Delete the default resources. - delete this->default_lane_resources_; - - // Delete the thread-pool manager. - delete this->tp_manager_; -} - -int -TAO_RT_Thread_Lane_Resources_Manager::open_default_resources (ACE_ENV_SINGLE_ARG_DECL) -{ - TAO_ORB_Parameters *params = - this->orb_core_->orb_params (); - - TAO_EndpointSet endpoint_set; - - params->get_endpoint_set (TAO_DEFAULT_LANE, - endpoint_set); - - bool ignore_address = false; - - int result = - this->default_lane_resources_->open_acceptor_registry (endpoint_set, - ignore_address - ACE_ENV_ARG_PARAMETER); - ACE_CHECK_RETURN (-1); - - return result; -} - -void -TAO_RT_Thread_Lane_Resources_Manager::finalize (void) -{ - // Finalize default resources. - this->default_lane_resources_->finalize (); - - // Finalize resources managed by the thread-pool manager. - this->tp_manager_->finalize (); -} - -void -TAO_RT_Thread_Lane_Resources_Manager::shutdown_reactor (void) -{ - // Shutdown default reactors. - this->default_lane_resources_->shutdown_reactor (); - - // Shutdown reactors managed by the thread-pool manager. - this->tp_manager_->shutdown_reactor (); -} - -void -TAO_RT_Thread_Lane_Resources_Manager::cleanup_rw_transports (void) -{ - // Shutdown default reactors. - this->default_lane_resources_->cleanup_rw_transports (); -} - -int -TAO_RT_Thread_Lane_Resources_Manager::is_collocated (const TAO_MProfile &mprofile) -{ - int result = - this->default_lane_resources_->is_collocated (mprofile); - - if (result) - return result; - - return this->tp_manager_->is_collocated (mprofile); -} - -TAO_Thread_Lane_Resources & -TAO_RT_Thread_Lane_Resources_Manager::lane_resources (void) -{ - // Get the ORB_Core's TSS resources. - TAO_ORB_Core_TSS_Resources &tss = - *this->orb_core_->get_tss_resources (); - - // Get the lane for this thread. - TAO_Thread_Lane *lane = - (TAO_Thread_Lane *) tss.lane_; - - // If we have a valid lane, use that lane's resources. - if (lane) - return lane->resources (); - else - // Otherwise, return the default resources. - return *this->default_lane_resources_; -} - -TAO_Thread_Lane_Resources & -TAO_RT_Thread_Lane_Resources_Manager::default_lane_resources (void) -{ - return *this->default_lane_resources_; -} - -TAO_Thread_Pool_Manager & -TAO_RT_Thread_Lane_Resources_Manager::tp_manager (void) -{ - return *this->tp_manager_; -} - -TAO_Thread_Lane_Resources_Manager * -TAO_RT_Thread_Lane_Resources_Manager_Factory::create_thread_lane_resources_manager (TAO_ORB_Core &core) -{ - TAO_Thread_Lane_Resources_Manager *manager = 0; - - /// Create the RT Thread Lane Resources Manager. - ACE_NEW_RETURN (manager, - TAO_RT_Thread_Lane_Resources_Manager (core), - 0); - - return manager; -} - -ACE_STATIC_SVC_DEFINE (TAO_RT_Thread_Lane_Resources_Manager_Factory, - ACE_TEXT ("RT_Thread_Lane_Resources_Manager_Factory"), - ACE_SVC_OBJ_T, - &ACE_SVC_NAME (TAO_RT_Thread_Lane_Resources_Manager_Factory), - ACE_Service_Type::DELETE_THIS | ACE_Service_Type::DELETE_OBJ, - 0) -ACE_FACTORY_DEFINE (TAO_RTCORBA, TAO_RT_Thread_Lane_Resources_Manager_Factory) - -#endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */ |