TAO/tao/RTCORBA/RT_Thread_Lane_Resources_Manager.cpp

   1 #include "tao/RTCORBA/RT_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/RTCORBA/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_RT_Thread_Lane_Resources_Manager::TAO_RT_Thread_Lane_Resources_Manager (TAO_ORB_Core &orb_core)
  16   : TAO_Thread_Lane_Resources_Manager (orb_core),
  17     default_lane_resources_ (0),
  18     tp_manager_ (0)
  19 {
  20   // Create the default resources.
  21   ACE_NEW (this->default_lane_resources_,
  22            TAO_Thread_Lane_Resources (orb_core));
  23
  24   // Create the thread-pool manager.
  25   ACE_NEW (this->tp_manager_,
  26            TAO_Thread_Pool_Manager (orb_core));
  27 }
  28
  29 TAO_RT_Thread_Lane_Resources_Manager::~TAO_RT_Thread_Lane_Resources_Manager ()
  30 {
  31   // Delete the default resources.
  32   delete this->default_lane_resources_;
  33
  34   // Delete the thread-pool manager.
  35   delete this->tp_manager_;
  36 }
  37
  38 int
  39 TAO_RT_Thread_Lane_Resources_Manager::open_default_resources ()
  40 {
  41   TAO_ORB_Parameters *params =
  42     this->orb_core_->orb_params ();
  43
  44   TAO_EndpointSet endpoint_set;
  45
  46   params->get_endpoint_set (TAO_DEFAULT_LANE, endpoint_set);
  47
  48   bool ignore_address = false;
  49
  50   int const result =
  51     this->default_lane_resources_->open_acceptor_registry (endpoint_set,
  52                                                            ignore_address);
  53
  54   return result;
  55 }
  56
  57 void
  58 TAO_RT_Thread_Lane_Resources_Manager::finalize ()
  59 {
  60   // Finalize resources managed by the thread-pool manager.
  61   this->tp_manager_->finalize ();
  62
  63   // Finalize default resources.
  64   this->default_lane_resources_->finalize ();
  65 }
  66
  67 void
  68 TAO_RT_Thread_Lane_Resources_Manager::shutdown_reactor ()
  69 {
  70   // Shutdown default reactors.
  71   this->default_lane_resources_->shutdown_reactor ();
  72
  73   // Shutdown reactors managed by the thread-pool manager.
  74   this->tp_manager_->shutdown_reactor ();
  75 }
  76
  77 void
  78 TAO_RT_Thread_Lane_Resources_Manager::close_all_transports ()
  79 {
  80   // Shutdown default reactors.
  81   this->default_lane_resources_->close_all_transports ();
  82 }
  83
  84 int
  85 TAO_RT_Thread_Lane_Resources_Manager::is_collocated (const TAO_MProfile &mprofile)
  86 {
  87   int result =
  88     this->default_lane_resources_->is_collocated (mprofile);
  89
  90   if (result)
  91     return result;
  92
  93   return this->tp_manager_->is_collocated (mprofile);
  94 }
  95
  96 TAO_Thread_Lane_Resources &
  97 TAO_RT_Thread_Lane_Resources_Manager::lane_resources ()
  98 {
  99   // Get the ORB_Core's TSS resources.
 100   TAO_ORB_Core_TSS_Resources &tss =
 101     *this->orb_core_->get_tss_resources ();
 102
 103   // Get the lane for this thread.
 104   TAO_Thread_Lane *lane =
 105     static_cast <TAO_Thread_Lane *> (tss.lane_);
 106
 107   // If we have a valid lane, use that lane's resources.
 108   if (lane)
 109     return lane->resources ();
 110   else
 111     // Otherwise, return the default resources.
 112     return *this->default_lane_resources_;
 113 }
 114
 115 TAO_Thread_Lane_Resources &
 116 TAO_RT_Thread_Lane_Resources_Manager::default_lane_resources ()
 117 {
 118   return *this->default_lane_resources_;
 119 }
 120
 121 TAO_Thread_Pool_Manager &
 122 TAO_RT_Thread_Lane_Resources_Manager::tp_manager ()
 123 {
 124   return *this->tp_manager_;
 125 }
 126
 127 TAO_Thread_Lane_Resources_Manager *
 128 TAO_RT_Thread_Lane_Resources_Manager_Factory::create_thread_lane_resources_manager (TAO_ORB_Core &core)
 129 {
 130   TAO_Thread_Lane_Resources_Manager *manager = 0;
 131
 132   /// Create the RT Thread Lane Resources Manager.
 133   ACE_NEW_RETURN (manager,
 134                   TAO_RT_Thread_Lane_Resources_Manager (core),
 135                   0);
 136
 137   return manager;
 138 }
 139
 140 ACE_STATIC_SVC_DEFINE (TAO_RT_Thread_Lane_Resources_Manager_Factory,
 141                        ACE_TEXT ("RT_Thread_Lane_Resources_Manager_Factory"),
 142                        ACE_SVC_OBJ_T,
 143                        &ACE_SVC_NAME (TAO_RT_Thread_Lane_Resources_Manager_Factory),
 144                        ACE_Service_Type::DELETE_THIS | ACE_Service_Type::DELETE_OBJ,
 145                        0)
 146 ACE_FACTORY_DEFINE (TAO_RTCORBA, TAO_RT_Thread_Lane_Resources_Manager_Factory)
 147
 148 TAO_END_VERSIONED_NAMESPACE_DECL
 149
 150 #endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */