diff options
| author | nanbor <nanbor@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-12-11 22:08:29 +0000 |
|---|---|---|
| committer | nanbor <nanbor@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1998-12-11 22:08:29 +0000 |
| commit | e9ca1cd4146c48d1909b1c00e21063a54bd56876 (patch) | |
| tree | 4082f9a505c1ec5a40e90902feaf3e08eb8b8527 /ace/Message_Queue.cpp | |
| parent | a59ec8c6e27ace78c79d0a643ef0bde88419533e (diff) | |
| download | ATCD-e9ca1cd4146c48d1909b1c00e21063a54bd56876.tar.gz | |
Added enqueue_tail and dequeue_head
Diffstat (limited to 'ace/Message_Queue.cpp')
| -rw-r--r-- | ace/Message_Queue.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/ace/Message_Queue.cpp b/ace/Message_Queue.cpp index 445028cfd10..574f3d5f6e8 100644 --- a/ace/Message_Queue.cpp +++ b/ace/Message_Queue.cpp @@ -311,7 +311,11 @@ ACE_Message_Queue_NT::enqueue (ACE_Message_Block *new_item, ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, this->lock_, -1); if (!this->deactivated_) { - size_t msize = new_item->size (); + size_t msize = 0; + for (ACE_Message_Block *temp = new_item; + temp != 0; + temp = temp->cont ()) + msize += temp->size (); if (::PostQueuedCompletionStatus (this->completion_port_, msize, this->deactivated_, |