TAO_RTEvent  2.4.0
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
[legend]
Collaboration diagram for TAO_EC_Queue:
Collaboration graph
[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 >
virtual int close (void)
 
virtual ~ACE_Message_Queue (void)
 
virtual int flush (void)
 
virtual int flush_i (void)
 
virtual ACE_SYNCH_MUTEX_T & lock (void)
 
ACE_Time_Value_T< ACE_System_Time_Policy > gettimeofday (void) const
 
void set_time_policy (ACE_System_Time_Policyconst &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_Strategy * notification_strategy (void)
 
virtual void notification_strategy (ACE_Notification_Strategy *s)
 
 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_Strategy * notification_strategy (void)
 
virtual void notification_strategy (ACE_Notification_Strategy *s)
 
- Public Member Functions inherited from ACE_Message_Queue_Base
 ACE_Message_Queue_Base (void)
 
virtual ~ACE_Message_Queue_Base (void)
 

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, ACE_System_Time_Policy > ITERATOR
 
typedef ACE_Message_Queue_Reverse_Iterator< ACE_SYNCH_USE, ACE_System_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< ACE_System_Time_Policy > cond_attr_
 
ACE_SYNCH_CONDITION_T not_empty_cond_
 
ACE_SYNCH_CONDITION_T not_full_cond_
 
ACE_System_Time_Policy time_policy_
 
- Protected Attributes inherited from ACE_Message_Queue_Base
int state_
 

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:
Generated by   doxygen 1.8.9.1