Searched refs:recv_into (Results 1 - 9 of 9) sorted by relevance
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_proactor_events.py | 57 self.proactor.recv_into.assert_called_with(self.sock, bytearray(self.buffer_size))
62 self.loop._proactor.recv_into.assert_called_with(self.sock, bytearray(self.buffer_size))
77 self.loop._proactor.recv_into.assert_called_with(self.sock, called_buf)
91 self.assertFalse(self.loop._proactor.recv_into.called)
96 err = self.loop._proactor.recv_into.side_effect = ConnectionAbortedError()
106 self.loop._proactor.recv_into.side_effect = ConnectionAbortedError()
115 self.loop._proactor.recv_into.side_effect = ConnectionAbortedError()
123 err = self.loop._proactor.recv_into.side_effect = ConnectionResetError()
134 err = self.loop._proactor.recv_into.side_effect = (OSError())
398 def recv_into(soc function
[all...] |
| H A D | test_selector_events.py | 962 self.sock.recv_into.return_value = 10
975 self.sock.recv_into.return_value = 10
991 self.sock.recv_into.return_value = 0
1000 self.sock.recv_into.return_value = 10
1010 self.sock.recv_into.return_value = 0
1020 self.sock.recv_into.return_value = 0
1029 self.sock.recv_into.side_effect = BlockingIOError
1039 self.sock.recv_into.side_effect = InterruptedError
1049 err = self.sock.recv_into.side_effect = ConnectionResetError()
1059 err = self.sock.recv_into
[all...] |
| /third_party/python/Lib/asyncio/ |
| H A D | selector_events.py | 409 return sock.recv_into(buf)
427 nbytes = sock.recv_into(buf)
970 nbytes = self._sock.recv_into(buf)
|
| H A D | proactor_events.py | 305 self._read_fut = self._loop._proactor.recv_into(self._sock, self._data)
708 return await self._proactor.recv_into(sock, buf)
|
| H A D | windows_events.py | 481 def recv_into(self, conn, buf, flags=0): member in IocpProactor
|
| /third_party/python/Lib/ |
| H A D | ssl.py | 1296 def recv_into(self, buffer, nbytes=None, flags=0): member in SSLSocket
1305 "non-zero flags not allowed in calls to recv_into() on %s" %
1309 return super().recv_into(buffer, nbytes, flags)
|
| H A D | socket.py | 706 return self._sock.recv_into(b)
|
| /third_party/python/Lib/test/ |
| H A D | test_socket.py | 4542 self.checkInterruptedRecv(self.serv.recv_into, bytearray(1024))
5609 nbytes = self.cli_conn.recv_into(buf)
5621 nbytes = self.cli_conn.recv_into(buf)
5630 nbytes = self.cli_conn.recv_into(memoryview(buf))
|
| H A D | test_ssl.py | 571 self.assertRaises(OSError, ss.recv_into, bytearray(b'x'))
3631 count = s.recv_into(b)
3649 ('recv_into', _recv_into, True, []),
3763 self.assertEqual(s.recv_into(bytearray()), 0)
|
Completed in 27 milliseconds