Commit c440a984 authored by Victor Stinner's avatar Victor Stinner

Issue #20455: Add a resolution attribute to IocpProactor (1 ms)

parent 626347ce
......@@ -354,6 +354,7 @@ class BaseProactorEventLoop(base_events.BaseEventLoop):
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()
......
......@@ -191,6 +191,7 @@ class IocpProactor:
self._cache = {}
self._registered = weakref.WeakSet()
self._stopped_serving = weakref.WeakSet()
self.resolution = 1e-3
def set_loop(self, loop):
self._loop = loop
......
......@@ -17,6 +17,7 @@ class ProactorSocketTransportTests(unittest.TestCase):
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 @@ class BaseProactorEventLoopTests(unittest.TestCase):
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()
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment