Home
last modified time | relevance | path

Searched refs:send_response (Results 1 – 25 of 53) sorted by relevance

123

/external/grpc-grpc/test/cpp/end2end/
Dasync_end2end_test.cc307 EchoResponse send_response; in SendRpc() local
327 send_response.set_message(recv_request.message()); in SendRpc()
328 response_writer.Finish(send_response, Status::OK, tag(3)); in SendRpc()
331 EXPECT_EQ(send_response.message(), recv_response.message()); in SendRpc()
417 EchoResponse send_response; in TEST_P() local
443 send_response.set_message(recv_request.message()); in TEST_P()
444 response_writer.Finish(send_response, Status::OK, tag(3)); in TEST_P()
448 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_P()
458 EchoResponse send_response; in TEST_P() local
487 send_response.set_message(recv_request.message()); in TEST_P()
[all …]
Dgeneric_end2end_test.cc111 EchoResponse send_response; in SendRpc() local
157 send_response.set_message(recv_request.message()); in SendRpc()
158 send_buffer = SerializeToByteBuffer(&send_response); in SendRpc()
174 EXPECT_EQ(send_response.message(), recv_response.message()); in SendRpc()
206 EchoResponse send_response; in TEST_F() local
240 send_response.set_message(recv_request.message()); in TEST_F()
242 SerializeToByteBuffer(&send_response); in TEST_F()
251 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
264 EchoResponse send_response; in TEST_F() local
297 send_response.set_message(recv_request.message()); in TEST_F()
[all …]
Dhybrid_end2end_test.cc65 EchoResponse send_response; in HandleEcho() local
69 send_response.set_message(recv_request.message()); in HandleEcho()
71 send_response.mutable_message()->append("_dup"); in HandleEcho()
73 response_writer.Finish(send_response, Status::OK, tag(2)); in HandleEcho()
91 EchoResponse send_response; in HandleRawEcho() local
92 send_response.set_message(recv_request.message()); in HandleRawEcho()
93 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleRawEcho()
102 EchoResponse send_response; in HandleClientStreaming() local
109 send_response.mutable_message()->append(recv_request.message()); in HandleClientStreaming()
112 srv_stream.Finish(send_response, Status::OK, tag(100)); in HandleClientStreaming()
[all …]
Dfilter_end2end_test.cc166 EchoResponse send_response; in SendRpc() local
201 send_response.set_message(recv_request.message()); in SendRpc()
202 send_buffer = SerializeToByteBuffer(&send_response); in SendRpc()
218 EXPECT_EQ(send_response.message(), recv_response.message()); in SendRpc()
261 EchoResponse send_response; in TEST_F() local
294 send_response.set_message(recv_request.message()); in TEST_F()
295 send_buffer = SerializeToByteBuffer(&send_response); in TEST_F()
303 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
317 EXPECT_EQ(send_response.message(), recv_response.message()); in TEST_F()
Dnonblocking_test.cc118 EchoResponse send_response; in SendRpc() local
143 send_response.set_message(recv_request.message()); in SendRpc()
144 response_writer.Finish(send_response, Status::OK, tag(3)); in SendRpc()
160 EXPECT_EQ(send_response.message(), recv_response.message()); in SendRpc()
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/
D_client_test.py115 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
116 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
118 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
119 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
146 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
147 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
151 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
152 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
221 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
222 rpc.send_response(_application_common.STREAM_STREAM_RESPONSE)
[all …]
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_streaming_ping_pong.h55 EchoResponse send_response; in BM_StreamingPingPong() local
62 send_response.set_message(std::string(msg_size, 'b')); in BM_StreamingPingPong()
106 response_rw.Write(send_response, tag(3)); in BM_StreamingPingPong()
148 EchoResponse send_response; in BM_StreamingPingPongMsgs() local
155 send_response.set_message(std::string(msg_size, 'b')); in BM_StreamingPingPongMsgs()
197 response_rw.Write(send_response, tag(3)); in BM_StreamingPingPongMsgs()
252 EchoResponse send_response; in BM_StreamingPingPongWithCoalescingApi() local
259 send_response.set_message(std::string(msg_size, 'b')); in BM_StreamingPingPongWithCoalescingApi()
326 response_rw.WriteAndFinish(send_response, WriteOptions(), in BM_StreamingPingPongWithCoalescingApi()
330 response_rw.WriteLast(send_response, WriteOptions(), tag(5)); in BM_StreamingPingPongWithCoalescingApi()
[all …]
Dfullstack_unary_ping_pong.h45 EchoResponse send_response; in BM_UnaryPingPong() local
51 send_response.set_message(std::string(state.range(1), 'a')); in BM_UnaryPingPong()
90 senv->response_writer.Finish(send_response, Status::OK, tag(3)); in BM_UnaryPingPong()
Dfullstack_streaming_pump.h114 EchoResponse send_response; in BM_PumpStreamServerToClient() local
117 send_response.set_message(std::string(state.range(0), 'a')); in BM_PumpStreamServerToClient()
141 response_rw.Write(send_response, tag(1)); in BM_PumpStreamServerToClient()
Dbm_fullstack_trickle.cc266 EchoResponse send_response; in BM_PumpStreamServerToClient_Trickle() local
269 send_response.set_message(std::string(state.range(0), 'a')); in BM_PumpStreamServerToClient_Trickle()
293 response_rw.Write(send_response, tag(1)); in BM_PumpStreamServerToClient_Trickle()
360 EchoResponse send_response; in BM_PumpUnbalancedUnary_Trickle() local
366 send_response.set_message(std::string(state.range(1), 'a')); in BM_PumpUnbalancedUnary_Trickle()
403 senv->response_writer.Finish(send_response, Status::OK, tag(3)); in BM_PumpUnbalancedUnary_Trickle()
/external/grpc-grpc/tools/run_tests/python_utils/
Dport_server.py153 self.send_response(200)
160 self.send_response(200)
175 self.send_response(200)
183 self.send_response(200)
197 self.send_response(200)
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/
D_channel_rpc.py42 def send_response(self, response): member in _UnaryStream
43 self._rpc_state.send_response(response)
85 def send_response(self, response): member in _StreamStream
86 self._rpc_state.send_response(response)
/external/swiftshader/third_party/llvm-7.0/llvm/tools/sancov/
Dcoverage-report-server.py131 self.send_response(200)
153 self.send_response(404)
157 self.send_response(200)
176 self.send_response(404)
/external/python/cpython2/Lib/
DSimpleXMLRPCServer.py510 self.send_response(500)
522 self.send_response(200)
546 self.send_response(501, "encoding %r not supported" % encoding)
548 self.send_response(400, "error decoding gzip content")
550 self.send_response(501, "encoding %r not supported" % encoding)
556 self.send_response(404)
DSimpleHTTPServer.py75 self.send_response(301)
99 self.send_response(200)
145 self.send_response(200)
/external/autotest/client/cros/cellular/
Dtest_endpoint.py30 self.send_response(204)
35 self.send_response(200)
/external/selinux/mcstrans/src/
Dmcstransd.c85 send_response(int fd, uint32_t function, char *data, int32_t ret_val) in send_response() function
150 ret = send_response(fd, function, NULL, result); in process_request()
154 ret = send_response(fd, function, out, result); in process_request()
158 ret = send_response(fd, function, out, result); in process_request()
162 ret = send_response(fd, function, out, result); in process_request()
/external/python/cpython3/Lib/xmlrpc/
Dserver.py519 self.send_response(500)
532 self.send_response(200)
556 self.send_response(501, "encoding %r not supported" % encoding)
558 self.send_response(400, "error decoding gzip content")
560 self.send_response(501, "encoding %r not supported" % encoding)
566 self.send_response(404)
921 self.send_response(200)
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc174 EchoResponse send_response; in UnaryPingPong() local
180 send_response.set_message(std::string(response_size, 'a')); in UnaryPingPong()
216 senv->response_writer.Finish(send_response, Status::OK, tag(3)); in UnaryPingPong()
/external/libchrome/mojo/public/cpp/bindings/tests/
Drouter_test_util.cc102 void LazyResponseGenerator::Complete(bool send_response) { in Complete() argument
103 if (send_response) { in Complete()
/external/python/cpython3/Lib/http/
Dserver.py457 self.send_response(code, message)
483 def send_response(self, code, message=None): member in BaseHTTPRequestHandler
680 self.send_response(HTTPStatus.MOVED_PERMANENTLY)
726 self.send_response(HTTPStatus.NOT_MODIFIED)
731 self.send_response(HTTPStatus.OK)
794 self.send_response(HTTPStatus.OK)
1139 self.send_response(HTTPStatus.OK, "Script output follows")
/external/python/cpython3/Lib/test/
Dtest_urllib2_localnet.py142 request_handler.send_response(407, "Proxy Authentication Required")
218 self.send_response(200)
223 self.send_response(401)
234 self.send_response(200)
268 self.send_response(200, "OK")
422 self.send_response(response_code)
/external/autotest/client/cros/update_engine/
Dnano_omaha_devserver.py180 self.send_response(200)
185 self.send_response(500)
/external/autotest/client/site_tests/platform_MetricsUploader/
Dplatform_MetricsUploader.py36 self.send_response(404)
43 self.send_response(200)
/external/python/cpython2/Lib/test/
Dtest_urllib2_localnet.py100 self.send_response(200)
105 self.send_response(401)
184 request_handler.send_response(407, "Proxy Authentication Required")
267 self.send_response(200, "OK")
419 self.send_response(response_code)

123