TAO_CosEvent 2.0.5
|
Dispatch using the caller thread. More...
#include <CEC_Reactive_Pulling_Strategy.h>
Public Member Functions | |
TAO_CEC_Reactive_Pulling_Strategy (const ACE_Time_Value &rate, const ACE_Time_Value &relative_timeout, TAO_CEC_EventChannel *event_channel, CORBA::ORB_ptr orb) | |
void | handle_timeout (const ACE_Time_Value &tv, const void *arg) |
Receive the timeout from the adapter. | |
virtual void | activate (void) |
virtual void | shutdown (void) |
Private Attributes | |
TAO_CEC_Pulling_Strategy_Adapter | adapter_ |
The Adapter for the reactor events. | |
ACE_Time_Value | rate_ |
The polling rate. | |
ACE_Time_Value | relative_timeout_ |
The relative timeout. | |
TAO_CEC_EventChannel * | event_channel_ |
The event channel. | |
CORBA::ORB_var | orb_ |
The ORB. | |
CORBA::PolicyCurrent_var | policy_current_ |
To control the timeout policy in the thread. | |
CORBA::PolicyList | policy_list_ |
Precomputed policy list to the set timeout. | |
ACE_Reactor * | reactor_ |
The ORB reactor. |
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_Pulling_Strategy::TAO_CEC_Reactive_Pulling_Strategy | ( | const ACE_Time_Value & | rate, |
const ACE_Time_Value & | relative_timeout, | ||
TAO_CEC_EventChannel * | event_channel, | ||
CORBA::ORB_ptr | orb | ||
) |
The scheduler is used to find the range of priorities and similar info.
void TAO_CEC_Reactive_Pulling_Strategy::activate | ( | void | ) | [virtual] |
Initialize all the data structures, activate any internal threads, etc.
Implements TAO_CEC_Pulling_Strategy.
void TAO_CEC_Reactive_Pulling_Strategy::handle_timeout | ( | const ACE_Time_Value & | tv, |
const void * | arg | ||
) |
Receive the timeout from the adapter.
void TAO_CEC_Reactive_Pulling_Strategy::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_Pulling_Strategy.
The Adapter for the reactor events.
The event channel.
The ORB.
CORBA::PolicyCurrent_var TAO_CEC_Reactive_Pulling_Strategy::policy_current_ [private] |
To control the timeout policy in the thread.
CORBA::PolicyList TAO_CEC_Reactive_Pulling_Strategy::policy_list_ [private] |
Precomputed policy list to the set timeout.
The polling rate.
The ORB reactor.
The relative timeout.