diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 2001-01-31 17:17:36 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 2001-01-31 17:17:36 +0000 |
| commit | 0db9e6a0f675e2e8c4e6f77ddb62b83ef53bb4ef (patch) | |
| tree | 0ec0bb96bf0f97c7d2ff2725a6e15479d4d9eca1 /ace | |
| parent | 16f40bbebf1adf938e47523c0595e86017c7b832 (diff) | |
| download | ATCD-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.cpp | 6 |
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; |