Home
last modified time | relevance | path

Searched refs:send_request (Results 1 – 25 of 31) sorted by relevance

12

/external/grpc-grpc/test/cpp/end2end/
Dasync_end2end_test.cc305 EchoRequest send_request; in SendRpc() local
315 send_request.set_message(GetParam().message_content); in SendRpc()
317 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
325 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
415 EchoRequest send_request; in TEST_P() local
425 send_request.set_message(GetParam().message_content); in TEST_P()
427 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in TEST_P()
441 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_P()
456 EchoRequest send_request; in TEST_P() local
466 send_request.set_message(GetParam().message_content); in TEST_P()
[all …]
Dgeneric_end2end_test.cc109 EchoRequest send_request; in SendRpc() local
120 send_request.set_message("Hello world. Hello world. Hello world."); in SendRpc()
131 SerializeToByteBuffer(&send_request); in SendRpc()
155 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
204 EchoRequest send_request; in TEST_F() local
215 send_request.set_message("Hello world. Hello world. Hello world."); in TEST_F()
218 SerializeToByteBuffer(&send_request); in TEST_F()
238 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_F()
262 EchoRequest send_request; in TEST_F() local
272 send_request.set_message("Hello"); in TEST_F()
[all …]
Dfilter_end2end_test.cc164 EchoRequest send_request; in SendRpc() local
175 send_request.set_message("Hello world. Hello world. Hello world."); in SendRpc()
181 SerializeToByteBuffer(&send_request); in SendRpc()
199 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
259 EchoRequest send_request; in TEST_F() local
269 send_request.set_message("Hello"); in TEST_F()
283 SerializeToByteBuffer(&send_request); in TEST_F()
292 EXPECT_EQ(send_request.message(), recv_request.message()); in TEST_F()
Dnonblocking_test.cc116 EchoRequest send_request; in SendRpc() local
126 send_request.set_message("hello non-blocking world"); in SendRpc()
128 stub_->PrepareAsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
141 EXPECT_EQ(send_request.message(), recv_request.message()); in SendRpc()
Dhybrid_end2end_test.cc292 EchoRequest send_request; in SendEcho() local
296 send_request.set_message("Hello"); in SendEcho()
297 Status recv_status = stub_->Echo(&cli_ctx, send_request, &recv_response); in SendEcho()
298 EXPECT_EQ(send_request.message(), recv_response.message()); in SendEcho()
306 EchoRequest send_request; in SendEchoToDupService() local
310 send_request.set_message("Hello"); in SendEchoToDupService()
311 Status recv_status = stub->Echo(&cli_ctx, send_request, &recv_response); in SendEchoToDupService()
312 EXPECT_EQ(send_request.message() + "_dup", recv_response.message()); in SendEchoToDupService()
317 EchoRequest send_request; in SendSimpleClientStreaming() local
322 send_request.set_message("Hello"); in SendSimpleClientStreaming()
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_server_test.py62 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
63 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
64 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
75 rpc.send_request(_application_common.STREAM_STREAM_REQUEST)
81 rpc.send_request(_application_common.STREAM_STREAM_REQUEST)
82 rpc.send_request(_application_common.STREAM_STREAM_REQUEST)
141 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
142 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
143 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
147 rpc.send_request(_application_common.STREAM_UNARY_REQUEST)
[all …]
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_streaming_ping_pong.h57 EchoRequest send_request; in BM_StreamingPingPong() local
61 send_request.set_message(std::string(msg_size, 'a')); in BM_StreamingPingPong()
94 request_rw->Write(send_request, tag(0)); // Start client send in BM_StreamingPingPong()
150 EchoRequest send_request; in BM_StreamingPingPongMsgs() local
154 send_request.set_message(std::string(msg_size, 'a')); in BM_StreamingPingPongMsgs()
185 request_rw->Write(send_request, tag(0)); // Start client send in BM_StreamingPingPongMsgs()
254 EchoRequest send_request; in BM_StreamingPingPongWithCoalescingApi() local
258 send_request.set_message(std::string(msg_size, 'a')); in BM_StreamingPingPongWithCoalescingApi()
287 request_rw->WriteLast(send_request, WriteOptions(), tag(2)); in BM_StreamingPingPongWithCoalescingApi()
289 request_rw->Write(send_request, tag(2)); // Start client send in BM_StreamingPingPongWithCoalescingApi()
Dfullstack_unary_ping_pong.h44 EchoRequest send_request; in BM_UnaryPingPong() local
48 send_request.set_message(std::string(state.range(0), 'a')); in BM_UnaryPingPong()
80 stub->AsyncEcho(&cli_ctx, send_request, fixture->cq())); in BM_UnaryPingPong()
Dfullstack_streaming_pump.h45 EchoRequest send_request; in BM_PumpStreamClientToServer() local
48 send_request.set_message(std::string(state.range(0), 'a')); in BM_PumpStreamClientToServer()
72 request_rw->Write(send_request, tag(1)); in BM_PumpStreamClientToServer()
Dbm_call_create.cc139 grpc::testing::EchoRequest send_request; in BM_LameChannelCallCreateCpp() local
145 auto reader = stub->AsyncEcho(&cli_ctx, send_request, &cq); in BM_LameChannelCallCreateCpp()
168 grpc::testing::EchoRequest send_request; in BM_LameChannelCallCreateCore() local
170 grpc_slice_new(&send_request, sizeof(send_request), do_nothing); in BM_LameChannelCallCreateCore()
242 grpc::testing::EchoRequest send_request; in BM_LameChannelCallCreateCoreSeparateBatch() local
244 grpc_slice_new(&send_request, sizeof(send_request), do_nothing); in BM_LameChannelCallCreateCoreSeparateBatch()
Dbm_fullstack_trickle.cc359 EchoRequest send_request; in BM_PumpUnbalancedUnary_Trickle() local
363 send_request.set_message(std::string(state.range(0), 'a')); in BM_PumpUnbalancedUnary_Trickle()
394 stub->AsyncEcho(&cli_ctx, send_request, fixture->cq())); in BM_PumpUnbalancedUnary_Trickle()
/external/grpc-grpc/src/python/grpcio_tests/tests/qps/
Dbenchmark_client.py81 def send_request(self): member in BenchmarkClient
104 def send_request(self): member in UnarySyncBenchmarkClient
122 def send_request(self): member in UnaryAsyncBenchmarkClient
149 def send_request(self): member in _SyncStream
187 def send_request(self): member in StreamingSyncBenchmarkClient
189 self._streams[self._curr_stream].send_request()
Dclient_runner.py64 self._client.send_request()
81 self._client.send_request()
90 client.send_request()
/external/curl/tests/libtest/
Dlibauthretry.c30 static CURLcode send_request(CURL *curl, const char *url, int seq, in send_request() function
61 return send_request(curl, url, seq, auth_scheme, "testuser:wrongpass"); in send_wrong_password()
67 return send_request(curl, url, seq, auth_scheme, "testuser:testpass"); in send_right_password()
/external/python/cpython2/Demo/sockets/
Dgopher.py51 def send_request(selector, host, port): function
59 f = send_request(selector, host, port)
95 f = send_request(selector, host, port)
114 f = send_request(selector, host, port)
121 f = send_request(selector, host, port)
/external/autotest/client/cros/netprotos/
Dcros_p2p.py108 ts = self._zeroconf.send_request([(self._p2p_domain, dpkt.dns.DNS_PTR)])
127 self._zeroconf.send_request(queries)
144 self._zeroconf.send_request(queries)
/external/selinux/libselinux/src/
Dsetrans_client.c81 send_request(int fd, uint32_t function, const char *data1, const char *data2) in send_request() function
188 ret = send_request(fd, RAW_TO_TRANS_CONTEXT, raw, NULL); in raw_to_trans_context()
213 ret = send_request(fd, TRANS_TO_RAW_CONTEXT, trans, NULL); in trans_to_raw_context()
237 ret = send_request(fd, RAW_CONTEXT_TO_COLOR, raw, NULL); in raw_context_to_color()
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/
D_server_rpc.py59 def send_request(self, request): member in StreamUnaryServerRpc
80 def send_request(self, request): member in StreamStreamServerRpc
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc173 EchoRequest send_request; in UnaryPingPong() local
177 send_request.set_message(std::string(request_size, 'a')); in UnaryPingPong()
207 stub->AsyncEcho(&cli_ctx, send_request, fixture->cq())); in UnaryPingPong()
/external/webrtc/webrtc/base/
Dhttpserver_unittest.cc60 bool send_request) { in CreateClientConnection() argument
67 if (send_request) { in CreateClientConnection()
/external/ltp/testcases/kernel/device-drivers/tbio/tbio_kernel/
Dltp_tbio.c77 static int send_request(struct request_queue *q, struct bio *bio, in send_request() function
170 send_request(q, bio, bdev, &inter, writing); in tbio_io()
351 send_request(q, &(bio_pairp->bio1), bdev, &inter, writing); in test_bio_split()
353 send_request(q, &(bio_pairp->bio2), bdev, &inter, writing); in test_bio_split()
/external/libpcap/
Dpcap-dlpi.c174 static int send_request(int, char *, int, char *, char *);
921 if (send_request(fd, (char *)&req, sizeof(req), "attach", ebuf) < 0)
992 if (send_request(p->fd, (char *)&req, sizeof(req), "promiscon",
1133 send_request(int fd, char *ptr, int len, char *what, char *ebuf) function
1450 return (send_request(fd, (char *)&req, sizeof(req), "bind", ebuf));
1475 return (send_request(fd, (char *)&req, sizeof(req), "info", ebuf));
1498 if (send_request(fd, (char *)&req, sizeof(req), "dlpassive", ebuf) == 0)
1627 if (send_request(fd, (char *)&req, sizeof(req), "hpppa", ebuf) < 0)
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
D__init__.py401 def send_request(self, request): member in StreamUnaryServerRpc
452 def send_request(self, request): member in StreamStreamServerRpc
/external/autotest/client/common_lib/cros/bluetooth/
Dbluetooth_sdp_socket.py116 def send_request(self, code, tid, data, forced_pdu_size=None): member in BluetoothSDPSocket
187 self.send_request(req_code, req_tid, req_data, forced_pdu_size)
/external/autotest/client/site_tests/peerd_AdvertiseServices/
Dpeerd_AdvertiseServices.py124 self._zc_listener.send_request(desired_records)

12