Home
last modified time | relevance | path

Searched refs:recv_response (Results 1 – 15 of 15) sorted by relevance

/third_party/grpc/test/cpp/end2end/
Dasync_end2end_test.cc312 EchoResponse recv_response; in SendRpc() local
326 response_reader->Finish(&recv_response, &recv_status, tag(4)); in SendRpc()
335 EXPECT_EQ(send_response.message(), recv_response.message()); in SendRpc()
360 EchoResponse recv_response; in TEST_P() local
380 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
394 EXPECT_EQ(recv_response.message(), ""); in TEST_P()
469 EchoResponse recv_response; in TEST_P() local
489 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
499 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_P()
510 EchoResponse recv_response; in TEST_P() local
[all …]
Dgeneric_end2end_test.cc119 EchoResponse recv_response; in SendRpc() local
184 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in SendRpc()
189 EXPECT_EQ(send_response.message(), recv_response.message()); in SendRpc()
273 EchoResponse recv_response; in TEST_F() local
317 EXPECT_TRUE(ParseFromByteBuffer(&cli_recv_buffer, &recv_response)); in TEST_F()
318 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
332 EchoResponse recv_response; in TEST_F() local
372 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in TEST_F()
373 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
387 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
Dinterceptors_util.cc103 EchoResponse recv_response; in MakeAsyncCQCall() local
111 response_reader->Finish(&recv_response, &recv_status, tag(1)); in MakeAsyncCQCall()
113 EXPECT_EQ(send_request.message(), recv_response.message()); in MakeAsyncCQCall()
125 EchoResponse recv_response; in MakeAsyncCQServerStreamingCall() local
136 cli_stream->Read(&recv_response, tag(2)); in MakeAsyncCQServerStreamingCall()
138 ASSERT_EQ(recv_response.message(), send_request.message()); in MakeAsyncCQServerStreamingCall()
141 cli_stream->Read(&recv_response, tag(3)); in MakeAsyncCQServerStreamingCall()
Dfilter_end2end_test.cc178 EchoResponse recv_response; in SendRpc() local
224 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in SendRpc()
229 EXPECT_EQ(send_response.message(), recv_response.message()); in SendRpc()
273 EchoResponse recv_response; in TEST_F() local
313 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in TEST_F()
314 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
328 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
Dserver_interceptors_end2end_test.cc372 EchoResponse recv_response; in TEST_F() local
387 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_F()
399 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
445 EchoResponse recv_response; in TEST_F() local
471 cli_stream->Read(&recv_response, tag(6)); in TEST_F()
473 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
528 EchoResponse recv_response; in TEST_F() local
581 EXPECT_TRUE(ParseFromByteBuffer(&recv_buffer, &recv_response)); in TEST_F()
587 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
628 EchoResponse recv_response; in TEST_F() local
[all …]
Dnonblocking_test.cc129 EchoResponse recv_response; in SendRpc() local
141 response_reader->Finish(&recv_response, &recv_status, tag(4)); in SendRpc()
170 EXPECT_EQ(send_response.message(), recv_response.message()); in SendRpc()
Dhybrid_end2end_test.cc331 EchoResponse recv_response; in SendEcho() local
335 Status recv_status = stub_->Echo(&cli_ctx, send_request, &recv_response); in SendEcho()
336 EXPECT_EQ(send_request.message(), recv_response.message()); in SendEcho()
345 EchoResponse recv_response; in SendEchoToDupService() local
349 Status recv_status = stub->Echo(&cli_ctx, send_request, &recv_response); in SendEchoToDupService()
350 EXPECT_EQ(send_request.message() + "_dup", recv_response.message()); in SendEchoToDupService()
356 EchoResponse recv_response; in SendSimpleClientStreaming() local
361 auto stream = stub_->RequestStream(&cli_ctx, &recv_response); in SendSimpleClientStreaming()
368 EXPECT_EQ(expected_message, recv_response.message()); in SendSimpleClientStreaming()
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/eap_peer/
Dmschapv2.c115 u8 recv_response[MSCHAPV2_AUTH_RESPONSE_LEN]; in mschapv2_verify_auth_response() local
118 hexstr2bin((char *) (buf + 2), recv_response, in mschapv2_verify_auth_response()
120 os_memcmp_const(auth_response, recv_response, in mschapv2_verify_auth_response()
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/eap_peer/
Dmschapv2.c115 u8 recv_response[MSCHAPV2_AUTH_RESPONSE_LEN]; in mschapv2_verify_auth_response() local
118 hexstr2bin((char *) (buf + 2), recv_response, in mschapv2_verify_auth_response()
120 os_memcmp_const(auth_response, recv_response, in mschapv2_verify_auth_response()
/third_party/grpc/test/cpp/microbenchmarks/
Dfullstack_streaming_ping_pong.h56 EchoResponse recv_response; in BM_StreamingPingPong() local
96 request_rw->Read(&recv_response, tag(2)); // Start client recv in BM_StreamingPingPong()
149 EchoResponse recv_response; in BM_StreamingPingPongMsgs() local
187 request_rw->Read(&recv_response, tag(2)); // Start client recv in BM_StreamingPingPongMsgs()
253 EchoResponse recv_response; in BM_StreamingPingPongWithCoalescingApi() local
311 request_rw->Read(&recv_response, tag(4)); // Start client recv in BM_StreamingPingPongWithCoalescingApi()
Dfullstack_unary_ping_pong.h46 EchoResponse recv_response; in BM_UnaryPingPong() local
76 recv_response.Clear(); in BM_UnaryPingPong()
81 response_reader->Finish(&recv_response, &recv_status, tag(4)); in BM_UnaryPingPong()
Dbm_fullstack_trickle.cc265 EchoResponse recv_response; in BM_PumpStreamServerToClient_Trickle() local
288 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient_Trickle()
296 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient_Trickle()
326 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient_Trickle()
359 EchoResponse recv_response; in BM_PumpUnbalancedUnary_Trickle() local
389 recv_response.Clear(); in BM_PumpUnbalancedUnary_Trickle()
395 response_reader->Finish(&recv_response, &recv_status, tag(4)); in BM_PumpUnbalancedUnary_Trickle()
Dfullstack_streaming_pump.h115 EchoResponse recv_response; in BM_PumpStreamServerToClient() local
138 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient()
145 request_rw->Read(&recv_response, tag(0)); in BM_PumpStreamServerToClient()
Dbm_call_create.cc140 grpc::testing::EchoResponse recv_response; in BM_LameChannelCallCreateCpp() local
146 reader->Finish(&recv_response, &recv_status, tag(0)); in BM_LameChannelCallCreateCpp()
/third_party/grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc159 EchoResponse recv_response; in UnaryPingPong() local
188 recv_response.Clear(); in UnaryPingPong()
194 response_reader->Finish(&recv_response, &recv_status, tag(4)); in UnaryPingPong()