summaryrefslogtreecommitdiff
path: root/ace
diff options
context:
space:
mode:
authorschmidt <douglascraigschmidt@users.noreply.github.com>2001-01-31 17:17:36 +0000
committerschmidt <douglascraigschmidt@users.noreply.github.com>2001-01-31 17:17:36 +0000
commit0db9e6a0f675e2e8c4e6f77ddb62b83ef53bb4ef (patch)
tree0ec0bb96bf0f97c7d2ff2725a6e15479d4d9eca1 /ace
parent16f40bbebf1adf938e47523c0595e86017c7b832 (diff)
downloadATCD-0db9e6a0f675e2e8c4e6f77ddb62b83ef53bb4ef.tar.gz
ChangeLogTag:Wed Jan 31 06:43:27 2001 Douglas C. Schmidt <schmidt@ace.cs.wustl.edu>
Diffstat (limited to 'ace')
-rw-r--r--ace/Message_Queue_T.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/ace/Message_Queue_T.cpp b/ace/Message_Queue_T.cpp
index 99552d797c2..113c1538ac6 100644
--- a/ace/Message_Queue_T.cpp
+++ b/ace/Message_Queue_T.cpp
@@ -182,13 +182,15 @@ ACE_Message_Queue_Ex<ACE_MESSAGE_TYPE, ACE_SYNCH_USE>::dequeue_head (ACE_MESSAGE
ACE_Message_Block *mb;
+ int cur_count = this->queue_.dequeue_head (mb, timeout);
+
// Dequeue the message.
- if (this->queue_.dequeue_head (mb, timeout) != -1 )
+ if (cur_count != -1)
{
first_item = ACE_reinterpret_cast (ACE_MESSAGE_TYPE *, mb->base ());
// Delete the message block.
mb->release ();
- return 0;
+ return cur_count;
}
else
return -1;