#include <RT_Builder.h>
Inheritance diagram for TAO_Notify_RT_Builder:
Public Member Functions | |
TAO_Notify_RT_Builder (void) | |
Constuctor. | |
virtual | ~TAO_Notify_RT_Builder () |
Destructor. | |
virtual void | apply_thread_pool_concurrency (TAO_Notify_Object &object, const NotifyExt::ThreadPoolParams &tp_params) |
Apply Thread Pools. | |
virtual void | apply_lane_concurrency (TAO_Notify_Object &object, const NotifyExt::ThreadPoolLanesParams &tpl_params) |
Apply Thread Pools with Lanes. |
Definition at line 31 of file RT_Builder.h.
|
Constuctor.
Definition at line 19 of file RT_Builder.cpp.
00020 { 00021 } |
|
Destructor.
Definition at line 23 of file RT_Builder.cpp.
00024 { 00025 } |
|
Apply Thread Pools with Lanes.
Reimplemented from TAO_Notify_Builder. Definition at line 51 of file RT_Builder.cpp. References ACE_CHECK, ACE_ENV_ARG_PARAMETER, ACE_NEW_THROW_EX, TAO_Notify_RT_POA_Helper::init(), TAO_Singleton< TYPE, ACE_LOCK >::instance(), ACE_Auto_Basic_Ptr< X >::release(), and TAO_Notify_Object::set_proxy_poa().
00053 { 00054 TAO_Notify_RT_POA_Helper* proxy_poa = 0; 00055 00056 // Bootstrap EC Proxy POA 00057 ACE_NEW_THROW_EX (proxy_poa, 00058 TAO_Notify_RT_POA_Helper (), 00059 CORBA::NO_MEMORY ()); 00060 ACE_CHECK; 00061 00062 ACE_Auto_Ptr<TAO_Notify_POA_Helper> auto_proxy_poa (proxy_poa); 00063 00064 PortableServer::POA_var default_poa = TAO_Notify_PROPERTIES::instance ()->default_poa (); 00065 00066 proxy_poa->init (default_poa.in (), tpl_params ACE_ENV_ARG_PARAMETER); 00067 ACE_CHECK; 00068 00069 // Give ownership of proxy_poa 00070 object.set_proxy_poa (auto_proxy_poa.release ()); 00071 } |
|
Apply Thread Pools.
Reimplemented from TAO_Notify_Builder. Definition at line 28 of file RT_Builder.cpp. References ACE_CHECK, ACE_ENV_ARG_PARAMETER, ACE_NEW_THROW_EX, TAO_Notify_RT_POA_Helper::init(), TAO_Singleton< TYPE, ACE_LOCK >::instance(), ACE_Auto_Basic_Ptr< X >::release(), and TAO_Notify_Object::set_proxy_poa().
00030 { 00031 TAO_Notify_RT_POA_Helper* proxy_poa = 0; 00032 00033 // Bootstrap EC Proxy POA 00034 ACE_NEW_THROW_EX (proxy_poa, 00035 TAO_Notify_RT_POA_Helper (), 00036 CORBA::NO_MEMORY ()); 00037 ACE_CHECK; 00038 00039 ACE_Auto_Ptr<TAO_Notify_POA_Helper> auto_proxy_poa (proxy_poa); 00040 00041 PortableServer::POA_var default_poa = TAO_Notify_PROPERTIES::instance ()->default_poa (); 00042 00043 proxy_poa->init (default_poa.in (), tp_params ACE_ENV_ARG_PARAMETER); 00044 ACE_CHECK; 00045 00046 // Give ownership of proxy_poa 00047 object.set_proxy_poa (auto_proxy_poa.release ()); 00048 } |