From: Georg Brandl <georg@python.org>
Date: Thu, 28 Oct 2010 13:01:06 +0000 (+0000)
Subject: Support new Condition return value in the multiprocessing version.
X-Git-Tag: v3.2a4~321
X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=2fa4cc55e9e5fdf1817d5ff1d82a23eb12b69e40;p=python

Support new Condition return value in the multiprocessing version.
---

diff --git a/Lib/multiprocessing/synchronize.py b/Lib/multiprocessing/synchronize.py
index 7f4718c847..edf6c3e02d 100644
--- a/Lib/multiprocessing/synchronize.py
+++ b/Lib/multiprocessing/synchronize.py
@@ -217,7 +217,7 @@ class Condition(object):
 
         try:
             # wait for notification or timeout
-            self._wait_semaphore.acquire(True, timeout)
+            ret = self._wait_semaphore.acquire(True, timeout)
         finally:
             # indicate that this thread has woken
             self._woken_count.release()
@@ -225,6 +225,7 @@ class Condition(object):
             # reacquire lock
             for i in range(count):
                 self._lock.acquire()
+            return ret
 
     def notify(self):
         assert self._lock._semlock._is_mine(), 'lock is not owned'