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_windows_events.py
102
coro = self.loop.
_proactor
.connect_pipe('pipe_address')
116
fut = self.loop.
_proactor
.wait_for_handle(event, 0.5)
131
fut = self.loop.
_proactor
.wait_for_handle(event, 10)
150
fut = self.loop.
_proactor
.wait_for_handle(event, 10)
160
fut = self.loop.
_proactor
.wait_for_handle(event)
test_proactor_events.py
35
self.loop.
_proactor
= self.proactor
56
self.loop.
_proactor
.recv.assert_called_with(self.sock, 32768)
67
self.loop.
_proactor
.recv.assert_called_with(self.sock, 32768)
80
self.assertFalse(self.loop.
_proactor
.recv.called)
85
err = self.loop.
_proactor
.recv.side_effect = ConnectionAbortedError()
95
self.loop.
_proactor
.recv.side_effect = ConnectionAbortedError()
104
self.loop.
_proactor
.recv.side_effect = ConnectionAbortedError()
112
err = self.loop.
_proactor
.recv.side_effect = ConnectionResetError()
123
err = self.loop.
_proactor
.recv.side_effect = (OSError())
156
self.loop.
_proactor
.send.assert_called_with(self.sock, b'data'
[
all
...]
/external/python/cpython3/Lib/asyncio/
proactor_events.py
274
self._read_fut = self._loop.
_proactor
.recv(self._sock, 32768)
370
self._write_fut = self._loop.
_proactor
.send(self._sock, data)
409
self._read_fut = self._loop.
_proactor
.recv(self._sock, 16)
486
self.
_proactor
= proactor
537
self.
_proactor
.close()
538
self.
_proactor
= None
545
return await self.
_proactor
.recv(sock, n)
548
return await self.
_proactor
.recv_into(sock, buf)
551
return await self.
_proactor
.send(sock, data)
554
return await self.
_proactor
.connect(sock, address
[
all
...]
windows_events.py
191
self.
_proactor
= proactor
209
self.
_proactor
._unregister(self._ov)
210
self.
_proactor
= None
236
self._event_fut = self.
_proactor
._wait_cancel(self._event,
312
f = self.
_proactor
.connect_pipe(address)
343
f = self.
_proactor
.accept_pipe(pipe)
825
f = self._loop.
_proactor
.wait_for_handle(int(self._proc._handle))
Completed in 205 milliseconds