TAO/tao/Dynamic_TP/DTP_ORBInitializer.cpp

   1 #include "tao/Dynamic_TP/DTP_ORBInitializer.h"
   2
   3 #if defined (TAO_HAS_CORBA_MESSAGING) && TAO_HAS_CORBA_MESSAGING != 0
   4
   5 #include "tao/Dynamic_TP/DTP_Config.h"
   6 #include "tao/Dynamic_TP/DTP_Thread_Lane_Resources_Manager.h"
   7 #include "tao/Dynamic_TP/DTP_Thread_Pool.h"
   8 #include "tao/Exception.h"
   9 #include "tao/ORB_Core.h"
  10 #include "tao/PI/ORBInitInfo.h"
  11 #include "tao/debug.h"
  12 #include "tao/Leader_Follower.h"
  13
  14 #include "ace/Service_Repository.h"
  15 #include "ace/Svc_Conf.h"
  16 #include "ace/Sched_Params.h"
  17
  18 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  19
  20 TAO_DTP_ORBInitializer::TAO_DTP_ORBInitializer (/*const ACE_CString &tplist*/)
  21 {
  22 }
  23
  24 void
  25 TAO_DTP_ORBInitializer::pre_init (PortableInterceptor::ORBInitInfo_ptr info)
  26 {
  27   TAO_ORBInitInfo_var tao_info = TAO_ORBInitInfo::_narrow (info);
  28
  29   if (CORBA::is_nil (tao_info.in ()))
  30     {
  31       if (TAO_debug_level > 0)
  32         TAOLIB_ERROR ((LM_ERROR,
  33                     ACE_TEXT ("(%P|%t) TAO_DTP_ORBInitializer::pre_init:\n")
  34                     ACE_TEXT ("(%P|%t)    Unable to narrow ")
  35                     ACE_TEXT ("\"PortableInterceptor::ORBInitInfo_ptr\" to\n")
  36                     ACE_TEXT ("(%P|%t)   \"TAO_ORBInitInfo *.\"\n")));
  37
  38       throw ::CORBA::INTERNAL ();
  39     }
  40
  41
  42   ACE_Service_Gestalt *gestalt = tao_info->orb_core ()->configuration();
  43
  44   ACE_Service_Object * const config_obj =
  45     ACE_Dynamic_Service<ACE_Service_Object>::instance (
  46       gestalt,
  47       "DTP_Config",
  48       true);
  49   if (config_obj == 0)
  50     {
  51       // no config manager object loaded
  52       return;
  53     }
  54
  55   TAO_DTP_Config *config_mgr = dynamic_cast<TAO_DTP_Config *>(config_obj);
  56   if (config_mgr == 0)
  57     {
  58       if (TAO_debug_level > 0)
  59         TAOLIB_ERROR ((LM_ERROR,
  60                     ACE_TEXT ("(%P|%t) TAO_DTP_ORBInitializer::pre_init:\n")
  61                     ACE_TEXT ("(%P|%t)   Unable to resolve DTP_Config ")
  62                     ACE_TEXT ("object\n")));
  63
  64       throw ::CORBA::INTERNAL ();
  65     }
  66
  67   // Set the name of the thread lane resources manager to be
  68   // DTP_Thread_Lane_Resources_Manager.
  69   tao_info->orb_core ()->orb_params ()
  70     ->thread_lane_resources_manager_factory_name (
  71         "DTP_Thread_Lane_Resources_Manager_Factory");
  72   ACE_Service_Config::process_directive (
  73     ace_svc_desc_TAO_DTP_Thread_Lane_Resources_Manager_Factory);
  74 }
  75
  76 void
  77 TAO_DTP_ORBInitializer::post_init (PortableInterceptor::ORBInitInfo_ptr info)
  78 {
  79   TAO_ORBInitInfo_var tao_info = TAO_ORBInitInfo::_narrow (info);
  80
  81   TAO_Thread_Lane_Resources_Manager &tlrm =
  82     tao_info->orb_core ()->thread_lane_resources_manager();
  83
  84   ACE_Service_Gestalt *gestalt = tao_info->orb_core ()->configuration();
  85
  86   const char *dtp_name =
  87     tao_info->orb_core ()->orb_params ()->dynamic_thread_pool_config_name ();
  88
  89   if (dtp_name != 0 && dtp_name[0] != 0)
  90     {
  91       if (TAO_debug_level > 0)
  92         {
  93           TAOLIB_DEBUG ((LM_DEBUG,
  94                       ACE_TEXT ("(%P|%t) TAO_DTP_ORBInitializer::post_init ")
  95                       ACE_TEXT ("using thread pool name %s\n"), dtp_name));
  96         }
  97
  98       TAO_DTP_Config_Registry *config_registry =
  99         dynamic_cast<TAO_DTP_Config_Registry *>
 100         (ACE_Dynamic_Service<ACE_Service_Object>::instance
 101          (gestalt, "DTP_Config_Registry", true));
 102
 103       TAO_DTP_Definition def;
 104
 105       if (config_registry == 0 || !config_registry->find(dtp_name, def))
 106         {
 107           if (TAO_debug_level > 0)
 108             TAOLIB_ERROR ((LM_ERROR,
 109                         ACE_TEXT ("(%P|%t) TAO_DTP_ORBInitializer::")
 110                         ACE_TEXT ("post_init:\n")
 111                         ACE_TEXT ("(%P|%t)   Unable to resolve ")
 112                         ACE_TEXT ("DTP_Config object\n")));
 113
 114           throw ::CORBA::INTERNAL ();
 115         }
 116
 117       TAO_DTP_Thread_Lane_Resources_Manager &dtp_tlrm =
 118         dynamic_cast<TAO_DTP_Thread_Lane_Resources_Manager &>(tlrm);
 119
 120       dtp_tlrm.tp_manager().create_threadpool (def);
 121
 122       tao_info->orb_core ()->leader_follower ().set_avoid_client_leader ();
 123     }
 124
 125
 126 }
 127
 128
 129 TAO_END_VERSIONED_NAMESPACE_DECL
 130
 131 #endif /* TAO_HAS_CORBA_MESSAGING && TAO_HAS_CORBA_MESSAGING != 0 */