/aosp_15_r20/external/crosvm/base/src/sys/unix/ |
H A D | stream_channel.rs | 299 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair_byte() localVariable 340 let mut recv_buffer: [u8; 6] = [0; 6]; in test_non_blocking_pair_message() localVariable 379 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair_error_no_data() localVariable 409 let mut recv_buffer: [u8; 6] = [0; 6]; in test_from_unix_seqpacket() localVariable
|
/aosp_15_r20/external/grpc-grpc/test/core/tsi/alts/handshaker/ |
H A D | alts_tsi_handshaker_test.cc | 774 grpc_byte_buffer* recv_buffer = grpc_raw_byte_buffer_create(&slice, 1); in TEST() local 848 grpc_byte_buffer* recv_buffer = grpc_raw_byte_buffer_create(&slice, 1); in TEST() local 885 grpc_byte_buffer* recv_buffer = grpc_raw_byte_buffer_create(&slice, 1); in TEST() local 934 grpc_byte_buffer* recv_buffer = generate_handshaker_response(INVALID); in TEST() local 1006 grpc_byte_buffer* recv_buffer = generate_handshaker_response(FAILED); in TEST() local 1052 grpc_byte_buffer* recv_buffer = generate_handshaker_response(CLIENT_START); in TEST() local
|
/aosp_15_r20/external/crosvm/base/src/sys/windows/ |
H A D | named_pipes.rs | 1263 let mut recv_buffer: [u8; 4] = [0; 4]; in duplex_pipe_stream() localVariable 1320 let mut recv_buffer: [u8; 5] = [0; 5]; // Larger than required for messages in duplex_pipe_message() localVariable 1335 let mut recv_buffer: [u8; 1] = [0; 1]; in duplex_nowait_helper() localVariable 1403 let mut recv_buffer: [u8; 6] = [0; 6]; in duplex_overlapped() localVariable 1455 let mut recv_buffer: [u8; 6] = [0; 6]; in duplex_overlapped_test_in_use() localVariable 1464 let mut recv_buffer: [u8; 6] = [0; 6]; in duplex_overlapped_test_in_use() localVariable
|
H A D | stream_channel.rs | 482 let mut recv_buffer = [0u8; 1]; in test_read_notifies_multiple_writes() localVariable 545 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair() localVariable 590 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair_error_no_data() localVariable
|
/aosp_15_r20/device/google/cuttlefish/host/libs/audio_connector/ |
D | server.cpp | 167 uint64_t recv_buffer[3]; in ReceiveCommands() local 313 uint32_t recv_buffer[3]; in ReceivePlayback() local 340 uint32_t recv_buffer[3]; in ReceiveCapture() local
|
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
H A D | nccl_all_to_all_thunk.cc | 102 uint8_t* recv_buffer = in RunAllToAll() local 134 uint8_t* recv_buffer = in RunAllToAll() local
|
H A D | nccl_all_reduce_thunk.cc | 57 void* recv_buffer = buffer.destination_buffer.opaque(); in RunAllReduce() local 388 void* recv_buffer = buffer.destination_buffer.opaque(); in RunReduceScatter() local
|
H A D | nccl_all_gather_thunk.cc | 77 void* recv_buffer = buffer.destination_buffer.opaque(); in RunAllGather() local
|
/aosp_15_r20/external/grpc-grpc/test/cpp/util/ |
H A D | cli_call.cc | 109 grpc::ByteBuffer recv_buffer; in Read() local 165 grpc::ByteBuffer recv_buffer; in ReadAndMaybeNotifyWrite() local
|
/aosp_15_r20/external/grpc-grpc/test/cpp/end2end/ |
H A D | hybrid_end2end_test.cc | 86 ByteBuffer recv_buffer; in HandleRawEcho() local 120 ByteBuffer recv_buffer; in HandleRawClientStreaming() local 165 ByteBuffer recv_buffer; in HandleGenericEcho() local 181 ByteBuffer recv_buffer; in HandleGenericRequestStream() local
|
H A D | generic_end2end_test.cc | 165 ByteBuffer recv_buffer; in SendRpc() local 357 ByteBuffer recv_buffer; in TEST_F() local
|
H A D | server_interceptors_end2end_test.cc | 553 ByteBuffer recv_buffer; in TEST_F() local
|
/aosp_15_r20/external/grpc-grpc/src/core/tsi/alts/handshaker/ |
H A D | alts_handshaker_client.cc | 78 grpc_byte_buffer* recv_buffer = nullptr; member 204 grpc_byte_buffer* recv_buffer = client->recv_buffer; in alts_handshaker_client_handle_response() local 804 grpc_byte_buffer* recv_buffer, bool inject_read_failure) { in alts_handshaker_client_set_fields_for_testing()
|
/aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/ |
D | alts_handshaker_client.cc | 78 grpc_byte_buffer* recv_buffer = nullptr; member 204 grpc_byte_buffer* recv_buffer = client->recv_buffer; in alts_handshaker_client_handle_response() local 802 grpc_byte_buffer* recv_buffer, bool inject_read_failure) { in alts_handshaker_client_set_fields_for_testing()
|
/aosp_15_r20/external/tensorflow/tensorflow/compiler/xla/stream_executor/tpu/ |
H A D | tpu_stream.h | 67 stream_executor::DeviceMemoryBase recv_buffer) override { in EnqueueOnTpuDeviceSendRecvLocal()
|
/aosp_15_r20/packages/modules/DnsResolver/tests/dns_responder/ |
D | dns_tls_frontend.cpp | 271 uint8_t recv_buffer[max_size]; in handleRequests() local
|
/aosp_15_r20/external/crosvm/net_util/src/slirp/sys/windows/ |
H A D | handler.rs | 994 let mut recv_buffer: [u8; 512] = [0; 512]; in test_send_tcp_syn() localVariable
|
/aosp_15_r20/external/webrtc/rtc_base/ |
H A D | socket_unittest.cc | 786 rtc::Buffer recv_buffer(0, data_size); in TcpInternal() local
|
H A D | virtual_socket_unittest.cc | 522 char send_buffer[kDataSize], recv_buffer[kDataSize]; in TcpSendTest() local
|
/aosp_15_r20/external/rust/android-crates-io/crates/nix/test/sys/ |
D | test_socket.rs | 360 let mut recv_buffer = [0u8; 32]; in test_recvmsg_sockaddr_un() localVariable
|