Main Page | Namespace List | Class Hierarchy | Alphabetical List | Class List | File List | Namespace Members | Class Members | File Members | Related Pages | Search for 

TAO_EC_Reactive_Dispatching Class Reference

Dispatch using the caller thread. More...

#include <EC_Reactive_Dispatching.h>

Inheritance diagram for TAO_EC_Reactive_Dispatching:

Inheritance graph
[legend]
Collaboration diagram for TAO_EC_Reactive_Dispatching:

Collaboration graph
[legend]
List of all members.

Public Member Functions

 TAO_EC_Reactive_Dispatching (void)
virtual void activate (void)
virtual void shutdown (void)
virtual void push (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, const RtecEventComm::EventSet &event, TAO_EC_QOS_Info &qos_info)
virtual void push_nocopy (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, RtecEventComm::EventSet &event, TAO_EC_QOS_Info &qos_info)

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.

Definition at line 39 of file EC_Reactive_Dispatching.h.

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_EC_Reactive_Dispatching::TAO_EC_Reactive_Dispatching (  void   ) 
 

The scheduler is used to find the range of priorities and similar info.

Definition at line 10 of file EC_Reactive_Dispatching.cpp. 

00011   : TAO_EC_Dispatching ()
00012 {
00013 }

Member Function Documentation

void TAO_EC_Reactive_Dispatching::activate (  void   )  [virtual]
 

Initialize all the data structures, activate any internal threads, etc.

Implements TAO_EC_Dispatching.

Definition at line 16 of file EC_Reactive_Dispatching.cpp. 

00017 {
00018 }

void TAO_EC_Reactive_Dispatching::push (  TAO_EC_ProxyPushSupplier *  proxy,
RtecEventComm::PushConsumer_ptr  consumer,
const RtecEventComm::EventSet &  event,
TAO_EC_QOS_Info &  qos_info
)  [virtual]
 

The consumer represented by proxy should receive event. It can use the information in qos_info to determine the event priority (among other things).

Implements TAO_EC_Dispatching.

Definition at line 26 of file EC_Reactive_Dispatching.cpp.

References RtecEventComm::EventSet, and TAO_EC_ProxyPushSupplier::reactive_push_to_consumer(). 

00030 {
00031   proxy->reactive_push_to_consumer (consumer, event);
00032 }

void TAO_EC_Reactive_Dispatching::push_nocopy (  TAO_EC_ProxyPushSupplier *  proxy,
RtecEventComm::PushConsumer_ptr  consumer,
RtecEventComm::EventSet &  event,
TAO_EC_QOS_Info &  qos_info
)  [virtual]
 

Implements TAO_EC_Dispatching.

Definition at line 35 of file EC_Reactive_Dispatching.cpp.

References RtecEventComm::EventSet, and TAO_EC_ProxyPushSupplier::reactive_push_to_consumer(). 

00039 {
00040   proxy->reactive_push_to_consumer (consumer, event);
00041 }

void TAO_EC_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_EC_Dispatching.

Definition at line 21 of file EC_Reactive_Dispatching.cpp. 

00022 {
00023 }

The documentation for this class was generated from the following files:
Generated on Sun Jan 27 13:42:52 2008 for TAO_RTEvent by doxygen 1.3.6