diff options
Diffstat (limited to 'ace/Message_Queue_T.cpp')
| -rw-r--r-- | ace/Message_Queue_T.cpp | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/ace/Message_Queue_T.cpp b/ace/Message_Queue_T.cpp index 9b2f44d9e89..eaa079e7aed 100644 --- a/ace/Message_Queue_T.cpp +++ b/ace/Message_Queue_T.cpp @@ -1180,9 +1180,9 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_head (ACE_Message_Block *new_item, if (queue_count == -1) return -1; - } - this->notify (); + this->notify (); + } return queue_count; } @@ -1212,8 +1212,9 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_prio (ACE_Message_Block *new_item, if (queue_count == -1) return -1; + + this->notify (); } - this->notify (); return queue_count; } @@ -1243,8 +1244,9 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_deadline (ACE_Message_Block *new_item, if (queue_count == -1) return -1; + + this->notify (); } - this->notify (); return queue_count; } @@ -1281,8 +1283,9 @@ ACE_Message_Queue<ACE_SYNCH_USE>::enqueue_tail (ACE_Message_Block *new_item, if (queue_count == -1) return -1; + + this->notify (); } - this->notify (); return queue_count; } |