#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) |
The consumer represented by <proxy> should receive <event>. | |
virtual void | push_nocopy (TAO_CEC_ProxyPushSupplier *proxy, CORBA::Any &event) |
The events are dispatched in FIFO ordering, using the invoking thread to push the event to the consumer.
Definition at line 85 of file CEC_Dispatching.h.
TAO_CEC_Reactive_Dispatching::TAO_CEC_Reactive_Dispatching | ( | void | ) |
The scheduler is used to find the range of priorities and similar info.
Definition at line 16 of file CEC_Dispatching.cpp.
void TAO_CEC_Reactive_Dispatching::activate | ( | void | ) | [virtual] |
Initialize all the data structures, activate any internal threads, etc.
Implements TAO_CEC_Dispatching.
Definition at line 21 of file CEC_Dispatching.cpp.
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.
Definition at line 31 of file CEC_Dispatching.cpp.
References TAO_CEC_ProxyPushSupplier::reactive_push_to_consumer().
00033 { 00034 proxy->reactive_push_to_consumer (event); 00035 }
void TAO_CEC_Reactive_Dispatching::push_nocopy | ( | TAO_CEC_ProxyPushSupplier * | proxy, | |
CORBA::Any & | event | |||
) | [virtual] |
Implements TAO_CEC_Dispatching.
Definition at line 38 of file CEC_Dispatching.cpp.
References TAO_CEC_ProxyPushSupplier::reactive_push_to_consumer().
00040 { 00041 proxy->reactive_push_to_consumer (event); 00042 }
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.
Definition at line 26 of file CEC_Dispatching.cpp.