[Python-checkins] cpython: Issue #20455: Add a resolution attribute to IocpProactor (1 ms)

[victor.stinner]

http://hg.python.org/cpython/rev/55abd847c9f5
changeset:   88855:55abd847c9f5
user:        Victor Stinner <victor.stinner at gmail.com>
date:        Fri Jan 31 16:26:38 2014 +0100
summary:
  Issue #20455: Add a resolution attribute to IocpProactor (1 ms)

files:
  Lib/asyncio/proactor_events.py                |  1 +
  Lib/asyncio/windows_events.py                 |  1 +
  Lib/test/test_asyncio/test_proactor_events.py |  2 ++
  3 files changed, 4 insertions(+), 0 deletions(-)


diff --git a/Lib/asyncio/proactor_events.py b/Lib/asyncio/proactor_events.py
--- a/Lib/asyncio/proactor_events.py
+++ b/Lib/asyncio/proactor_events.py
@@ -354,6 +354,7 @@
         self._selector = proactor   # convenient alias
         self._self_reading_future = None
         self._accept_futures = {}   # socket file descriptor => Future
+        self._granularity = max(proactor.resolution, self._granularity)
         proactor.set_loop(self)
         self._make_self_pipe()
 
diff --git a/Lib/asyncio/windows_events.py b/Lib/asyncio/windows_events.py
--- a/Lib/asyncio/windows_events.py
+++ b/Lib/asyncio/windows_events.py
@@ -191,6 +191,7 @@
         self._cache = {}
         self._registered = weakref.WeakSet()
         self._stopped_serving = weakref.WeakSet()
+        self.resolution = 1e-3
 
     def set_loop(self, loop):
         self._loop = loop
diff --git a/Lib/test/test_asyncio/test_proactor_events.py b/Lib/test/test_asyncio/test_proactor_events.py
--- a/Lib/test/test_asyncio/test_proactor_events.py
+++ b/Lib/test/test_asyncio/test_proactor_events.py
@@ -17,6 +17,7 @@
     def setUp(self):
         self.loop = test_utils.TestLoop()
         self.proactor = unittest.mock.Mock()
+        self.proactor.resolution = 1e-3
         self.loop._proactor = self.proactor
         self.protocol = test_utils.make_test_protocol(asyncio.Protocol)
         self.sock = unittest.mock.Mock(socket.socket)
@@ -342,6 +343,7 @@
     def setUp(self):
         self.sock = unittest.mock.Mock(socket.socket)
         self.proactor = unittest.mock.Mock()
+        self.proactor.resolution = 1e-3
 
         self.ssock, self.csock = unittest.mock.Mock(), unittest.mock.Mock()
 

-- 
Repository URL: http://hg.python.org/cpython