#include <EC_Dispatching_Task.h>

Inheritance diagram for TAO_EC_Queue:

[legend]

Collaboration diagram for TAO_EC_Queue:

[legend]

Public Member Functions
	TAO_EC_Queue (size_t high_water_mark=ACE_Message_Queue_Base::DEFAULT_HWM, size_t low_water_mark=ACE_Message_Queue_Base::DEFAULT_LWM, ACE_Notification_Strategy *=0)

Public Member Functions inherited from ACE_Message_Queue< ACE_SYNCH >
	ACE_Message_Queue (size_t hwm=ACE_Message_Queue_Base::DEFAULT_HWM, size_t lwm=ACE_Message_Queue_Base::DEFAULT_LWM, ACE_Notification_Strategy *ns=0)

	ACE_Message_Queue (size_t hwm=ACE_Message_Queue_Base::DEFAULT_HWM, size_t lwm=ACE_Message_Queue_Base::DEFAULT_LWM, ACE_Notification_Strategy *ns=0)

virtual int	open (size_t hwm=ACE_Message_Queue_Base::DEFAULT_HWM, size_t lwm=ACE_Message_Queue_Base::DEFAULT_LWM, ACE_Notification_Strategy *ns=0)

virtual int	open (size_t hwm=ACE_Message_Queue_Base::DEFAULT_HWM, size_t lwm=ACE_Message_Queue_Base::DEFAULT_LWM, ACE_Notification_Strategy *ns=0)

virtual int	close ()

virtual int	close ()

virtual	~ACE_Message_Queue ()

virtual	~ACE_Message_Queue ()

virtual int	flush ()

virtual int	flush ()

virtual int	flush_i ()

virtual int	flush_i ()

virtual int	peek_dequeue_head (ACE_Message_Block &first_item, ACE_Time_Value timeout=0)

virtual int	peek_dequeue_head (ACE_Message_Block &first_item, ACE_Time_Value timeout=0)

virtual int	enqueue_prio (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue_prio (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue_deadline (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue_deadline (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue_tail (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue_tail (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue_head (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	enqueue_head (ACE_Message_Block new_item, ACE_Time_Value timeout=0)

virtual int	dequeue (ACE_Message_Block &first_item, ACE_Time_Value timeout=0)

virtual int	dequeue (ACE_Message_Block &first_item, ACE_Time_Value timeout=0)

virtual int	dequeue_head (ACE_Message_Block &first_item, ACE_Time_Value timeout=0)

virtual int	dequeue_head (ACE_Message_Block &first_item, ACE_Time_Value timeout=0)

virtual int	dequeue_prio (ACE_Message_Block &first_item, ACE_Time_Value timeout=0)

virtual int	dequeue_prio (ACE_Message_Block &first_item, ACE_Time_Value timeout=0)

virtual int	dequeue_tail (ACE_Message_Block &dequeued, ACE_Time_Value timeout=0)

virtual int	dequeue_tail (ACE_Message_Block &dequeued, ACE_Time_Value timeout=0)

virtual int	dequeue_deadline (ACE_Message_Block &dequeued, ACE_Time_Value timeout=0)

virtual int	dequeue_deadline (ACE_Message_Block &dequeued, ACE_Time_Value timeout=0)

virtual bool	is_full ()

virtual bool	is_full ()

virtual bool	is_empty ()

virtual bool	is_empty ()

virtual size_t	message_bytes ()

virtual void	message_bytes (size_t new_size)

virtual size_t	message_bytes ()

virtual void	message_bytes (size_t new_size)

virtual size_t	message_length ()

virtual void	message_length (size_t new_length)

virtual size_t	message_length ()

virtual void	message_length (size_t new_length)

virtual size_t	message_count ()

virtual size_t	message_count ()

virtual size_t	high_water_mark ()

virtual void	high_water_mark (size_t hwm)

virtual size_t	high_water_mark ()

virtual void	high_water_mark (size_t hwm)

virtual size_t	low_water_mark ()

virtual void	low_water_mark (size_t lwm)

virtual size_t	low_water_mark ()

virtual void	low_water_mark (size_t lwm)

virtual int	deactivate ()

virtual int	deactivate ()

virtual int	activate ()

virtual int	activate ()

virtual int	pulse ()

virtual int	pulse ()

virtual int	state ()

virtual int	state ()

virtual int	deactivated ()

virtual int	deactivated ()

virtual int	notify ()

virtual ACE_Notification_Strategy *	notification_strategy ()

virtual void	notification_strategy (ACE_Notification_Strategy *s)

virtual ACE_SYNCH_MUTEX_T &	lock ()

ACE_Time_Value_T< TIME_POLICY >	gettimeofday () const

void	set_time_policy (TIME_POLICY const &time_policy)

virtual void	dump () const

Public Member Functions inherited from ACE_Message_Queue_Base
	ACE_Message_Queue_Base ()

virtual	~ACE_Message_Queue_Base ()

Protected Member Functions
virtual bool	is_full_i ()

Protected Member Functions inherited from ACE_Message_Queue< ACE_SYNCH >
virtual int	enqueue_i (ACE_Message_Block *new_item)

virtual int	enqueue_deadline_i (ACE_Message_Block *new_item)

virtual int	enqueue_tail_i (ACE_Message_Block *new_item)

virtual int	enqueue_head_i (ACE_Message_Block *new_item)

virtual int	dequeue_head_i (ACE_Message_Block *&first_item)

virtual int	dequeue_prio_i (ACE_Message_Block *&dequeued)

virtual int	dequeue_tail_i (ACE_Message_Block *&first_item)

virtual int	dequeue_deadline_i (ACE_Message_Block *&first_item)

virtual bool	is_empty_i ()

virtual int	deactivate_i (int pulse=0)

virtual int	activate_i ()

virtual int	wait_not_full_cond (ACE_Time_Value *timeout)

virtual int	wait_not_empty_cond (ACE_Time_Value *timeout)

virtual int	signal_enqueue_waiters ()

virtual int	signal_dequeue_waiters ()

Additional Inherited Members
Public Types inherited from ACE_Message_Queue< ACE_SYNCH >
typedef ACE_Message_Queue_Iterator< ACE_SYNCH_USE, TIME_POLICY >	ITERATOR

typedef ACE_Message_Queue_Reverse_Iterator< ACE_SYNCH_USE, TIME_POLICY >	REVERSE_ITERATOR

Public Attributes inherited from ACE_Message_Queue< ACE_SYNCH >
	ACE_ALLOC_HOOK_DECLARE

Public Attributes inherited from ACE_Message_Queue_Base
	DEFAULT_HWM

	DEFAULT_LWM

	ACTIVATED

	DEACTIVATED

	PULSED

Protected Attributes inherited from ACE_Message_Queue< ACE_SYNCH >
ACE_Message_Block *	head_

ACE_Message_Block *	tail_

size_t	low_water_mark_

size_t	high_water_mark_

size_t	cur_bytes_

size_t	cur_length_

size_t	cur_count_

ACE_Notification_Strategy *	notification_strategy_

ACE_SYNCH_MUTEX_T	lock_

ACE_Condition_Attributes_T< TIME_POLICY >	cond_attr_

ACE_SYNCH_CONDITION_T	not_empty_cond_

ACE_SYNCH_CONDITION_T	not_full_cond_

TIME_POLICY	time_policy_

Protected Attributes inherited from ACE_Message_Queue_Base
int	state_

Constructor & Destructor Documentation

◆ TAO_EC_Queue()

TAO_EC_Queue::TAO_EC_Queue	(	size_t	high_water_mark = ACE_Message_Queue_Base::DEFAULT_HWM,
		size_t	low_water_mark = ACE_Message_Queue_Base::DEFAULT_LWM,
		ACE_Notification_Strategy *	ns = 0 )

Member Function Documentation

◆ is_full_i()

virtual bool TAO_EC_Queue::is_full_i ( )

protectedvirtual

Reimplemented from ACE_Message_Queue< ACE_SYNCH >.

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

Public Member Functions

Protected Member Functions

Additional Inherited Members

Constructor & Destructor Documentation

◆ TAO_EC_Queue()

Member Function Documentation

◆ is_full_i()