cpython: 55abd847c9f5 (original) (raw)

Mercurial > cpython

changeset 88855:55abd847c9f5

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

Victor Stinner victor.stinner@gmail.com
date	Fri, 31 Jan 2014 16:26:38 +0100
parents	3f54bc5392c3
children	7f649ff0756c
files	Lib/asyncio/proactor_events.py Lib/asyncio/windows_events.py Lib/test/test_asyncio/test_proactor_events.py
diffstat	3 files changed, 4 insertions(+), 0 deletions(-)[+] [-] Lib/asyncio/proactor_events.py 1 Lib/asyncio/windows_events.py 1 Lib/test/test_asyncio/test_proactor_events.py 2

line wrap: on

line diff

--- a/Lib/asyncio/proactor_events.py +++ b/Lib/asyncio/proactor_events.py @@ -354,6 +354,7 @@ class BaseProactorEventLoop(base_events. self._selector = proactor # convenient alias self._self_reading_future = None self._accept_futures = {} # socket file descriptor => Future

   self._granularity = max(proactor.resolution, self._granularity)[](#l1.7)
   proactor.set_loop(self)[](#l1.8)
   self._make_self_pipe()[](#l1.9)

--- a/Lib/asyncio/windows_events.py +++ b/Lib/asyncio/windows_events.py @@ -191,6 +191,7 @@ class IocpProactor: self._cache = {} self._registered = weakref.WeakSet() self._stopped_serving = weakref.WeakSet()

```
   self.resolution = 1e-3[](#l2.7)
```

def set_loop(self, loop): self._loop = loop

--- a/Lib/test/test_asyncio/test_proactor_events.py +++ b/Lib/test/test_asyncio/test_proactor_events.py @@ -17,6 +17,7 @@ class ProactorSocketTransportTests(unitt def setUp(self): self.loop = test_utils.TestLoop() self.proactor = unittest.mock.Mock()

   self.proactor.resolution = 1e-3[](#l3.7)
   self.loop._proactor = self.proactor[](#l3.8)
   self.protocol = test_utils.make_test_protocol(asyncio.Protocol)[](#l3.9)
   self.sock = unittest.mock.Mock(socket.socket)[](#l3.10)

@@ -342,6 +343,7 @@ class BaseProactorEventLoopTests(unittes def setUp(self): self.sock = unittest.mock.Mock(socket.socket) self.proactor = unittest.mock.Mock()

   self.proactor.resolution = 1e-3[](#l3.15)

self.ssock, self.csock = unittest.mock.Mock(), unittest.mock.Mock()