diff options
| author | Victor Stinner <victor.stinner@gmail.com> | 2014-12-19 16:58:10 +0100 |
|---|---|---|
| committer | Victor Stinner <victor.stinner@gmail.com> | 2014-12-19 16:58:10 +0100 |
| commit | 7cdcdfa11b1cc084f9cc9ab0822da5a8a2014da9 (patch) | |
| tree | 4196f5842e6c8a8823bd722940aed1737edbb704 | |
| parent | e32105eb32b152c6d3c03620dea83e98e5d256bf (diff) | |
| download | trollius-git-7cdcdfa11b1cc084f9cc9ab0822da5a8a2014da9.tar.gz | |
IocpProactor.wait_for_handle() test now also checks the result of the future
| -rw-r--r-- | asyncio/windows_events.py | 5 | ||||
| -rw-r--r-- | tests/test_windows_events.py | 8 |
2 files changed, 11 insertions, 2 deletions
diff --git a/asyncio/windows_events.py b/asyncio/windows_events.py index 0773d06..d7feb1a 100644 --- a/asyncio/windows_events.py +++ b/asyncio/windows_events.py @@ -427,6 +427,11 @@ class IocpProactor: return self._register(ov, None, finish_connect_pipe, wait_for_post=True) def wait_for_handle(self, handle, timeout=None): + """Wait for a handle. + + Return a Future object. The result of the future is True if the wait + completed, or False if the wait did not complete (on timeout). + """ if timeout is None: ms = _winapi.INFINITE else: diff --git a/tests/test_windows_events.py b/tests/test_windows_events.py index b4d9398..9b264a6 100644 --- a/tests/test_windows_events.py +++ b/tests/test_windows_events.py @@ -98,8 +98,10 @@ class ProactorTests(test_utils.TestCase): # result should be False at timeout fut = self.loop._proactor.wait_for_handle(event, 0.5) start = self.loop.time() - self.loop.run_until_complete(fut) + done = self.loop.run_until_complete(fut) elapsed = self.loop.time() - start + + self.assertEqual(done, False) self.assertFalse(fut.result()) self.assertTrue(0.48 < elapsed < 0.9, elapsed) @@ -109,8 +111,10 @@ class ProactorTests(test_utils.TestCase): # result should be True immediately fut = self.loop._proactor.wait_for_handle(event, 10) start = self.loop.time() - self.loop.run_until_complete(fut) + done = self.loop.run_until_complete(fut) elapsed = self.loop.time() - start + + self.assertEqual(done, True) self.assertTrue(fut.result()) self.assertTrue(0 <= elapsed < 0.3, elapsed) |
