Home
last modified time | relevance | path

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

/external/grpc-grpc/test/cpp/end2end/
Dfilter_end2end_test.cc195 ByteBuffer recv_buffer; in SendRpc() local
196 stream.Read(&recv_buffer, tag(5)); in SendRpc()
198 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in SendRpc()
210 recv_buffer.Clear(); in SendRpc()
211 call->Read(&recv_buffer, tag(8)); in SendRpc()
213 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in SendRpc()
288 ByteBuffer recv_buffer; in TEST_F() local
289 srv_stream.Read(&recv_buffer, tag(4)); in TEST_F()
291 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in TEST_F()
300 cli_stream->Read(&recv_buffer, tag(6)); in TEST_F()
[all …]
Dgeneric_end2end_test.cc151 ByteBuffer recv_buffer; in SendRpc() local
152 stream.Read(&recv_buffer, tag(5)); in SendRpc()
154 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in SendRpc()
166 recv_buffer.Clear(); in SendRpc()
167 call->Read(&recv_buffer, tag(8)); in SendRpc()
169 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in SendRpc()
291 ByteBuffer recv_buffer; in TEST_F() local
292 srv_stream.Read(&recv_buffer, tag(4)); in TEST_F()
294 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in TEST_F()
303 cli_stream->Read(&recv_buffer, tag(6)); in TEST_F()
[all …]
Dhybrid_end2end_test.cc85 ByteBuffer recv_buffer; in HandleRawEcho() local
86 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, in HandleRawEcho()
90 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in HandleRawEcho()
119 ByteBuffer recv_buffer; in HandleRawClientStreaming() local
128 srv_stream.Read(&recv_buffer, tag(i)); in HandleRawClientStreaming()
132 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in HandleRawClientStreaming()
164 ByteBuffer recv_buffer; in HandleGenericEcho() local
165 stream->Read(&recv_buffer, tag(2)); in HandleGenericEcho()
168 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_request)); in HandleGenericEcho()
180 ByteBuffer recv_buffer; in HandleGenericRequestStream() local
[all …]
/external/grpc-grpc/test/core/tsi/alts/handshaker/
Dalts_tsi_handshaker_test.cc327 event->recv_buffer = generate_handshaker_response(CLIENT_START); in mock_client_start()
351 event->recv_buffer = generate_handshaker_response(SERVER_START); in mock_server_start()
387 event->recv_buffer = generate_handshaker_response(CLIENT_NEXT); in mock_next()
389 event->recv_buffer = generate_handshaker_response(SERVER_NEXT); in mock_next()
589 grpc_byte_buffer recv_buffer; in check_handle_response_invalid_input() local
591 alts_tsi_handshaker_handle_response(nullptr, &recv_buffer, GRPC_STATUS_OK, in check_handle_response_invalid_input()
599 alts_tsi_handshaker_handle_response(alts_handshaker, &recv_buffer, in check_handle_response_invalid_input()
603 alts_tsi_handshaker_handle_response(alts_handshaker, &recv_buffer, in check_handle_response_invalid_input()
632 grpc_byte_buffer* recv_buffer = generate_handshaker_response(INVALID); in check_handle_response_invalid_resp() local
633 alts_tsi_handshaker_handle_response(alts_handshaker, recv_buffer, in check_handle_response_invalid_resp()
[all …]
Dalts_handshaker_client_test.cc129 ok &= (op->data.recv_message.recv_message == &event->recv_buffer); in validate_op()
/external/grpc-grpc/test/cpp/util/
Dcli_call.cc94 grpc::ByteBuffer recv_buffer; in Read() local
95 call_->Read(&recv_buffer, tag(3)); in Read()
101 GPR_ASSERT(recv_buffer.Dump(&slices).ok()); in Read()
151 grpc::ByteBuffer recv_buffer; in ReadAndMaybeNotifyWrite() local
153 call_->Read(&recv_buffer, tag(3)); in ReadAndMaybeNotifyWrite()
185 GPR_ASSERT(recv_buffer.Dump(&slices).ok()); in ReadAndMaybeNotifyWrite()
/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/http2_test/
Dhttp2_base_server.py190 recv_buffer = self._recv_buffer[stream_id]
191 grpc_msg_size = struct.unpack('i',recv_buffer[1:5][::-1])[0]
192 if len(recv_buffer) != _GRPC_HEADER_SIZE + grpc_msg_size:
194 req_proto_str = recv_buffer[5:5+grpc_msg_size]
/external/grpc-grpc/src/core/tsi/alts/handshaker/
Dalts_tsi_event.cc58 alts_tsi_handshaker_handle_response(event->handshaker, event->recv_buffer, in alts_tsi_event_dispatch_to_handshaker()
68 grpc_byte_buffer_destroy(event->recv_buffer); in alts_tsi_event_destroy()
Dalts_tsi_handshaker.h77 grpc_byte_buffer* recv_buffer,
Dalts_tsi_event.h46 grpc_byte_buffer* recv_buffer; member
Dalts_tsi_handshaker.cc405 grpc_byte_buffer* recv_buffer, in alts_tsi_handshaker_handle_response() argument
416 if (handshaker == nullptr || recv_buffer == nullptr) { in alts_tsi_handshaker_handle_response()
439 alts_tsi_utils_deserialize_response(recv_buffer); in alts_tsi_handshaker_handle_response()
Dalts_handshaker_client.cc71 op->data.recv_message.recv_message = &event->recv_buffer; in make_grpc_call()
/external/grpc-grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/
DViewController.mm67 grpc::ByteBuffer recv_buffer;
68 call->Read(&recv_buffer, tag(3));
87 recv_buffer.Dump(&slices);
/external/ppp/pppd/plugins/radius/
Dsendserver.c211 char recv_buffer[BUFFER_LEN]; in rc_send_server() local
329 length = recvfrom (sockfd, (char *) recv_buffer, in rc_send_server()
330 (int) sizeof (recv_buffer), in rc_send_server()
342 recv_auth = (AUTH_HDR *)recv_buffer; in rc_send_server()
/external/webrtc/webrtc/base/
Dvirtualsocket_unittest.cc503 char send_buffer[kDataSize], recv_buffer[kDataSize]; in TcpSendTest() local
506 memset(recv_buffer, 0, sizeof(recv_buffer)); in TcpSendTest()
533 result = b->Recv(recv_buffer + recv_pos, 500); in TcpSendTest()
548 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); in TcpSendTest()
562 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); in TcpSendTest()
581 result = b->Recv(recv_buffer + recv_pos, kDataSize - recv_pos); in TcpSendTest()
596 EXPECT_EQ(0, memcmp(recv_buffer, send_buffer, kDataSize)); in TcpSendTest()
Dsocket_unittest.cc681 scoped_ptr<char[]> recv_buffer(new char[kDataSize]); in TcpInternal() local
685 recv_buffer[i] = 0; in TcpInternal()
752 int rcvd = client->Recv(recv_buffer.get() + recv_pos, in TcpInternal()
785 EXPECT_EQ(0, memcmp(recv_buffer.get(), send_buffer.get(), kDataSize)); in TcpInternal()
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
Dnccl_all_reduce_thunk.cc291 void* recv_buffer = participant.destination_data.opaque(); in DoAllReduce() local
292 ncclResult_t result = ncclAllReduce(send_buffer, recv_buffer, in DoAllReduce()
/external/autotest/server/cros/network/rf_switch/
Drf_mocks.py25 self.recv_buffer = ''