TAO_CosEvent  2.2.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | List of all members
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
Collaboration diagram for TAO_CEC_Reactive_Dispatching:
Collaboration graph

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>. More...
virtual void push_nocopy (TAO_CEC_ProxyPushSupplier *proxy, CORBA::Any &event)
- Public Member Functions inherited from TAO_CEC_Dispatching
virtual ~TAO_CEC_Dispatching (void)
 destructor... 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_Dispatching::TAO_CEC_Reactive_Dispatching ( void  )

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

Member Function Documentation

void TAO_CEC_Reactive_Dispatching::activate ( void  )

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

Implements TAO_CEC_Dispatching.

void TAO_CEC_Reactive_Dispatching::push ( TAO_CEC_ProxyPushSupplier proxy,
const CORBA::Any &  event 

The consumer represented by <proxy> should receive <event>.

Implements TAO_CEC_Dispatching.

void TAO_CEC_Reactive_Dispatching::push_nocopy ( TAO_CEC_ProxyPushSupplier proxy,
CORBA::Any &  event 

Implements TAO_CEC_Dispatching.

void TAO_CEC_Reactive_Dispatching::shutdown ( void  )

Deactivate any internal threads and cleanup internal data structures, it should only return once the threads have finished their jobs.

Implements TAO_CEC_Dispatching.

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