TAO_RTEvent
2.1.0
|
Dispatch using the caller thread. More...
#include <EC_Reactive_Dispatching.h>
Public Member Functions | |
TAO_EC_Reactive_Dispatching (void) | |
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) |
Dispatch using the caller thread.
The events are dispatched in FIFO ordering, using the invoking thread to push the event to the consumer.
The scheduler is used to find the range of priorities and similar info.
void TAO_EC_Reactive_Dispatching::activate | ( | void | ) | [virtual] |
Initialize all the data structures, activate any internal threads, etc.
Implements TAO_EC_Dispatching.
void TAO_EC_Reactive_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_Reactive_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_Reactive_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.