TAO_RTEvent
2.0.8
|
RTCORBA-based dispatching strategy. More...
#include <EC_RTCORBA_Dispatching.h>
Public Member Functions | |
TAO_EC_RTCORBA_Dispatching (const RTCORBA::ThreadpoolLanes &lanes, RTCORBA::PriorityMapping *mapping, RTCORBA::Current_ptr current) | |
Constructor. | |
~TAO_EC_RTCORBA_Dispatching (void) | |
Destructor. | |
virtual void | activate (void) |
virtual void | shutdown (void) |
virtual void | push (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, const RtecEventComm::EventSet &event, TAO_EC_QOS_Info &qos_info) |
virtual void | push_nocopy (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, RtecEventComm::EventSet &event, TAO_EC_QOS_Info &qos_info) |
Private Attributes | |
RTCORBA::ThreadpoolLanes | lanes_ |
The thread pools... | |
RTCORBA::PriorityMapping * | priority_mapping_ |
Used to map between CORBA and native priorities. | |
RTCORBA::Current_var | current_ |
Used to get the current RTCORBA priority. | |
ACE_Thread_Manager | thread_manager_ |
Use our own thread manager. | |
TAO_EC_Dispatching_Task * | tasks_ |
The dispatching task(s), one per lane. |
RTCORBA-based dispatching strategy.
TAO_EC_RTCORBA_Dispatching::TAO_EC_RTCORBA_Dispatching | ( | const RTCORBA::ThreadpoolLanes & | lanes, |
RTCORBA::PriorityMapping * | mapping, | ||
RTCORBA::Current_ptr | current | ||
) |
Constructor.
TAO_EC_RTCORBA_Dispatching::~TAO_EC_RTCORBA_Dispatching | ( | void | ) |
Destructor.
void TAO_EC_RTCORBA_Dispatching::activate | ( | void | ) | [virtual] |
Initialize all the data structures, activate any internal threads, etc.
Implements TAO_EC_Dispatching.
void TAO_EC_RTCORBA_Dispatching::push | ( | TAO_EC_ProxyPushSupplier * | proxy, |
RtecEventComm::PushConsumer_ptr | consumer, | ||
const RtecEventComm::EventSet & | event, | ||
TAO_EC_QOS_Info & | qos_info | ||
) | [virtual] |
The consumer represented by proxy should receive event. It can use the information in qos_info to determine the event priority (among other things).
Implements TAO_EC_Dispatching.
void TAO_EC_RTCORBA_Dispatching::push_nocopy | ( | TAO_EC_ProxyPushSupplier * | proxy, |
RtecEventComm::PushConsumer_ptr | consumer, | ||
RtecEventComm::EventSet & | event, | ||
TAO_EC_QOS_Info & | qos_info | ||
) | [virtual] |
Implements TAO_EC_Dispatching.
void TAO_EC_RTCORBA_Dispatching::shutdown | ( | void | ) | [virtual] |
Deactivate any internal threads and cleanup internal data structures, it should only return once the threads have finished their jobs.
Implements TAO_EC_Dispatching.
Used to get the current RTCORBA priority.
RTCORBA::ThreadpoolLanes TAO_EC_RTCORBA_Dispatching::lanes_ [private] |
The thread pools...
RTCORBA::PriorityMapping* TAO_EC_RTCORBA_Dispatching::priority_mapping_ [private] |
Used to map between CORBA and native priorities.
The dispatching task(s), one per lane.
Use our own thread manager.