Home
last modified time | relevance | path

Searched refs:recv_buffer (Results 1 – 25 of 27) sorted by relevance

12

/external/crosvm/base/src/sys/unix/
Dstream_channel.rs292 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair_byte() localVariable
294 let mut size = receiver.read(&mut recv_buffer).unwrap(); in test_non_blocking_pair_byte()
296 assert_eq!(recv_buffer, [75, 77, 54, 82]); in test_non_blocking_pair_byte()
298 size = receiver.read(&mut recv_buffer).unwrap(); in test_non_blocking_pair_byte()
300 assert_eq!(recv_buffer[0..2], [76, 65]); in test_non_blocking_pair_byte()
333 let mut recv_buffer: [u8; 6] = [0; 6]; in test_non_blocking_pair_message() localVariable
335 let size = receiver.read(&mut recv_buffer).unwrap(); in test_non_blocking_pair_message()
337 assert_eq!(recv_buffer, [75, 77, 54, 82, 76, 65]); in test_non_blocking_pair_message()
372 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair_error_no_data() localVariable
373 let size = receiver.read(&mut recv_buffer).unwrap(); in test_non_blocking_pair_error_no_data()
[all …]
/external/crosvm/base/src/sys/windows/
Dstream_channel.rs485 let mut recv_buffer = [0u8; 1]; in test_read_notifies_multiple_writes() localVariable
486 let size = receiver.read(&mut recv_buffer).unwrap(); in test_read_notifies_multiple_writes()
488 assert_eq!(recv_buffer[0], 1); in test_read_notifies_multiple_writes()
492 let size = receiver.read(&mut recv_buffer).unwrap(); in test_read_notifies_multiple_writes()
494 assert_eq!(recv_buffer[0], 2); in test_read_notifies_multiple_writes()
548 let mut recv_buffer: [u8; 4] = [0; 4]; in test_non_blocking_pair() localVariable
550 let mut size = receiver.read(&mut recv_buffer).unwrap(); in test_non_blocking_pair()
552 assert_eq!(recv_buffer, [75, 77, 54, 82]); in test_non_blocking_pair()
554 size = receiver.read(&mut recv_buffer).unwrap(); in test_non_blocking_pair()
556 assert_eq!(recv_buffer[0..2], [76, 65]); in test_non_blocking_pair()
[all …]
Dnamed_pipes.rs1316 let mut recv_buffer: [u8; 4] = [0; 4]; in duplex_pipe_stream() localVariable
1318 let mut size = receiver.read(&mut recv_buffer).unwrap(); in duplex_pipe_stream()
1320 assert_eq!(recv_buffer, [75, 77, 54, 82]); in duplex_pipe_stream()
1322 size = receiver.read(&mut recv_buffer).unwrap(); in duplex_pipe_stream()
1324 assert_eq!(recv_buffer[0..2], [76, 65]); in duplex_pipe_stream()
1373 let mut recv_buffer: [u8; 5] = [0; 5]; // Larger than required for messages in duplex_pipe_message() localVariable
1375 let mut size = receiver.read(&mut recv_buffer).unwrap(); in duplex_pipe_message()
1377 assert_eq!(recv_buffer[0..3], [1, 23, 45]); in duplex_pipe_message()
1379 size = receiver.read(&mut recv_buffer).unwrap(); in duplex_pipe_message()
1381 assert_eq!(recv_buffer[0..3], [67, 89, 10]); in duplex_pipe_message()
[all …]
/external/grpc-grpc/test/cpp/end2end/
Dgeneric_end2end_test.cc165 ByteBuffer recv_buffer; in SendRpc() local
166 stream.Read(&recv_buffer, tag(5)); in SendRpc()
168 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in SendRpc()
180 recv_buffer.Clear(); in SendRpc()
181 call->Read(&recv_buffer, tag(8)); in SendRpc()
183 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in SendRpc()
357 ByteBuffer recv_buffer; in TEST_F() local
358 srv_stream.Read(&recv_buffer, tag(4)); in TEST_F()
360 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in TEST_F()
369 cli_stream->Read(&recv_buffer, tag(6)); in TEST_F()
[all …]
Dhybrid_end2end_test.cc86 ByteBuffer recv_buffer; in HandleRawEcho() local
87 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, in HandleRawEcho()
91 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in HandleRawEcho()
120 ByteBuffer recv_buffer; in HandleRawClientStreaming() local
129 srv_stream.Read(&recv_buffer, tag(i)); in HandleRawClientStreaming()
133 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in HandleRawClientStreaming()
165 ByteBuffer recv_buffer; in HandleGenericEcho() local
166 stream->Read(&recv_buffer, tag(2)); in HandleGenericEcho()
169 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in HandleGenericEcho()
181 ByteBuffer recv_buffer; in HandleGenericRequestStream() local
[all …]
Dserver_interceptors_end2end_test.cc553 ByteBuffer recv_buffer; in TEST_F() local
554 stream.Read(&recv_buffer, tag(5)); in TEST_F()
556 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in TEST_F()
572 recv_buffer.Clear(); in TEST_F()
573 call->Read(&recv_buffer, tag(8)); in TEST_F()
575 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in TEST_F()
/external/grpc-grpc/test/cpp/util/
Dcli_call.cc109 grpc::ByteBuffer recv_buffer; in Read() local
110 call_->Read(&recv_buffer, tag(3)); in Read()
116 GPR_ASSERT(recv_buffer.Dump(&slices).ok()); in Read()
165 grpc::ByteBuffer recv_buffer; in ReadAndMaybeNotifyWrite() local
167 call_->Read(&recv_buffer, tag(3)); in ReadAndMaybeNotifyWrite()
199 GPR_ASSERT(recv_buffer.Dump(&slices).ok()); in ReadAndMaybeNotifyWrite()
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
Dnccl_all_to_all_thunk.cc102 uint8_t* recv_buffer = in RunAllToAll() local
121 XLA_CUDA_RETURN_IF_ERROR(ncclRecv(recv_buffer + rank * chunk_bytes, in RunAllToAll()
134 uint8_t* recv_buffer = in RunAllToAll() local
145 XLA_CUDA_RETURN_IF_ERROR(ncclRecv(recv_buffer, element_count, dtype, in RunAllToAll()
Dnccl_all_gather_thunk.cc77 void* recv_buffer = buffer.destination_buffer.opaque(); in RunAllGather() local
88 send_buffer, recv_buffer, element_count, static_cast<const void*>(comm), in RunAllGather()
92 send_buffer, recv_buffer, element_count, dtype, comm, gpu_stream)); in RunAllGather()
Dnccl_all_reduce_thunk.cc57 void* recv_buffer = buffer.destination_buffer.opaque(); in RunAllReduce() local
67 send_buffer, recv_buffer, element_count, static_cast<const void*>(comm), in RunAllReduce()
70 XLA_CUDA_RETURN_IF_ERROR(ncclAllReduce(send_buffer, recv_buffer, in RunAllReduce()
388 void* recv_buffer = buffer.destination_buffer.opaque(); in RunReduceScatter() local
406 send_buffer, recv_buffer, recv_count, static_cast<const void*>(comm), in RunReduceScatter()
408 XLA_CUDA_RETURN_IF_ERROR(ncclReduceScatter(send_buffer, recv_buffer, in RunReduceScatter()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc78 grpc_byte_buffer* recv_buffer = nullptr; member
139 grpc_byte_buffer_destroy(client->recv_buffer); in alts_grpc_handshaker_client_unref()
141 client->recv_buffer = nullptr; in alts_grpc_handshaker_client_unref()
204 grpc_byte_buffer* recv_buffer = client->recv_buffer; in alts_handshaker_client_handle_response() local
236 if (recv_buffer == nullptr) { in alts_handshaker_client_handle_response()
247 alts_tsi_utils_deserialize_response(recv_buffer, arena.ptr()); in alts_handshaker_client_handle_response()
248 grpc_byte_buffer_destroy(client->recv_buffer); in alts_handshaker_client_handle_response()
249 client->recv_buffer = nullptr; in alts_handshaker_client_handle_response()
353 op->data.recv_message.recv_message = &client->recv_buffer; in continue_make_grpc_call()
780 return &client->recv_buffer; in alts_handshaker_client_get_recv_buffer_addr_for_testing()
[all …]
Dalts_tsi_handshaker_private.h66 grpc_byte_buffer* recv_buffer, bool inject_read_failure);
/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_handshaker_client.cc78 grpc_byte_buffer* recv_buffer = nullptr; member
139 grpc_byte_buffer_destroy(client->recv_buffer); in alts_grpc_handshaker_client_unref()
141 client->recv_buffer = nullptr; in alts_grpc_handshaker_client_unref()
204 grpc_byte_buffer* recv_buffer = client->recv_buffer; in alts_handshaker_client_handle_response() local
236 if (recv_buffer == nullptr) { in alts_handshaker_client_handle_response()
247 alts_tsi_utils_deserialize_response(recv_buffer, arena.ptr()); in alts_handshaker_client_handle_response()
248 grpc_byte_buffer_destroy(client->recv_buffer); in alts_handshaker_client_handle_response()
249 client->recv_buffer = nullptr; in alts_handshaker_client_handle_response()
353 op->data.recv_message.recv_message = &client->recv_buffer; in continue_make_grpc_call()
782 return &client->recv_buffer; in alts_handshaker_client_get_recv_buffer_addr_for_testing()
[all …]
Dalts_tsi_handshaker_private.h66 grpc_byte_buffer* recv_buffer, bool inject_read_failure);
/external/grpc-grpc/test/cpp/cocoapods/generic/
Dgeneric.mm206 ByteBuffer recv_buffer;
207 stream.Read(&recv_buffer, tag(5));
209 XCTAssertTrue(byte_buffer_eq_string(&recv_buffer, "hello world"));
211 send_buffer = std::unique_ptr<ByteBuffer>(new ByteBuffer(recv_buffer));
219 recv_buffer.Clear();
220 call->Read(&recv_buffer, tag(8));
222 XCTAssertTrue(byte_buffer_eq_string(&recv_buffer, "hello world"));
/external/grpc-grpc/test/core/tsi/alts/handshaker/
Dalts_tsi_handshaker_test.cc774 grpc_byte_buffer* recv_buffer = grpc_raw_byte_buffer_create(&slice, 1); in TEST() local
779 client, nullptr, on_invalid_input_cb, nullptr, recv_buffer, in TEST()
848 grpc_byte_buffer* recv_buffer = grpc_raw_byte_buffer_create(&slice, 1); in TEST() local
853 client, alts_handshaker, on_failed_grpc_call_cb, nullptr, recv_buffer, in TEST()
885 grpc_byte_buffer* recv_buffer = grpc_raw_byte_buffer_create(&slice, 1); in TEST() local
890 client, alts_handshaker, on_failed_grpc_call_cb, nullptr, recv_buffer, in TEST()
934 grpc_byte_buffer* recv_buffer = generate_handshaker_response(INVALID); in TEST() local
936 client, alts_handshaker, on_invalid_resp_cb, nullptr, recv_buffer, in TEST()
1006 grpc_byte_buffer* recv_buffer = generate_handshaker_response(FAILED); in TEST() local
1008 client, alts_handshaker, on_failed_resp_cb, nullptr, recv_buffer, in TEST()
[all …]
/external/grpc-grpc/test/http2_test/
Dhttp2_base_server.py241 recv_buffer = self._recv_buffer[stream_id]
242 grpc_msg_size = struct.unpack("i", recv_buffer[1:5][::-1])[0]
243 if len(recv_buffer) != _GRPC_HEADER_SIZE + grpc_msg_size:
245 req_proto_str = recv_buffer[5 : 5 + grpc_msg_size]
/external/rust/android-crates-io/crates/grpcio-sys/grpc/test/http2_test/
Dhttp2_base_server.py221 recv_buffer = self._recv_buffer[stream_id]
222 grpc_msg_size = struct.unpack('i', recv_buffer[1:5][::-1])[0]
223 if len(recv_buffer) != _GRPC_HEADER_SIZE + grpc_msg_size:
225 req_proto_str = recv_buffer[5:5 + grpc_msg_size]
/external/tensorflow/tensorflow/compiler/xla/stream_executor/tpu/
Dtpu_stream.h67 stream_executor::DeviceMemoryBase recv_buffer) override { in EnqueueOnTpuDeviceSendRecvLocal() argument
72 ApiConverter::ToC(recv_buffer), status.c_status); in EnqueueOnTpuDeviceSendRecvLocal()
Dtpu_stream_interface.h33 stream_executor::DeviceMemoryBase recv_buffer) = 0;
/external/crosvm/net_util/src/slirp/sys/windows/
Dhandler.rs994 let mut recv_buffer: [u8; 512] = [0; 512]; in test_send_tcp_syn() localVariable
997 unsafe { guest_pipe.read_overlapped(&mut recv_buffer, &mut overlapped_wrapper) }.unwrap(); in test_send_tcp_syn()
1004 for byte in recv_buffer[0..size].iter() { in test_send_tcp_syn()
1014 recv_buffer.copy_within(VETH_HEADER_LENGTH.., 0); in test_send_tcp_syn()
1021 recv_buffer[0..ETH_RESPONSE_HEADER.len()], in test_send_tcp_syn()
1026 assert_eq!(recv_buffer[26..=29], [0x7f, 0x00, 0x00, 0x01]); // 127.0.0.1 in test_send_tcp_syn()
1029 assert_eq!(recv_buffer[30..=33], [0x0A, 0x00, 0x02, 0x0F]); // 10.0.2.15 in test_send_tcp_syn()
1032 assert_eq!(recv_buffer[34..=35], [0x4b, 0xde]); // 19422 in test_send_tcp_syn()
1035 assert_eq!(recv_buffer[36..=37], [0x16, 0x2e]); // 5678 in test_send_tcp_syn()
1038 assert_eq!(recv_buffer[47], 0x12); in test_send_tcp_syn()
/external/grpc-grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/
DViewController.mm68 grpc::ByteBuffer recv_buffer;
69 call->Read(&recv_buffer, tag(3));
88 recv_buffer.Dump(&slices);
/external/webrtc/rtc_base/
Dvirtual_socket_unittest.cc522 char send_buffer[kDataSize], recv_buffer[kDataSize]; in TcpSendTest() local
525 memset(recv_buffer, 0, sizeof(recv_buffer)); in TcpSendTest()
552 result = b->Recv(recv_buffer + recv_pos, 500, nullptr); in TcpSendTest()
567 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos, nullptr); in TcpSendTest()
581 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos, nullptr); in TcpSendTest()
600 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos, nullptr); in TcpSendTest()
615 EXPECT_EQ(0, memcmp(recv_buffer, send_buffer, kDataSize)); in TcpSendTest()
Dsocket_unittest.cc786 rtc::Buffer recv_buffer(0, data_size); in TcpInternal() local
799 while (recv_buffer.size() < send_buffer.size()) { in TcpInternal()
829 while (recv_buffer.size() < sent_size) { in TcpInternal()
850 sent_size - recv_buffer.size()); in TcpInternal()
851 recv_buffer.AppendData(recved_data.data(), recved_size); in TcpInternal()
869 EXPECT_EQ(data_size, recv_buffer.size()); in TcpInternal()
870 EXPECT_EQ(recv_buffer, send_buffer); in TcpInternal()
/external/autotest/server/cros/network/rf_switch/
Drf_mocks.py25 self.recv_buffer = ''

12