| /third_party/ltp/testcases/network/sockets/ |
| D | ltpServer.c | 313 static int bytes_received = 0; in tcp_receive_buffer() local
322 if (bytes_received == 0) { in tcp_receive_buffer()
348 while (*(message_received + bytes_received) != END_LINE in tcp_receive_buffer()
349 && bytes_received < count) { in tcp_receive_buffer()
351 message_received + bytes_received, 1); in tcp_receive_buffer()
353 bytes_received++; in tcp_receive_buffer()
357 if (bytes_received == count - 1) { in tcp_receive_buffer()
360 bytes_received = 0; in tcp_receive_buffer()
365 if (bytes_received < count - 1) { in tcp_receive_buffer()
368 bytes_received++; in tcp_receive_buffer()
[all …]
|
| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client.h | 58 grpc_slice* bytes_received);
60 grpc_slice* bytes_received);
86 grpc_slice* bytes_received);
98 grpc_slice* bytes_received);
|
| D | alts_handshaker_client.cc | 546 alts_handshaker_client* c, grpc_slice* bytes_received) { in get_serialized_start_server() argument
548 GPR_ASSERT(bytes_received != nullptr); in get_serialized_start_server()
567 GRPC_SLICE_START_PTR(*bytes_received)), in get_serialized_start_server()
568 GRPC_SLICE_LENGTH(*bytes_received))); in get_serialized_start_server()
580 grpc_slice* bytes_received) { in handshaker_client_start_server() argument
581 if (c == nullptr || bytes_received == nullptr) { in handshaker_client_start_server()
587 grpc_byte_buffer* buffer = get_serialized_start_server(c, bytes_received); in handshaker_client_start_server()
602 static grpc_byte_buffer* get_serialized_next(grpc_slice* bytes_received) { in get_serialized_next() argument
603 GPR_ASSERT(bytes_received != nullptr); in get_serialized_next()
610 *bytes_received), in get_serialized_next()
[all …]
|
| /third_party/libuv/test/ |
| D | test-callback-stack.c | 44 static int bytes_received = 0; variable
89 bytes_received += nread; in read_cb()
94 if (bytes_received == sizeof MESSAGE) { in read_cb()
198 ASSERT(bytes_received == sizeof MESSAGE); in TEST_IMPL()
|
| /third_party/grpc/test/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_test.cc | 450 grpc_slice* bytes_received) { in mock_server_start() argument
457 GPR_ASSERT(grpc_slice_cmp(*bytes_received, slice) == 0); in mock_server_start()
469 grpc_slice* bytes_received) { in mock_next() argument
479 alts_handshaker_client_set_recv_bytes_for_testing(client, bytes_received); in mock_next()
481 bytes_received); in mock_next()
482 GPR_ASSERT(bytes_received != nullptr); in mock_next()
483 GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR(*bytes_received), in mock_next()
485 GRPC_SLICE_LENGTH(*bytes_received)) == 0); in mock_next()
|
| /third_party/gstreamer/gstplugins_base/gst/tcp/ |
| D | gsttcpclientsrc.h | 64 guint64 bytes_received; member
|
| D | gsttcpserversrc.h | 63 guint64 bytes_received; member
|
| D | gsttcpclientsrc.c | 310 src->bytes_received += read; in gst_tcp_client_src_create()
415 src->bytes_received = 0; in gst_tcp_client_src_start()
567 "bytes-received", G_TYPE_UINT64, src->bytes_received, NULL); in gst_tcp_client_src_get_stats()
|
| D | gsttcpserversrc.c | 311 src->bytes_received += read; in gst_tcp_server_src_create()
427 src->bytes_received = 0; in gst_tcp_server_src_start()
597 "bytes-received", G_TYPE_UINT64, src->bytes_received, NULL); in gst_tcp_server_src_get_stats()
|
| /third_party/grpc/src/core/lib/security/transport/ |
| D | security_handshaker.cc | 60 grpc_error* DoHandshakerNextLocked(const unsigned char* bytes_received,
357 const unsigned char* bytes_received, size_t bytes_received_size) { in DoHandshakerNextLocked() argument
363 handshaker_, bytes_received, bytes_received_size, &bytes_to_send, in DoHandshakerNextLocked()
|
| /third_party/grpc/test/core/tsi/ |
| D | transport_security_test_lib.h | 214 size_t* bytes_received, bool is_client);
|
| D | transport_security_test_lib.cc | 238 size_t* bytes_received, bool is_client) { in tsi_test_frame_protector_receive_message_from_peer() argument
244 GPR_ASSERT(bytes_received != nullptr); in tsi_test_frame_protector_receive_message_from_peer()
286 *bytes_received = message_offset; in tsi_test_frame_protector_receive_message_from_peer()
|
| /third_party/gstreamer/gstplugins_good/gst/rtpmanager/ |
| D | rtpsource.c | 420 "bytes-received", G_TYPE_UINT64, src->stats.bytes_received, in rtp_source_create_stats()
1034 src->stats.bytes_received += bytes; in update_queued_stats()
1037 src->bytes_received += bytes; in update_queued_stats()
1051 src->stats.bytes_received = 0; in init_seq()
1216 src->stats.bytes_received += pinfo->bytes; in update_receiver_stats()
1219 src->bytes_received += pinfo->bytes; in update_receiver_stats()
1275 do_bitrate_estimation (src, pinfo->running_time, &src->bytes_received); in rtp_source_process_rtp()
|
| D | rtpstats.h | 138 guint64 bytes_received; member
|
| D | rtpsource.h | 176 guint64 bytes_received; member
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | tcp_server_windows.cc | 256 DWORD bytes_received = 0; in start_accept_locked() local
275 addrlen, addrlen, &bytes_received, in start_accept_locked()
|
| /third_party/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter.cc | 445 const uint64_t bytes_received = in ProcessViewDataCallEnd() local
462 0, ok_count, error_count, bytes_sent, bytes_received, latency_ms); in ProcessViewDataCallEnd()
|
| /third_party/glib/gio/ |
| D | giotypes.h | 486 gsize bytes_received; member
|
| D | gsocket.c | 5453 input_message.bytes_received = 0; in g_socket_receive_message_with_timeout()
5516 DWORD bytes_received; in g_socket_receive_message_with_timeout() local
5546 &bytes_received, &win_flags, in g_socket_receive_message_with_timeout()
5552 &bytes_received, &win_flags, in g_socket_receive_message_with_timeout()
5597 return bytes_received; in g_socket_receive_message_with_timeout()
5817 messages[i].bytes_received = msgvec[i].msg_len; in g_socket_receive_messages_with_timeout()
5856 msg->bytes_received = len; in g_socket_receive_messages_with_timeout()
|
| /third_party/gstreamer/gstplugins_good/tests/check/elements/ |
| D | rtpbin_buffer_list.c | 1086 guint64 bytes_received; in GST_START_TEST() local
1124 "bytes-received", G_TYPE_UINT64, &bytes_received, in GST_START_TEST()
1127 fail_unless (bytes_received == chain_list_bytes_received); in GST_START_TEST()
|
| /third_party/glib/gio/tests/ |
| D | socket.c | 736 g_assert_cmpuint (im[0].bytes_received, ==, 3); in test_ip_sync_dgram()
738 g_assert_cmpuint (im[1].bytes_received, ==, 17); in test_ip_sync_dgram()
739 g_assert_cmpuint (im[2].bytes_received, ==, v[6].size); in test_ip_sync_dgram()
|
| /third_party/gstreamer/gstplugins_bad/tests/check/elements/ |
| D | webrtcbin.c | 1399 guint64 packets_received, bytes_received; in validate_inbound_rtp_stats() local
1413 &bytes_received, NULL)); in validate_inbound_rtp_stats()
|
| /third_party/gstreamer/gstplugins_good/ |
| D | ChangeLog | 13027 rtpsource: expose field bytes_received in RTPSourceStats
13029 2010-03-02) bytes_received filed in RTPSourceStats is set but then never
|