OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:_proactor
(Results
1 - 4
of
4
) sorted by null
/external/python/cpython3/Lib/test/test_asyncio/
test_proactor_events.py
31
self.loop.
_proactor
= self.proactor
52
self.loop.
_proactor
.recv.assert_called_with(self.sock, 4096)
63
self.loop.
_proactor
.recv.assert_called_with(self.sock, 4096)
76
self.assertFalse(self.loop.
_proactor
.recv.called)
81
err = self.loop.
_proactor
.recv.side_effect = ConnectionAbortedError()
91
self.loop.
_proactor
.recv.side_effect = ConnectionAbortedError()
100
self.loop.
_proactor
.recv.side_effect = ConnectionAbortedError()
108
err = self.loop.
_proactor
.recv.side_effect = ConnectionResetError()
119
err = self.loop.
_proactor
.recv.side_effect = (OSError())
152
self.loop.
_proactor
.send.assert_called_with(self.sock, b'data'
[
all
...]
test_windows_events.py
100
coro = self.loop.
_proactor
.connect_pipe('pipe_address')
114
fut = self.loop.
_proactor
.wait_for_handle(event, 0.5)
127
fut = self.loop.
_proactor
.wait_for_handle(event, 10)
146
fut = self.loop.
_proactor
.wait_for_handle(event, 10)
156
fut = self.loop.
_proactor
.wait_for_handle(event)
/external/python/cpython3/Lib/asyncio/
proactor_events.py
202
self._read_fut = self._loop.
_proactor
.recv(self._sock, 4096)
290
self._write_fut = self._loop.
_proactor
.send(self._sock, data)
316
self._read_fut = self._loop.
_proactor
.recv(self._sock, 16)
384
self.
_proactor
= proactor
436
self.
_proactor
.close()
437
self.
_proactor
= None
444
return self.
_proactor
.recv(sock, n)
447
return self.
_proactor
.send(sock, data)
450
return self.
_proactor
.connect(sock, address)
453
return self.
_proactor
.accept(sock
[
all
...]
windows_events.py
188
self.
_proactor
= proactor
206
self.
_proactor
._unregister(self._ov)
207
self.
_proactor
= None
233
self._event_fut = self.
_proactor
._wait_cancel(self._event,
316
f = self.
_proactor
.connect_pipe(address)
348
f = self.
_proactor
.accept_pipe(pipe)
768
f = self._loop.
_proactor
.wait_for_handle(int(self._proc._handle))
Completed in 447 milliseconds