Home
last modified time | relevance | path

Searched refs:bytes_received (Results 1 – 25 of 28) sorted by relevance

12

/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc140 alts_tsi_event* event, grpc_slice* bytes_received) { in get_serialized_start_server() argument
141 GPR_ASSERT(bytes_received != nullptr); in get_serialized_start_server()
149 req, reinterpret_cast<const char*> GRPC_SLICE_START_PTR(*bytes_received), in get_serialized_start_server()
150 GRPC_SLICE_LENGTH(*bytes_received)); in get_serialized_start_server()
168 grpc_slice* bytes_received) { in handshaker_client_start_server() argument
169 if (client == nullptr || event == nullptr || bytes_received == nullptr) { in handshaker_client_start_server()
173 grpc_byte_buffer* buffer = get_serialized_start_server(event, bytes_received); in handshaker_client_start_server()
187 static grpc_byte_buffer* get_serialized_next(grpc_slice* bytes_received) { in get_serialized_next() argument
188 GPR_ASSERT(bytes_received != nullptr); in get_serialized_next()
191 req, reinterpret_cast<const char*> GRPC_SLICE_START_PTR(*bytes_received), in get_serialized_next()
[all …]
Dalts_handshaker_client.h51 alts_tsi_event* event, grpc_slice* bytes_received);
53 grpc_slice* bytes_received);
87 grpc_slice* bytes_received);
101 grpc_slice* bytes_received);
/external/ltp/testcases/network/sockets/
DltpServer.c313 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 …]
/external/webrtc/webrtc/modules/rtp_rtcp/source/
Dreceive_statistics_unittest.cc59 size_t bytes_received = 0; in TEST_F() local
61 statistician->GetDataCounters(&bytes_received, &packets_received); in TEST_F()
62 EXPECT_EQ(200u, bytes_received); in TEST_F()
69 statistician->GetDataCounters(&bytes_received, &packets_received); in TEST_F()
70 EXPECT_EQ(600u, bytes_received); in TEST_F()
82 statisticians[kSsrc1]->GetDataCounters(&bytes_received, &packets_received); in TEST_F()
83 EXPECT_EQ(300u, bytes_received); in TEST_F()
85 statisticians[kSsrc2]->GetDataCounters(&bytes_received, &packets_received); in TEST_F()
86 EXPECT_EQ(900u, bytes_received); in TEST_F()
90 &bytes_received, &packets_received); in TEST_F()
[all …]
Dreceive_statistics_impl.cc284 size_t* bytes_received, uint32_t* packets_received) const { in GetDataCounters() argument
286 if (bytes_received) { in GetDataCounters()
287 *bytes_received = receive_counters_.transmitted.payload_bytes + in GetDataCounters()
Dreceive_statistics_impl.h36 void GetDataCounters(size_t* bytes_received,
/external/webrtc/talk/app/webrtc/test/
Dmockpeerconnectionobservers.h138 &stats_.bytes_received); in OnComplete()
171 return stats_.bytes_received; in BytesReceived()
222 bytes_received = 0; in Clear()
233 int bytes_received; member
/external/grpc-grpc/test/core/tsi/alts/handshaker/
Dalts_tsi_handshaker_test.cc337 grpc_slice* bytes_received) { in mock_server_start() argument
347 GPR_ASSERT(grpc_slice_cmp(*bytes_received, slice) == 0); in mock_server_start()
359 grpc_slice* bytes_received) { in mock_next() argument
374 GPR_ASSERT(bytes_received != nullptr); in mock_next()
375 GPR_ASSERT(memcmp(GRPC_SLICE_START_PTR(*bytes_received), in mock_next()
377 GRPC_SLICE_LENGTH(*bytes_received)) == 0); in mock_next()
380 *bytes_received) == 0); in mock_next()
/external/libchrome/base/
Dsync_socket_posix.cc188 const size_t bytes_received = in ReceiveWithTimeout() local
190 bytes_read_total += bytes_received; in ReceiveWithTimeout()
191 if (bytes_received != bytes_to_read) in ReceiveWithTimeout()
/external/linux-kselftest/tools/testing/selftests/bpf/
Dtest_tcpbpf_kern.c131 g.bytes_received = skops->bytes_received; in bpf_testcb()
Dtest_tcpbpf.h13 __u64 bytes_received; member
Dtest_tcpbpf_user.c44 EXPECT_EQ(501ULL, result->bytes_received, "llu"); in verify_result()
/external/iperf3/src/
Diperf.h109 iperf_size_t bytes_received; member
328 iperf_size_t bytes_received; member
Diperf_api.c1428 test->bytes_received += r; in iperf_recv()
1853 …= sp->sender ? (sp->result->bytes_sent - sp->result->bytes_sent_omit) : sp->result->bytes_received; in send_results()
1982 sp->result->bytes_received = bytes_transferred; in get_results()
2480 test->bytes_received = 0; in iperf_reset_test()
2562 rp->bytes_received = 0; in iperf_reset_stats()
2936 iperf_size_t bytes_received, total_received = 0; in iperf_print_results() local
3003 bytes_received = sp->result->bytes_received; in iperf_print_results()
3005 total_received += bytes_received; in iperf_print_results()
3121 … percent_received = (int) ( ( (double) bytes_received / (double) sb.st_size ) * 100.0 ); in iperf_print_results()
3125 …percent_received: %d filename: %s", (int64_t) bytes_sent, (int64_t) bytes_received, (int64_t) sb.… in iperf_print_results()
[all …]
Diperf_udp.c83 sp->result->bytes_received += r; in iperf_udp_recv()
Diperf_sctp.c69 sp->result->bytes_received += r; in iperf_sctp_recv()
Diperf_tcp.c66 sp->result->bytes_received += r; in iperf_tcp_recv()
/external/webrtc/webrtc/modules/rtp_rtcp/include/
Dreceive_statistics.h29 virtual void GetDataCounters(size_t* bytes_received,
/external/grpc-grpc/test/core/tsi/
Dtransport_security_test_lib.h214 size_t* bytes_received, bool is_client);
Dtransport_security_test_lib.cc238 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()
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_server_windows.cc250 DWORD bytes_received = 0; in start_accept_locked() local
269 addrlen, addrlen, &bytes_received, in start_accept_locked()
/external/grpc-grpc/src/core/lib/security/transport/
Dsecurity_handshaker.cc294 security_handshaker* h, const unsigned char* bytes_received, in do_handshaker_next_locked() argument
301 h->handshaker, bytes_received, bytes_received_size, &bytes_to_send, in do_handshaker_next_locked()
/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter.cc443 const uint64_t bytes_received = in ProcessViewDataCallEnd() local
460 0, ok_count, error_count, bytes_sent, bytes_received, latency_ms); in ProcessViewDataCallEnd()
/external/kernel-headers/original/uapi/linux/
Dbpf.h2829 __u64 bytes_received; member
/external/bcc/src/cc/compat/linux/
Dbpf.h2732 __u64 bytes_received; member

12