TAO_CosEvent  2.3.2
Public Member Functions | Private Attributes | List of all members
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]

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. More...
 
virtual void activate (void)
 
virtual void shutdown (void)
 
- Public Member Functions inherited from TAO_CEC_Pulling_Strategy
virtual ~TAO_CEC_Pulling_Strategy (void)
 destructor... More...
 

Private Attributes

TAO_CEC_Pulling_Strategy_Adapter adapter_
 The Adapter for the reactor events. More...
 
ACE_Time_Value rate_
 The polling rate. More...
 
ACE_Time_Value relative_timeout_
 The relative timeout. More...
 
TAO_CEC_EventChannelevent_channel_
 The event channel. More...
 
CORBA::ORB_var orb_
 The ORB. More...
 
CORBA::PolicyCurrent_var policy_current_
 To control the timeout policy in the thread. More...
 
CORBA::PolicyList policy_list_
 Precomputed policy list to the set timeout. More...
 
ACE_Reactorreactor_
 The ORB reactor. More...
 
long timer_id_
 The timer id. More...
 

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.

long TAO_CEC_Reactive_Pulling_Strategy::timer_id_
private

The timer id.


The documentation for this class was generated from the following files: