ChangeLogTag: Thu May 09 00:38:22 2002 Irfan Pyarali <irfan@cs.wustl.edu>

1 files changed, 16 insertions, 15 deletions

diff --git a/ace/WFMO_Reactor.cpp b/ace/WFMO_Reactor.cpp
index cb674dd425c..0e8c79ebe8d 100644
--- a/ace/WFMO_Reactor.cpp
+++ b/ace/WFMO_Reactor.cpp
@@ -1603,25 +1603,26 @@ ACE_WFMO_Reactor::event_handling (ACE_Time_Value *max_wait_time,
   // called.
   ACE_Countdown_Time countdown (max_wait_time);
 
-  // Check to see if it is ok to enter ::WaitForMultipleObjects
-  // This will acquire <this->lock_> on success
-  // On failure, the lock will not be acquired
-  int result = this->ok_to_wait (max_wait_time, alertable);
-  if (result != 1)
-    return result;
+  int result;
+  do
+    {
+      // Check to see if it is ok to enter ::WaitForMultipleObjects
+      // This will acquire <this->lock_> on success On failure, the
+      // lock will not be acquired
+      result = this->ok_to_wait (max_wait_time, alertable);
+      if (result != 1)
+        return result;
 
-  // Increment the number of active threads
-  this->active_threads_++;
+      // Increment the number of active threads
+      this->active_threads_++;
 
-  // Release the <lock_>
-  this->lock_.release ();
+      // Release the <lock_>
+      this->lock_.release ();
 
-  // Update the countdown to reflect time waiting to play with the
-  // mut and event.
-  countdown.update ();
+      // Update the countdown to reflect time waiting to play with the
+      // mut and event.
+      countdown.update ();
 
-  do
-    {
       // Calculate timeout
       int timeout = this->calculate_timeout (max_wait_time);