TAO/tao/Dynamic_TP/DTP_Thread_Lane_Resources_Manager.cpp

   1 #include "tao/Dynamic_TP/DTP_Thread_Lane_Resources_Manager.h"
   2
   3 #if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
   4
   5 #include "tao/ORB_Core.h"
   6 #include "tao/ORB_Core_TSS_Resources.h"
   7 #include "tao/Acceptor_Registry.h"
   8 #include "tao/Thread_Lane_Resources.h"
   9 #include "tao/Dynamic_TP/DTP_Thread_Pool.h"
  10 #include "tao/LF_Follower.h"
  11 #include "tao/Leader_Follower.h"
  12
  13 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  14
  15 TAO_DTP_Thread_Lane_Resources_Manager::TAO_DTP_Thread_Lane_Resources_Manager
  16   (TAO_ORB_Core &orb_core)
  17     : TAO_Thread_Lane_Resources_Manager (orb_core),
  18       default_lane_resources_ (0),
  19       tp_manager_ (0)
  20 {
  21   // Create the default resources.
  22   ACE_NEW (this->default_lane_resources_,
  23            TAO_Thread_Lane_Resources (orb_core));
  24
  25   // Create the thread-pool manager.
  26   ACE_NEW (this->tp_manager_,
  27            TAO_DTP_Thread_Pool_Manager (orb_core));
  28 }
  29
  30 TAO_DTP_Thread_Lane_Resources_Manager::~TAO_DTP_Thread_Lane_Resources_Manager ()
  31 {
  32   // Delete the default resources.
  33   delete this->default_lane_resources_;
  34
  35   // Delete the thread-pool manager.
  36   delete this->tp_manager_;
  37 }
  38
  39 int
  40 TAO_DTP_Thread_Lane_Resources_Manager::open_default_resources ()
  41 {
  42   TAO_ORB_Parameters *params =
  43     this->orb_core_->orb_params ();
  44
  45   TAO_EndpointSet endpoint_set;
  46
  47   params->get_endpoint_set (TAO_DEFAULT_LANE, endpoint_set);
  48
  49   bool ignore_address = false;
  50
  51   int const result =
  52     this->default_lane_resources_->open_acceptor_registry (endpoint_set,
  53                                                            ignore_address);
  54
  55   return result;
  56 }
  57
  58 void
  59 TAO_DTP_Thread_Lane_Resources_Manager::finalize ()
  60 {
  61   // Finalize default resources.
  62   this->default_lane_resources_->finalize ();
  63 }
  64
  65 void
  66 TAO_DTP_Thread_Lane_Resources_Manager::shutdown_reactor ()
  67 {
  68   // Shutdown default reactors.
  69   this->default_lane_resources_->shutdown_reactor ();
  70   // This is the only reactor in use with this thread pool
  71 }
  72
  73 void
  74 TAO_DTP_Thread_Lane_Resources_Manager::close_all_transports ()
  75 {
  76   // Shutdown default reactors.
  77   this->default_lane_resources_->close_all_transports ();
  78 }
  79
  80 int
  81 TAO_DTP_Thread_Lane_Resources_Manager::is_collocated (const TAO_MProfile &mprofile)
  82 {
  83   return this->default_lane_resources_->is_collocated (mprofile);
  84 }
  85
  86 TAO_Thread_Lane_Resources &
  87 TAO_DTP_Thread_Lane_Resources_Manager::lane_resources ()
  88 {
  89     return *this->default_lane_resources_;
  90 }
  91
  92 TAO_Thread_Lane_Resources &
  93 TAO_DTP_Thread_Lane_Resources_Manager::default_lane_resources ()
  94 {
  95   return *this->default_lane_resources_;
  96 }
  97
  98 TAO_DTP_Thread_Pool_Manager &
  99 TAO_DTP_Thread_Lane_Resources_Manager::tp_manager ()
 100 {
 101   return *this->tp_manager_;
 102 }
 103
 104 TAO_Thread_Lane_Resources_Manager *
 105 TAO_DTP_Thread_Lane_Resources_Manager_Factory::create_thread_lane_resources_manager (
 106   TAO_ORB_Core &core)
 107 {
 108   TAO_Thread_Lane_Resources_Manager *manager = 0;
 109
 110   /// Create the RT Thread Lane Resources Manager.
 111   ACE_NEW_RETURN (manager,
 112                   TAO_DTP_Thread_Lane_Resources_Manager (core),
 113                   0);
 114
 115   return manager;
 116 }
 117
 118 ACE_STATIC_SVC_DEFINE (TAO_DTP_Thread_Lane_Resources_Manager_Factory,
 119                        ACE_TEXT ("DTP_Thread_Lane_Resources_Manager_Factory"),
 120                        ACE_SVC_OBJ_T,
 121                        &ACE_SVC_NAME (TAO_DTP_Thread_Lane_Resources_Manager_Factory),
 122                        ACE_Service_Type::DELETE_THIS | ACE_Service_Type::DELETE_OBJ,
 123                        0)
 124 ACE_FACTORY_DEFINE (TAO_Dynamic_TP, TAO_DTP_Thread_Lane_Resources_Manager_Factory)
 125
 126 TAO_END_VERSIONED_NAMESPACE_DECL
 127
 128 #endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */