summaryrefslogtreecommitdiff
path: root/ace
diff options
context:
space:
mode:
authorvenkita <venkita@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2003-04-29 17:21:18 +0000
committervenkita <venkita@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2003-04-29 17:21:18 +0000
commite0bb8a164c5dcb78035ae99c54ed64047a4494f2 (patch)
tree462da1696243846c34860144e56d83dc1f49b25a /ace
parent7f5013c5c02c35699042567555b5f7a953b0642d (diff)
downloadATCD-e0bb8a164c5dcb78035ae99c54ed64047a4494f2.tar.gz
ChangeLogTag: Tue Apr 29 12:17:03 2003 Venkita Subramonian <venkita@cs.wustl.edu>
Diffstat (limited to 'ace')
-rw-r--r--ace/Message_Queue_T.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/ace/Message_Queue_T.cpp b/ace/Message_Queue_T.cpp
index eaa079e7aed..1f0e5f71cfb 100644
--- a/ace/Message_Queue_T.cpp
+++ b/ace/Message_Queue_T.cpp
@@ -1756,9 +1756,8 @@ ACE_Dynamic_Message_Queue<ACE_SYNCH_USE>::enqueue_i (ACE_Message_Block *new_item
size_t mb_length = 0;
new_item->total_size_and_length (mb_bytes,
mb_length);
- // Subtract off all of the bytes associated with this message.
- this->cur_bytes_ -= mb_bytes;
- this->cur_length_ -= mb_length;
+ this->cur_bytes_ += mb_bytes;
+ this->cur_length_ += mb_length;
this->cur_count_++;
if (this->signal_dequeue_waiters () == -1)