| /external/crosvm/base/src/sys/unix/ |
| D | stream_channel.rs | 288 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair_byte() localVariable
329 let mut recv_buffer: [u8; 6] = [0; 6]; in test_non_blocking_pair_message() localVariable
368 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair_error_no_data() localVariable
398 let mut recv_buffer: [u8; 6] = [0; 6]; in test_from_unix_seqpacket() localVariable
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | nccl_all_to_all_thunk.cc | 102 uint8_t* recv_buffer = in RunAllToAll() local
134 uint8_t* recv_buffer = in RunAllToAll() local
|
| D | nccl_all_gather_thunk.cc | 77 void* recv_buffer = buffer.destination_buffer.opaque(); in RunAllGather() local
|
| 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
|
| /external/grpc-grpc/test/cpp/util/ |
| D | cli_call.cc | 94 grpc::ByteBuffer recv_buffer; in Read() local
151 grpc::ByteBuffer recv_buffer; in ReadAndMaybeNotifyWrite() local
|
| /external/crosvm/base/src/sys/windows/ |
| D | named_pipes.rs | 1061 let mut recv_buffer: [u8; 4] = [0; 4]; in duplex_pipe_stream() localVariable
1117 let mut recv_buffer: [u8; 5] = [0; 5]; // Larger than required for messages in duplex_pipe_message() localVariable
1132 let mut recv_buffer: [u8; 1] = [0; 1]; in duplex_nowait_helper() localVariable
1198 let mut recv_buffer: [u8; 6] = [0; 6]; in duplex_overlapped() localVariable
1250 let mut recv_buffer: [u8; 6] = [0; 6]; in duplex_overlapped_test_in_use() localVariable
1259 let mut recv_buffer: [u8; 6] = [0; 6]; in duplex_overlapped_test_in_use() localVariable
1307 let recv_buffer = p2 in read_write_overlapped_message() localVariable
|
| D | stream_channel.rs | 470 let mut recv_buffer = [0u8; 1]; in test_read_notifies_multiple_writes() localVariable
533 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair() localVariable
578 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair_error_no_data() localVariable
|
| /external/tensorflow/tensorflow/compiler/xla/stream_executor/tpu/ |
| D | tpu_stream.h | 67 stream_executor::DeviceMemoryBase recv_buffer) override { in EnqueueOnTpuDeviceSendRecvLocal()
|
| /external/grpc-grpc/test/core/tsi/alts/handshaker/ |
| D | alts_tsi_handshaker_test.cc | 589 grpc_byte_buffer recv_buffer; in check_handle_response_invalid_input() local
632 grpc_byte_buffer* recv_buffer = generate_handshaker_response(INVALID); in check_handle_response_invalid_resp() local
681 grpc_byte_buffer* recv_buffer = generate_handshaker_response(FAILED); in check_handle_response_failure() local
708 grpc_byte_buffer* recv_buffer = generate_handshaker_response(CLIENT_START); in check_handle_response_after_shutdown() local
|
| /external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| D | alts_tsi_event.h | 46 grpc_byte_buffer* recv_buffer; member
|
| D | alts_tsi_handshaker.cc | 405 grpc_byte_buffer* recv_buffer, in alts_tsi_handshaker_handle_response()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | filter_end2end_test.cc | 195 ByteBuffer recv_buffer; in SendRpc() local
288 ByteBuffer recv_buffer; in TEST_F() local
|
| D | generic_end2end_test.cc | 151 ByteBuffer recv_buffer; in SendRpc() local
291 ByteBuffer recv_buffer; in TEST_F() local
|
| D | hybrid_end2end_test.cc | 85 ByteBuffer recv_buffer; in HandleRawEcho() local
119 ByteBuffer recv_buffer; in HandleRawClientStreaming() local
164 ByteBuffer recv_buffer; in HandleGenericEcho() local
180 ByteBuffer recv_buffer; in HandleGenericRequestStream() local
|
| /external/ppp/pppd/plugins/radius/ |
| D | sendserver.c | 211 char recv_buffer[BUFFER_LEN]; in rc_send_server() local
|
| /external/rust/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client.cc | 73 grpc_byte_buffer* recv_buffer = nullptr; member
196 grpc_byte_buffer* recv_buffer = client->recv_buffer; in alts_handshaker_client_handle_response() local
775 grpc_byte_buffer* recv_buffer, grpc_status_code status) { in alts_handshaker_client_set_fields_for_testing()
|
| /external/crosvm/net_util/src/slirp/sys/windows/ |
| D | handler.rs | 960 let mut recv_buffer: [u8; 512] = [0; 512]; in test_send_tcp_syn() localVariable
|
| /external/webrtc/rtc_base/ |
| D | socket_unittest.cc | 786 rtc::Buffer recv_buffer(0, data_size); in TcpInternal() local
|
| D | virtual_socket_unittest.cc | 522 char send_buffer[kDataSize], recv_buffer[kDataSize]; in TcpSendTest() local
|
| /external/curl/lib/ |
| D | cf-socket.c | 753 struct io_buffer recv_buffer; member
|