TAO_CEC_Reactive_Pulling_Strategy Class Reference

Dispatch using the caller thread. More...

#include <CEC_Reactive_Pulling_Strategy.h>

Inheritance diagram for TAO_CEC_Reactive_Pulling_Strategy:

Inheritance graph
[legend]
Collaboration diagram for TAO_CEC_Reactive_Pulling_Strategy:

Collaboration graph
[legend]
List of all members.

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_EventChannelevent_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_Reactorreactor_
 The ORB reactor.
int timer_id_
 The timer id.

Detailed Description

Dispatch using the caller thread.

The events are dispatched in FIFO ordering, using the invoking thread to push the event to the consumer.


Constructor & Destructor Documentation

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.


Member Function Documentation

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.


Member Data Documentation

TAO_CEC_Pulling_Strategy_Adapter TAO_CEC_Reactive_Pulling_Strategy::adapter_ [private]
 

The Adapter for the reactor events.

TAO_CEC_EventChannel* TAO_CEC_Reactive_Pulling_Strategy::event_channel_ [private]
 

The event channel.

CORBA::ORB_var TAO_CEC_Reactive_Pulling_Strategy::orb_ [private]
 

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.

ACE_Time_Value TAO_CEC_Reactive_Pulling_Strategy::rate_ [private]
 

The polling rate.

ACE_Reactor* TAO_CEC_Reactive_Pulling_Strategy::reactor_ [private]
 

The ORB reactor.

ACE_Time_Value TAO_CEC_Reactive_Pulling_Strategy::relative_timeout_ [private]
 

The relative timeout.

int TAO_CEC_Reactive_Pulling_Strategy::timer_id_ [private]
 

The timer id.


The documentation for this class was generated from the following files:
Generated on Wed Nov 23 16:20:36 2005 for TAO_CosEvent by  doxygen 1.4.5