Implement the dispatching queues for FIFO and Priority dispatching. More...

#include <EC_Dispatching_Task.h>

Inheritance diagram for TAO_EC_Dispatching_Task:

Collaboration diagram for TAO_EC_Dispatching_Task:

Public Member Functions
	TAO_EC_Dispatching_Task (ACE_Thread_Manager thr_manager=0, TAO_EC_Queue_Full_Service_Object queue_full_service_object=0)
	Constructor. More...

virtual int	svc (void)
	Process the events in the queue. More...

virtual void	push (TAO_EC_ProxyPushSupplier *proxy, RtecEventComm::PushConsumer_ptr consumer, RtecEventComm::EventSet &event)

Public Member Functions inherited from ACE_Task< ACE_SYNCH >
	ACE_Task (ACE_Thread_Manager thr_mgr=0, ACE_Message_Queue< ACE_SYNCH_USE, TIME_POLICY > mq=0)

virtual	~ACE_Task (void)

ACE_Message_Queue < ACE_SYNCH_USE, TIME_POLICY > *	msg_queue (void)

void	msg_queue (ACE_Message_Queue< ACE_SYNCH_USE, TIME_POLICY > *)

ACE_Time_Value_T< TIME_POLICY >	gettimeofday (void) const

void	set_time_policy (TIME_POLICY const &time_policy)

int	putq (ACE_Message_Block , ACE_Time_Value timeout=0)

int	getq (ACE_Message_Block &mb, ACE_Time_Value timeout=0)

int	ungetq (ACE_Message_Block , ACE_Time_Value timeout=0)

int	reply (ACE_Message_Block mb, ACE_Time_Value tv=0)

int	put_next (ACE_Message_Block msg, ACE_Time_Value timeout=0)

const ACE_TCHAR *	name (void) const

ACE_Task< ACE_SYNCH_USE, TIME_POLICY > *	next (void)

void	next (ACE_Task< ACE_SYNCH_USE, TIME_POLICY > *)

ACE_Task< ACE_SYNCH_USE, TIME_POLICY > *	sibling (void)

ACE_Module< ACE_SYNCH_USE, TIME_POLICY > *	module (void) const

int	flush (u_long flag=ACE_Task_Flags::ACE_FLUSHALL)

void	water_marks (ACE_IO_Cntl_Msg::ACE_IO_Cntl_Cmds, size_t)

void	dump (void) const

Private Attributes
ACE_Allocator *	allocator_
	An per-task allocator. More...

ACE_Locked_Data_Block < ACE_Lock_Adapter < TAO_SYNCH_MUTEX > >	data_block_
	Helper data structure to minimize memory allocations... More...

TAO_EC_Queue	the_queue_
	The queue. More...

TAO_EC_Queue_Full_Service_Object *	queue_full_service_object_

Additional Inherited Members
Public Attributes inherited from ACE_Task< ACE_SYNCH >
ACE_Message_Queue < ACE_SYNCH_USE, TIME_POLICY > *	msg_queue_

bool	delete_msg_queue_

ACE_Module< ACE_SYNCH_USE, TIME_POLICY > *	mod_

ACE_Task< ACE_SYNCH_USE, TIME_POLICY > *	next_

	ACE_ALLOC_HOOK_DECLARE

Detailed Description

Implement the dispatching queues for FIFO and Priority dispatching.

Constructor & Destructor Documentation

TAO_EC_Dispatching_Task::TAO_EC_Dispatching_Task	(	ACE_Thread_Manager *	thr_manager = `0`,
		TAO_EC_Queue_Full_Service_Object *	queue_full_service_object = `0`
	)

Constructor.

void TAO_EC_Dispatching_Task::push	(	TAO_EC_ProxyPushSupplier *	proxy,
		RtecEventComm::PushConsumer_ptr	consumer,
		RtecEventComm::EventSet &	event
	)

virtual

int TAO_EC_Dispatching_Task::svc ( void )

virtual

Process the events in the queue.

ACE_Allocator* TAO_EC_Dispatching_Task::allocator_

private

An per-task allocator.

private

Helper data structure to minimize memory allocations...

TAO_EC_Queue_Full_Service_Object* TAO_EC_Dispatching_Task::queue_full_service_object_

private

TAO_EC_Queue TAO_EC_Dispatching_Task::the_queue_

private

The queue.

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