#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 }
|
1.3.6