Dispatch using the caller thread. More...
#include <CEC_Dispatching.h>
Public Member Functions | |
TAO_CEC_Reactive_Dispatching (void) | |
virtual void | activate (void) |
virtual void | shutdown (void) |
virtual void | push (TAO_CEC_ProxyPushSupplier *proxy, const CORBA::Any &event) |
The consumer represented by <proxy> should receive <event>. | |
virtual void | push_nocopy (TAO_CEC_ProxyPushSupplier *proxy, CORBA::Any &event) |
Dispatch using the caller thread.
The events are dispatched in FIFO ordering, using the invoking thread to push the event to the consumer.
TAO_CEC_Reactive_Dispatching::TAO_CEC_Reactive_Dispatching | ( | void | ) |
The scheduler is used to find the range of priorities and similar info.
void TAO_CEC_Reactive_Dispatching::activate | ( | void | ) | [virtual] |
Initialize all the data structures, activate any internal threads, etc.
Implements TAO_CEC_Dispatching.
void TAO_CEC_Reactive_Dispatching::push | ( | TAO_CEC_ProxyPushSupplier * | proxy, | |
const CORBA::Any & | event | |||
) | [virtual] |
The consumer represented by <proxy> should receive <event>.
Implements TAO_CEC_Dispatching.
void TAO_CEC_Reactive_Dispatching::push_nocopy | ( | TAO_CEC_ProxyPushSupplier * | proxy, | |
CORBA::Any & | event | |||
) | [virtual] |
Implements TAO_CEC_Dispatching.
void TAO_CEC_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_CEC_Dispatching.