| /external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker.cc | 49 grpc_slice recv_bytes; member
272 if (!GRPC_SLICE_IS_EMPTY(handshaker->recv_bytes)) { in handshaker_next()
273 grpc_slice_unref_internal(handshaker->recv_bytes); in handshaker_next()
275 handshaker->recv_bytes = grpc_slice_ref(slice); in handshaker_next()
303 grpc_slice_unref_internal(handshaker->recv_bytes); in handshaker_destroy()
389 grpc_slice* recv_bytes, size_t bytes_consumed) { in set_unused_bytes() argument
390 GPR_ASSERT(recv_bytes != nullptr && self != nullptr); in set_unused_bytes()
391 if (GRPC_SLICE_LENGTH(*recv_bytes) == bytes_consumed) { in set_unused_bytes()
396 result->unused_bytes_size = GRPC_SLICE_LENGTH(*recv_bytes) - bytes_consumed; in set_unused_bytes()
400 GRPC_SLICE_START_PTR(*recv_bytes) + bytes_consumed, in set_unused_bytes()
[all …]
|
| /external/bcc/tools/ |
| D | tcptop.py | 251 for k, (send_bytes, recv_bytes) in sorted(ipv4_throughput.items(),
258 int(recv_bytes / 1024), int(send_bytes / 1024)))
278 for k, (send_bytes, recv_bytes) in sorted(ipv6_throughput.items(),
285 int(recv_bytes / 1024), int(send_bytes / 1024)))
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | collective_rma_local.cc | 48 int64 recv_bytes = to_tensor->TotalBytes(); in RecvFromPeer() local
49 CHECK_EQ(recv_bytes, hook->prod_value->TotalBytes()); in RecvFromPeer()
|
| /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/perfetto/src/profiling/memory/ |
| D | client.cc | 360 ssize_t recv_bytes = sock_.Receive(buf, sizeof(buf), nullptr, 0); in IsConnected() local
361 if (recv_bytes == 0) in IsConnected()
365 if (recv_bytes > 0) in IsConnected()
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | connection.py | 208 def recv_bytes(self, maxlength=None): member in _ConnectionBase
729 response = connection.recv_bytes(256) # reject large message
741 message = connection.recv_bytes(256) # reject large message
746 response = connection.recv_bytes(256) # reject large message
766 s = self._conn.recv_bytes()
|
| D | queues.py | 77 self._recv_bytes = self._reader.recv_bytes
352 res = self._reader.recv_bytes()
|
| D | resource_sharer.py | 39 share = conn.recv_bytes()
|
| /external/python/cpython2/Lib/multiprocessing/dummy/ |
| D | connection.py | 74 self.recv = self.recv_bytes = _in.get
|
| /external/python/cpython3/Lib/multiprocessing/dummy/ |
| D | connection.py | 57 self.recv = self.recv_bytes = _in.get
|
| /external/python/cpython2/Lib/test/ |
| D | test_multiprocessing.py | 1611 for msg in iter(conn.recv_bytes, SENTINEL):
1634 self.assertEqual(conn.recv_bytes(), msg)
1678 self.assertEqual(conn.recv_bytes(), really_big_msg)
1687 self.assertRaises(EOFError, conn.recv_bytes)
1719 self.assertEqual(conn.recv_bytes(), msg)
1733 self.assertEqual(b.recv_bytes(), msg)
1736 self.assertEqual(b.recv_bytes(), msg[5:])
1739 self.assertEqual(b.recv_bytes(), msg[7:7+8])
1742 self.assertEqual(b.recv_bytes(), latin(''))
1745 self.assertEqual(b.recv_bytes(), latin(''))
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | _test_multiprocessing.py | 2863 for msg in iter(conn.recv_bytes, SENTINEL):
2886 self.assertEqual(conn.recv_bytes(), msg)
2933 self.assertEqual(conn.recv_bytes(), really_big_msg)
2942 self.assertRaises(EOFError, conn.recv_bytes)
2974 self.assertEqual(conn.recv_bytes(), msg)
2988 self.assertEqual(b.recv_bytes(), msg)
2991 self.assertEqual(b.recv_bytes(), msg[5:])
2994 self.assertEqual(b.recv_bytes(), msg[7:7+8])
2997 self.assertEqual(b.recv_bytes(), latin(''))
3000 self.assertEqual(b.recv_bytes(), latin(''))
[all …]
|
| /external/kernel-headers/original/uapi/linux/ |
| D | cyclades.h | 89 unsigned long recv_bytes; /* Bytes received */ member
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | process.py | 93 self._reader.recv_bytes()
|
| /external/python/cpython2/Doc/library/ |
| D | multiprocessing.rst | 860 .. method:: recv_bytes([maxlength])
899 >>> a.recv_bytes()
2112 print conn.recv_bytes() # => 'hello'
|
| /external/python/cpython3/Doc/library/ |
| D | multiprocessing.rst | 1088 .. method:: recv_bytes([maxlength])
1140 >>> a.recv_bytes()
2462 print(conn.recv_bytes()) # => 'hello'
|