TAO_RTEvent  2.2.7
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Protected Member Functions | List of all members
TAO_EC_Queue Class Reference

#include <EC_Dispatching_Task.h>

Inheritance diagram for TAO_EC_Queue:
Inheritance graph
Collaboration diagram for TAO_EC_Queue:
Collaboration graph

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 >
virtual int close (void)
 
virtual ~ACE_Message_Queue (void)
 
virtual int flush (void)
 
virtual int flush_i (void)
 
virtual ACE_SYNCH_MUTEX_Tlock (void)
 
ACE_Time_Value_T< TIME_POLICY > gettimeofday (void) const
 
void set_time_policy (TIME_POLICY const &time_policy)
 
virtual void dump (void) const
 
 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 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_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_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 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_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_deadline (ACE_Message_Block *&dequeued, ACE_Time_Value *timeout=0)
 
virtual bool is_full (void)
 
virtual bool is_empty (void)
 
virtual size_t message_bytes (void)
 
virtual void message_bytes (size_t new_size)
 
virtual size_t message_length (void)
 
virtual void message_length (size_t new_length)
 
virtual size_t message_count (void)
 
virtual size_t high_water_mark (void)
 
virtual void high_water_mark (size_t hwm)
 
virtual size_t low_water_mark (void)
 
virtual void low_water_mark (size_t lwm)
 
virtual int deactivate (void)
 
virtual int activate (void)
 
virtual int pulse (void)
 
virtual int state (void)
 
virtual int deactivated (void)
 
virtual int notify (void)
 
virtual ACE_Notification_Strategynotification_strategy (void)
 
virtual void notification_strategy (ACE_Notification_Strategy *s)
 

Protected Member Functions

virtual bool is_full_i (void)
 
- 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 (void)
 
virtual int deactivate_i (int pulse=0)
 
virtual int activate_i (void)
 
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 (void)
 
virtual int signal_dequeue_waiters (void)
 

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
 
- Protected Attributes inherited from ACE_Message_Queue< ACE_SYNCH >
ACE_Message_Blockhead_
 
ACE_Message_Blocktail_
 
size_t low_water_mark_
 
size_t high_water_mark_
 
size_t cur_bytes_
 
size_t cur_length_
 
size_t cur_count_
 
ACE_Notification_Strategynotification_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_
 

Constructor & Destructor Documentation

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

virtual bool TAO_EC_Queue::is_full_i ( void  )
protectedvirtual

Reimplemented from ACE_Message_Queue< ACE_SYNCH >.


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