Builder for RT specific classes. More...
#include <RT_Builder.h>


Public Member Functions | |
| TAO_Notify_RT_Builder (void) | |
| Constructor. | |
| 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. | |
Builder for RT specific classes.
Definition at line 31 of file RT_Builder.h.
| TAO_Notify_RT_Builder::TAO_Notify_RT_Builder | ( | void | ) |
| TAO_Notify_RT_Builder::~TAO_Notify_RT_Builder | ( | ) | [virtual] |
| void TAO_Notify_RT_Builder::apply_lane_concurrency | ( | TAO_Notify_Object & | object, | |
| const NotifyExt::ThreadPoolLanesParams & | tpl_params | |||
| ) | [virtual] |
Apply Thread Pools with Lanes.
Reimplemented from TAO_Notify_Builder.
Definition at line 49 of file RT_Builder.cpp.
{
TAO_Notify_RT_POA_Helper* proxy_poa = 0;
// Bootstrap EC Proxy POA
ACE_NEW_THROW_EX (proxy_poa,
TAO_Notify_RT_POA_Helper (),
CORBA::NO_MEMORY ());
ACE_Auto_Ptr<TAO_Notify_POA_Helper> auto_proxy_poa (proxy_poa);
PortableServer::POA_var default_poa = TAO_Notify_PROPERTIES::instance ()->default_poa ();
proxy_poa->init (default_poa.in (), tpl_params);
// Give ownership of proxy_poa
object.set_proxy_poa (auto_proxy_poa.release ());
}
| void TAO_Notify_RT_Builder::apply_thread_pool_concurrency | ( | TAO_Notify_Object & | object, | |
| const NotifyExt::ThreadPoolParams & | tp_params | |||
| ) | [virtual] |
Apply Thread Pools.
Reimplemented from TAO_Notify_Builder.
Definition at line 28 of file RT_Builder.cpp.
{
TAO_Notify_RT_POA_Helper* proxy_poa = 0;
// Bootstrap EC Proxy POA
ACE_NEW_THROW_EX (proxy_poa,
TAO_Notify_RT_POA_Helper (),
CORBA::NO_MEMORY ());
ACE_Auto_Ptr<TAO_Notify_POA_Helper> auto_proxy_poa (proxy_poa);
PortableServer::POA_var default_poa = TAO_Notify_PROPERTIES::instance ()->default_poa ();
proxy_poa->init (default_poa.in (), tp_params);
// Give ownership of proxy_poa
object.set_proxy_poa (auto_proxy_poa.release ());
}
1.7.0