Home
last modified time | relevance | path

Searched refs:recv_bytes (Results 1 – 21 of 21) sorted by relevance

/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_tsi_handshaker.cc49 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/
Dtcptop.py251 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/rust/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc91 grpc_slice recv_bytes; member
138 grpc_slice_unref_internal(client->recv_bytes); in alts_grpc_handshaker_client_unref()
274 result, &client->recv_bytes, in alts_handshaker_client_handle_response()
624 grpc_slice_unref_internal(client->recv_bytes); in handshaker_client_next()
625 client->recv_bytes = grpc_slice_ref_internal(*bytes_received); in handshaker_client_next()
710 client->recv_bytes = grpc_empty_slice(); in alts_grpc_handshaker_client_create()
771 alts_handshaker_client* c, grpc_slice* recv_bytes) { in alts_handshaker_client_set_recv_bytes_for_testing() argument
775 client->recv_bytes = grpc_slice_ref_internal(*recv_bytes); in alts_handshaker_client_set_recv_bytes_for_testing()
794 void* user_data, bool has_sent_start_message, grpc_slice* recv_bytes) { in alts_handshaker_client_check_fields_for_testing() argument
800 if (recv_bytes != nullptr) { in alts_handshaker_client_check_fields_for_testing()
[all …]
Dalts_tsi_handshaker_private.h57 alts_handshaker_client* client, grpc_slice* recv_bytes);
61 void* user_data, bool has_sent_start_message, grpc_slice* recv_bytes);
Dalts_tsi_handshaker.cc656 grpc_slice* recv_bytes, in alts_tsi_handshaker_result_set_unused_bytes() argument
658 GPR_ASSERT(recv_bytes != nullptr && result != nullptr); in alts_tsi_handshaker_result_set_unused_bytes()
659 if (GRPC_SLICE_LENGTH(*recv_bytes) == bytes_consumed) { in alts_tsi_handshaker_result_set_unused_bytes()
664 sresult->unused_bytes_size = GRPC_SLICE_LENGTH(*recv_bytes) - bytes_consumed; in alts_tsi_handshaker_result_set_unused_bytes()
668 GRPC_SLICE_START_PTR(*recv_bytes) + bytes_consumed, in alts_tsi_handshaker_result_set_unused_bytes()
Dalts_tsi_handshaker.h95 grpc_slice* recv_bytes,
/external/python/cpython2/Lib/multiprocessing/
Dconnection.py422 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/tensorflow/tensorflow/core/common_runtime/
Dcollective_rma_local.cc65 int64 recv_bytes = to_tensor->TotalBytes(); in RecvFromPeer() local
66 CHECK_EQ(recv_bytes, hook->prod_value->TotalBytes()); in RecvFromPeer()
/external/perfetto/src/profiling/memory/
Dclient.cc479 ssize_t recv_bytes = sock_.Receive(buf, sizeof(buf), nullptr, 0); in IsConnected() local
480 if (recv_bytes == 0) in IsConnected()
484 if (recv_bytes > 0) in IsConnected()
/external/python/cpython2/Lib/multiprocessing/dummy/
Dconnection.py74 self.recv = self.recv_bytes = _in.get
/external/python/cpython3/Lib/multiprocessing/dummy/
Dconnection.py57 self.recv = self.recv_bytes = _in.get
/external/python/cpython3/Lib/multiprocessing/
Dconnection.py213 def recv_bytes(self, maxlength=None): member in _ConnectionBase
745 response = connection.recv_bytes(256) # reject large message
757 message = connection.recv_bytes(256) # reject large message
762 response = connection.recv_bytes(256) # reject large message
782 s = self._conn.recv_bytes()
Dqueues.py83 self._recv_bytes = self._reader.recv_bytes
366 res = self._reader.recv_bytes()
Dresource_sharer.py39 share = conn.recv_bytes()
/external/python/cpython2/Lib/test/
Dtest_multiprocessing.py1611 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/kernel-headers/original/uapi/linux/
Dcyclades.h89 unsigned long recv_bytes; /* Bytes received */ member
/external/python/cpython3/Lib/test/
D_test_multiprocessing.py3019 for msg in iter(conn.recv_bytes, SENTINEL):
3042 self.assertEqual(conn.recv_bytes(), msg)
3089 self.assertEqual(conn.recv_bytes(), really_big_msg)
3098 self.assertRaises(EOFError, conn.recv_bytes)
3130 self.assertEqual(conn.recv_bytes(), msg)
3144 self.assertEqual(b.recv_bytes(), msg)
3147 self.assertEqual(b.recv_bytes(), msg[5:])
3150 self.assertEqual(b.recv_bytes(), msg[7:7+8])
3153 self.assertEqual(b.recv_bytes(), latin(''))
3156 self.assertEqual(b.recv_bytes(), latin(''))
[all …]
/external/llvm-project/lldb/packages/Python/lldbsuite/test/tools/lldb-server/
Dgdbremote_testcase.py512 recv_bytes = sock.recv(4096)
513 if recv_bytes:
514 response += seven.bitcast_to_string(recv_bytes)
/external/python/cpython3/Lib/concurrent/futures/
Dprocess.py84 self._reader.recv_bytes()
/external/python/cpython2/Doc/library/
Dmultiprocessing.rst860 .. method:: recv_bytes([maxlength])
899 >>> a.recv_bytes()
2112 print conn.recv_bytes() # => 'hello'
/external/python/cpython3/Doc/library/
Dmultiprocessing.rst1127 .. method:: recv_bytes([maxlength])
1179 >>> a.recv_bytes()
2518 print(conn.recv_bytes()) # => 'hello'