Searched refs:recv_bytes (Results 1 – 11 of 11) sorted by relevance
| /external/python/cpython2/Lib/multiprocessing/ |
| D | connection.py | 422 response = connection.recv_bytes(256) # reject large message
432 message = connection.recv_bytes(256) # reject large message
437 response = connection.recv_bytes(256) # reject large message
457 s = self._conn.recv_bytes()
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | connection.py | 208 def recv_bytes(self, maxlength=None): member in _ConnectionBase
722 response = connection.recv_bytes(256) # reject large message
732 message = connection.recv_bytes(256) # reject large message
737 response = connection.recv_bytes(256) # reject large message
757 s = self._conn.recv_bytes()
|
| D | queues.py | 77 self._recv_bytes = self._reader.recv_bytes
343 res = self._reader.recv_bytes()
|
| D | resource_sharer.py | 39 share = conn.recv_bytes()
|
| /external/python/cpython2/Lib/test/ |
| D | test_multiprocessing.py | 1541 for msg in iter(conn.recv_bytes, SENTINEL):
1564 self.assertEqual(conn.recv_bytes(), msg)
1608 self.assertEqual(conn.recv_bytes(), really_big_msg)
1617 self.assertRaises(EOFError, conn.recv_bytes)
1649 self.assertEqual(conn.recv_bytes(), msg)
1663 self.assertEqual(b.recv_bytes(), msg)
1666 self.assertEqual(b.recv_bytes(), msg[5:])
1669 self.assertEqual(b.recv_bytes(), msg[7:7+8])
1672 self.assertEqual(b.recv_bytes(), latin(''))
1675 self.assertEqual(b.recv_bytes(), latin(''))
[all …]
|
| /external/python/cpython2/Lib/multiprocessing/dummy/ |
| D | connection.py | 74 self.recv = self.recv_bytes = _in.get
|
| /external/python/cpython3/Lib/test/ |
| D | _test_multiprocessing.py | 2300 for msg in iter(conn.recv_bytes, SENTINEL):
2323 self.assertEqual(conn.recv_bytes(), msg)
2370 self.assertEqual(conn.recv_bytes(), really_big_msg)
2379 self.assertRaises(EOFError, conn.recv_bytes)
2411 self.assertEqual(conn.recv_bytes(), msg)
2425 self.assertEqual(b.recv_bytes(), msg)
2428 self.assertEqual(b.recv_bytes(), msg[5:])
2431 self.assertEqual(b.recv_bytes(), msg[7:7+8])
2434 self.assertEqual(b.recv_bytes(), latin(''))
2437 self.assertEqual(b.recv_bytes(), latin(''))
[all …]
|
| /external/python/cpython3/Lib/multiprocessing/dummy/ |
| D | connection.py | 55 self.recv = self.recv_bytes = _in.get
|
| /external/kernel-headers/original/uapi/linux/ |
| D | cyclades.h | 89 unsigned long recv_bytes; /* Bytes received */ member
|
| /external/python/cpython2/Doc/library/ |
| D | multiprocessing.rst | 857 .. method:: recv_bytes([maxlength])
896 >>> a.recv_bytes()
2095 print conn.recv_bytes() # => 'hello'
|
| /external/python/cpython3/Doc/library/ |
| D | multiprocessing.rst | 1061 .. method:: recv_bytes([maxlength])
1113 >>> a.recv_bytes()
2437 print(conn.recv_bytes()) # => 'hello'
|