| /third_party/grpc/test/cpp/end2end/ |
| D | async_end2end_test.cc | 316 ServerContext srv_ctx; in SendRpc() local
317 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc()
323 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
364 ServerContext srv_ctx; in TEST_P() local
365 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
376 srv_ctx.AsyncNotifyWhenDone(tag(5)); in TEST_P()
377 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), in TEST_P()
397 EXPECT_FALSE(srv_ctx.IsCancelled()); in TEST_P()
473 ServerContext srv_ctx; in TEST_P() local
474 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_P()
[all …]
|
| D | generic_end2end_test.cc | 123 GenericServerContext srv_ctx; in SendRpc() local
124 GenericServerAsyncReaderWriter stream(&srv_ctx); in SendRpc()
154 generic_service_.RequestCall(&srv_ctx, &stream, srv_cq_.get(), in SendRpc()
158 EXPECT_EQ(server_host_, srv_ctx.host().substr(0, server_host_.length())); in SendRpc()
159 EXPECT_EQ(kMethodName, srv_ctx.method()); in SendRpc()
162 EXPECT_TRUE(gpr_time_similar(deadline, srv_ctx.raw_deadline(), in SendRpc()
277 GenericServerContext srv_ctx; in TEST_F() local
278 GenericServerAsyncReaderWriter stream(&srv_ctx); in TEST_F()
294 generic_service_.RequestCall(&srv_ctx, &stream, srv_cq_.get(), in TEST_F()
298 EXPECT_EQ(server_host_, srv_ctx.host().substr(0, server_host_.length())); in TEST_F()
[all …]
|
| D | filter_end2end_test.cc | 182 GenericServerContext srv_ctx; in SendRpc() local
183 GenericServerAsyncReaderWriter stream(&srv_ctx); in SendRpc()
200 generic_service_.RequestCall(&srv_ctx, &stream, srv_cq_.get(), in SendRpc()
204 EXPECT_EQ(server_host_, srv_ctx.host().substr(0, server_host_.length())); in SendRpc()
205 EXPECT_EQ(kMethodName, srv_ctx.method()); in SendRpc()
276 GenericServerContext srv_ctx; in TEST_F() local
277 GenericServerAsyncReaderWriter srv_stream(&srv_ctx); in TEST_F()
286 generic_service_.RequestCall(&srv_ctx, &srv_stream, srv_cq_.get(), in TEST_F()
290 EXPECT_EQ(server_host_, srv_ctx.host().substr(0, server_host_.length())); in TEST_F()
291 EXPECT_EQ(kMethodName, srv_ctx.method()); in TEST_F()
|
| D | hybrid_end2end_test.cc | 69 ServerContext srv_ctx; in HandleEcho() local
70 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in HandleEcho()
73 service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq, in HandleEcho()
90 ServerContext srv_ctx; in HandleRawEcho() local
91 GenericServerAsyncResponseWriter response_writer(&srv_ctx); in HandleRawEcho()
93 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, in HandleRawEcho()
107 ServerContext srv_ctx; in HandleClientStreaming() local
110 ServerAsyncReader<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in HandleClientStreaming()
111 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleClientStreaming()
125 ServerContext srv_ctx; in HandleRawClientStreaming() local
[all …]
|
| D | server_interceptors_end2end_test.cc | 376 ServerContext srv_ctx; in TEST_F() local
377 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in TEST_F()
384 service.RequestEcho(&srv_ctx, &recv_request, &response_writer, cq.get(), in TEST_F()
392 EXPECT_TRUE(CheckMetadata(srv_ctx.client_metadata(), "testkey", "testvalue")); in TEST_F()
393 srv_ctx.AddTrailingMetadata("testkey", "testvalue"); in TEST_F()
449 ServerContext srv_ctx; in TEST_F() local
450 grpc::ServerAsyncReaderWriter<EchoResponse, EchoRequest> srv_stream(&srv_ctx); in TEST_F()
457 service.RequestBidiStream(&srv_ctx, &srv_stream, cq.get(), cq.get(), tag(2)); in TEST_F()
461 EXPECT_TRUE(CheckMetadata(srv_ctx.client_metadata(), "testkey", "testvalue")); in TEST_F()
462 srv_ctx.AddTrailingMetadata("testkey", "testvalue"); in TEST_F()
[all …]
|
| D | nonblocking_test.cc | 133 ServerContext srv_ctx; in SendRpc() local
134 grpc::ServerAsyncResponseWriter<EchoResponse> response_writer(&srv_ctx); in SendRpc()
143 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, in SendRpc()
|
| D | thread_stress_test.cc | 242 contexts_[i].srv_ctx.reset(new ServerContext); in RefreshContext()
245 contexts_[i].srv_ctx.get())); in RefreshContext()
246 service_.RequestEcho(contexts_[i].srv_ctx.get(), in RefreshContext()
253 std::unique_ptr<ServerContext> srv_ctx; member
|
| /third_party/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(),
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_sendfile.py | 255 srv_ctx = test_utils.simple_server_sslcontext()
258 srv_ctx = None
263 lambda: srv_proto, sock=srv_sock, ssl=srv_ctx))
|