diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 2000-08-10 00:24:56 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 2000-08-10 00:24:56 +0000 |
| commit | 45476814852995130b416b29cf2bba3a045d8df8 (patch) | |
| tree | 6f26eb64110a869fe34567fc049668c385b589b3 /ace/Message_Queue_T.cpp | |
| parent | 7db82cba4b6ac854499a1b79b2db16f553356b64 (diff) | |
| download | ATCD-45476814852995130b416b29cf2bba3a045d8df8.tar.gz | |
ChangeLogTag:Wed Aug 9 13:28:20 2000 Douglas C. Schmidt <schmidt@tango.cs.wustl.edu>
Diffstat (limited to 'ace/Message_Queue_T.cpp')
| -rw-r--r-- | ace/Message_Queue_T.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ace/Message_Queue_T.cpp b/ace/Message_Queue_T.cpp index fb714be321f..b9c23dc1ea5 100644 --- a/ace/Message_Queue_T.cpp +++ b/ace/Message_Queue_T.cpp @@ -471,6 +471,9 @@ ACE_Message_Queue<ACE_SYNCH_USE>::dequeue_head_i (ACE_Message_Block *&first_item this->cur_count_--; + if (this->cur_count_ == 0 && this->head_ == this->tail_) + this->head_ = this->tail_ = 0; + // Only signal enqueueing threads if we've fallen below the low // water mark. if (this->cur_bytes_ <= this->low_water_mark_ |