summaryrefslogtreecommitdiff
path: root/ace/Message_Queue.h
diff options
context:
space:
mode:
authorschmidt <douglascraigschmidt@users.noreply.github.com>2000-06-06 16:42:53 +0000
committerschmidt <douglascraigschmidt@users.noreply.github.com>2000-06-06 16:42:53 +0000
commit4be1f1449b31f66230f43ea737ee41eb73e223b7 (patch)
tree24fab48e776b78d4b211d7fdc0104aeb62d7de7d /ace/Message_Queue.h
parent5c6ef0331abc1665dc2239a874fb9b74b2ad4125 (diff)
downloadATCD-4be1f1449b31f66230f43ea737ee41eb73e223b7.tar.gz
ChangeLogTag:Tue Jun 6 10:32:51 2000 Edan Ayal <edanayal@yahoo.com>
Diffstat (limited to 'ace/Message_Queue.h')
-rw-r--r--ace/Message_Queue.h14
1 files changed, 14 insertions, 0 deletions
diff --git a/ace/Message_Queue.h b/ace/Message_Queue.h
index 7d1df9e0ec3..837bc6505f6 100644
--- a/ace/Message_Queue.h
+++ b/ace/Message_Queue.h
@@ -72,6 +72,16 @@ public:
// which case <errno> == <EINTR>, or if the time specified in
// timeout elapses (in which case <errno> == <EWOULDBLOCK>).
+ virtual int peek_dequeue_head (ACE_Message_Block *&first_item,
+ ACE_Time_Value *timeout = 0) = 0;
+ // Retrieve the first <ACE_Message_Block> without removing it. Note
+ // that <timeout> uses <{absolute}> time rather than <{relative}>
+ // time. If the <timeout> elapses without receiving a message -1 is
+ // returned and <errno> is set to <EWOULDBLOCK>. If the queue is
+ // deactivated -1 is returned and <errno> is set to <ESHUTDOWN>.
+ // Otherwise, returns -1 on failure, else the number of items still
+ // on the queue.
+
virtual int enqueue_tail (ACE_Message_Block *new_item,
ACE_Time_Value *timeout = 0) = 0;
// Enqueue a <ACE_Message_Block *> into the tail of the queue.
@@ -138,6 +148,10 @@ public:
virtual int deactivated (void) = 0;
// Returns true if <deactivated_> is enabled.
+ // = Get/set the notification strategy for the <Message_Queue>
+ virtual ACE_Notification_Strategy *notification_strategy (void) = 0;
+ virtual void notification_strategy (ACE_Notification_Strategy *s) = 0;
+
// = Notification hook.
virtual void dump (void) const = 0;