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:

Collaboration diagram for TAO_CEC_Reactive_Pulling_Strategy:

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

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_EventChannel *	event_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_Reactor *	reactor_
	The ORB reactor.

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::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

activate()

void TAO_CEC_Reactive_Pulling_Strategy::activate ( )

virtual

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

Implements TAO_CEC_Pulling_Strategy.

handle_timeout()

void TAO_CEC_Reactive_Pulling_Strategy::handle_timeout	(	const ACE_Time_Value &	tv,
		const void *	arg )

Receive the timeout from the adapter.

shutdown()

void TAO_CEC_Reactive_Pulling_Strategy::shutdown ( )

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

adapter_

TAO_CEC_Pulling_Strategy_Adapter TAO_CEC_Reactive_Pulling_Strategy::adapter_

private

The Adapter for the reactor events.

event_channel_

TAO_CEC_EventChannel* TAO_CEC_Reactive_Pulling_Strategy::event_channel_

private

The event channel.

orb_

CORBA::ORB_var TAO_CEC_Reactive_Pulling_Strategy::orb_

private

The ORB.

policy_current_

CORBA::PolicyCurrent_var TAO_CEC_Reactive_Pulling_Strategy::policy_current_

private

To control the timeout policy in the thread.

policy_list_

CORBA::PolicyList TAO_CEC_Reactive_Pulling_Strategy::policy_list_

private

Precomputed policy list to the set timeout.

rate_

ACE_Time_Value TAO_CEC_Reactive_Pulling_Strategy::rate_

private

The polling rate.

reactor_

ACE_Reactor* TAO_CEC_Reactive_Pulling_Strategy::reactor_

private

The ORB reactor.

relative_timeout_

ACE_Time_Value TAO_CEC_Reactive_Pulling_Strategy::relative_timeout_

private

The relative timeout.

---

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

• CEC_Reactive_Pulling_Strategy.h
• CEC_Reactive_Pulling_Strategy.cpp