diff options
Diffstat (limited to 'ace/Message_Queue.cpp')
| -rw-r--r-- | ace/Message_Queue.cpp | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/ace/Message_Queue.cpp b/ace/Message_Queue.cpp index 3453c8b29c1..a05fdc4d5c3 100644 --- a/ace/Message_Queue.cpp +++ b/ace/Message_Queue.cpp @@ -420,9 +420,9 @@ ACE_Message_Queue_NT::deactivate (void) // Get the number of shutdown messages necessary to wake up all // waiting threads. - - for (size_t cntr = this->cur_thrs_ - this->cur_count_; - cntr > 0; cntr++) + size_t cntr = + this->cur_thrs_ - ACE_static_cast (size_t, this->cur_count_); + while (cntr-- > 0) ::PostQueuedCompletionStatus (this->completion_port_, 0, this->state_, @@ -455,8 +455,9 @@ ACE_Message_Queue_NT::pulse (void) // Get the number of shutdown messages necessary to wake up all // waiting threads. - for (size_t cntr = this->cur_thrs_ - this->cur_count_; - cntr > 0; cntr++) + size_t cntr = + this->cur_thrs_ - ACE_static_cast (size_t, this->cur_count_); + while (cntr-- > 0) ::PostQueuedCompletionStatus (this->completion_port_, 0, this->state_, |