summaryrefslogtreecommitdiff
path: root/ace/Message_Queue.h
diff options
context:
space:
mode:
Diffstat (limited to 'ace/Message_Queue.h')
-rw-r--r--ace/Message_Queue.h15
1 files changed, 15 insertions, 0 deletions
diff --git a/ace/Message_Queue.h b/ace/Message_Queue.h
index b9363d2690b..a96db9fa72a 100644
--- a/ace/Message_Queue.h
+++ b/ace/Message_Queue.h
@@ -208,6 +208,21 @@ protected:
int activate_i (void);
// Activate the queue.
+ // = Helper methods to factor out common #ifdef code.
+ int wait_not_full_cond (ACE_Guard<ACE_SYNCH_MUTEX_T> &mon,
+ ACE_Time_Value *tv);
+ // Wait for the queue to become non-full.
+
+ int wait_not_empty_cond (ACE_Guard<ACE_SYNCH_MUTEX_T> &mon,
+ ACE_Time_Value *tv);
+ // Wait for the queue to become non-empty.
+
+ int signal_enqueue_waiters (void);
+ // Inform any threads waiting to enqueue that they can procede.
+
+ int signal_dequeue_waiters (void);
+ // Inform any threads waiting to dequeue that they can procede.
+
ACE_Message_Block *head_;
// Pointer to head of ACE_Message_Block list.