Searched defs:recv_buffer (Results 1 – 15 of 15) sorted by relevance
85 uint8* recv_buffer = static_cast<uint8*>( in RunNcclCollective() local117 uint8* recv_buffer = static_cast<uint8*>( in RunNcclCollective() local
85 void* recv_buffer = in RunNcclCollective() local
136 void* recv_buffer = in RunNcclCollective() local
94 grpc::ByteBuffer recv_buffer; in Read() local151 grpc::ByteBuffer recv_buffer; in ReadAndMaybeNotifyWrite() local
67 stream_executor::DeviceMemoryBase recv_buffer) override { in EnqueueOnTpuDeviceSendRecvLocal()
46 grpc_byte_buffer* recv_buffer; member
405 grpc_byte_buffer* recv_buffer, in alts_tsi_handshaker_handle_response()
589 grpc_byte_buffer recv_buffer; in check_handle_response_invalid_input() local632 grpc_byte_buffer* recv_buffer = generate_handshaker_response(INVALID); in check_handle_response_invalid_resp() local681 grpc_byte_buffer* recv_buffer = generate_handshaker_response(FAILED); in check_handle_response_failure() local708 grpc_byte_buffer* recv_buffer = generate_handshaker_response(CLIENT_START); in check_handle_response_after_shutdown() local
195 ByteBuffer recv_buffer; in SendRpc() local288 ByteBuffer recv_buffer; in TEST_F() local
151 ByteBuffer recv_buffer; in SendRpc() local291 ByteBuffer recv_buffer; in TEST_F() local
85 ByteBuffer recv_buffer; in HandleRawEcho() local119 ByteBuffer recv_buffer; in HandleRawClientStreaming() local164 ByteBuffer recv_buffer; in HandleGenericEcho() local180 ByteBuffer recv_buffer; in HandleGenericRequestStream() local
211 char recv_buffer[BUFFER_LEN]; in rc_send_server() local
73 grpc_byte_buffer* recv_buffer; member200 grpc_byte_buffer* recv_buffer = client->recv_buffer; in alts_handshaker_client_handle_response() local781 grpc_byte_buffer* recv_buffer, grpc_status_code status) { in alts_handshaker_client_set_fields_for_testing()
744 rtc::Buffer recv_buffer(0, data_size); in TcpInternal() local
540 char send_buffer[kDataSize], recv_buffer[kDataSize]; in TcpSendTest() local