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 ()); }