| /external/grpc-grpc/test/cpp/end2end/ |
| D | async_end2end_test.cc | 312 ServerContext srv_ctx; in SendRpc() local
313 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc()
319 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
422 ServerContext srv_ctx; in TEST_P() local
423 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
436 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
463 ServerContext srv_ctx; in TEST_P() local
464 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
479 service_->RequestEcho(&srv_ctx, &recv_request, resp_writer_ptr, cq_.get(), in TEST_P()
508 ServerContext srv_ctx; in TEST_P() local
[all …]
|
| D | generic_end2end_test.cc | 116 GenericServerContext srv_ctx; in SendRpc() local
117 GenericServerAsyncReaderWriter stream(&srv_ctx); in SendRpc()
139 generic_service_.RequestCall(&srv_ctx, &stream, srv_cq_.get(), in SendRpc()
143 EXPECT_EQ(server_host_, srv_ctx.host().substr(0, server_host_.length())); in SendRpc()
144 EXPECT_EQ(kMethodName, srv_ctx.method()); in SendRpc()
147 EXPECT_TRUE(gpr_time_similar(deadline, srv_ctx.raw_deadline(), in SendRpc()
211 GenericServerContext srv_ctx; in TEST_F() local
212 GenericServerAsyncReaderWriter stream(&srv_ctx); in TEST_F()
227 generic_service_.RequestCall(&srv_ctx, &stream, srv_cq_.get(), in TEST_F()
231 EXPECT_EQ(server_host_, srv_ctx.host().substr(0, server_host_.length())); in TEST_F()
[all …]
|
| D | filter_end2end_test.cc | 171 GenericServerContext srv_ctx; in SendRpc() local
172 GenericServerAsyncReaderWriter stream(&srv_ctx); in SendRpc()
189 generic_service_.RequestCall(&srv_ctx, &stream, srv_cq_.get(), in SendRpc()
193 EXPECT_EQ(server_host_, srv_ctx.host().substr(0, server_host_.length())); in SendRpc()
194 EXPECT_EQ(kMethodName, srv_ctx.method()); in SendRpc()
265 GenericServerContext srv_ctx; in TEST_F() local
266 GenericServerAsyncReaderWriter srv_stream(&srv_ctx); in TEST_F()
275 generic_service_.RequestCall(&srv_ctx, &srv_stream, srv_cq_.get(), in TEST_F()
279 EXPECT_EQ(server_host_, srv_ctx.host().substr(0, server_host_.length())); in TEST_F()
280 EXPECT_EQ(kMethodName, srv_ctx.method()); in TEST_F()
|
| D | hybrid_end2end_test.cc | 62 ServerContext srv_ctx; in HandleEcho() local
63 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in HandleEcho()
66 service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq, in HandleEcho()
83 ServerContext srv_ctx; in HandleRawEcho() local
84 GenericServerAsyncResponseWriter response_writer(&srv_ctx); in HandleRawEcho()
86 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, in HandleRawEcho()
100 ServerContext srv_ctx; in HandleClientStreaming() local
103 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in HandleClientStreaming()
104 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleClientStreaming()
118 ServerContext srv_ctx; in HandleRawClientStreaming() local
[all …]
|
| D | nonblocking_test.cc | 123 ServerContext srv_ctx; in SendRpc() local
124 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc()
133 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
|
| D | thread_stress_test.cc | 235 contexts_[i].srv_ctx.reset(new ServerContext); in RefreshContext()
238 contexts_[i].srv_ctx.get())); in RefreshContext()
239 service_.RequestEcho(contexts_[i].srv_ctx.get(), in RefreshContext()
246 std::unique_ptr<ServerContext> srv_ctx; member
|
| /external/grpc-grpc/test/cpp/cocoapods/generic/ |
| D | generic.mm | 172 GenericServerContext srv_ctx;
173 GenericServerAsyncReaderWriter stream(&srv_ctx);
195 generic_service_.RequestCall(&srv_ctx, &stream, srv_cq_.get(), srv_cq_.get(), tag(4));
198 XCTAssertEqual(server_host_, srv_ctx.host().substr(0, server_host_.length()));
199 XCTAssertEqual(kMethodName, srv_ctx.method());
202 XCTAssertTrue(gpr_time_similar(deadline, srv_ctx.raw_deadline(),
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_sendfile.py | 250 srv_ctx = test_utils.simple_server_sslcontext()
253 srv_ctx = None
258 lambda: srv_proto, sock=srv_sock, ssl=srv_ctx))
|