#include <CEC_Dispatching.h>
Inheritance diagram for TAO_CEC_Reactive_Dispatching:
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 ACE_ENV_ARG_DECL_WITH_DEFAULTS) |
The consumer represented by <proxy> should receive <event>. | |
virtual void | push_nocopy (TAO_CEC_ProxyPushSupplier *proxy, CORBA::Any &event ACE_ENV_ARG_DECL_WITH_DEFAULTS) |
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 | ACE_ENV_ARG_DECL_WITH_DEFAULTS | |||
) | [virtual] |
void TAO_CEC_Reactive_Dispatching::push_nocopy | ( | TAO_CEC_ProxyPushSupplier * | proxy, | |
CORBA::Any &event | ACE_ENV_ARG_DECL_WITH_DEFAULTS | |||
) | [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.