TAO_CEC_Reactive_Dispatching Class Reference

Dispatch using the caller thread. More...

#include <CEC_Dispatching.h>

Inheritance diagram for TAO_CEC_Reactive_Dispatching:

Inheritance graph
[legend]
Collaboration diagram for TAO_CEC_Reactive_Dispatching:

Collaboration graph
[legend]
List of all members.

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)

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 85 of file CEC_Dispatching.h.


Constructor & Destructor Documentation

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.

00017 {
00018 }


Member Function Documentation

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.

00022 {
00023 }

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.

00027 {
00028 }


The documentation for this class was generated from the following files:
Generated on Tue Feb 2 17:45:01 2010 for TAO_CosEvent by  doxygen 1.4.7