TAO_RTEvent
2.2.0
|
#include <EC_Dispatching_Task.h>
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< 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_Strategy * | notification_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_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_ |
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 |
||
) |
|
protectedvirtual |
Reimplemented from ACE_Message_Queue< ACE_SYNCH >.