Home
last modified time | relevance | path

Searched refs:cli_ctx (Results 1 – 20 of 20) sorted by relevance

/third_party/grpc/test/cpp/microbenchmarks/
Dcallback_unary_ping_pong.h39 void SendCallbackUnaryPingPong(benchmark::State* state, ClientContext* cli_ctx, in SendCallbackUnaryPingPong() argument
44 cli_ctx->AddMetadata(kServerMessageSize, std::to_string(response_msgs_size)); in SendCallbackUnaryPingPong()
46 cli_ctx, request, response, in SendCallbackUnaryPingPong()
47 [state, cli_ctx, request, response, stub_, done, mu, cv](Status s) { in SendCallbackUnaryPingPong()
50 cli_ctx->~ClientContext(); in SendCallbackUnaryPingPong()
51 new (cli_ctx) ClientContext(); in SendCallbackUnaryPingPong()
52 SendCallbackUnaryPingPong(state, cli_ctx, request, response, stub_, in SendCallbackUnaryPingPong()
72 ClientContext cli_ctx; in BM_CallbackUnaryPingPong() local
85 SendCallbackUnaryPingPong(&state, &cli_ctx, &request, &response, in BM_CallbackUnaryPingPong()
Dfullstack_streaming_ping_pong.h75 ClientContext cli_ctx; in BM_StreamingPingPong() local
76 ClientContextMutator cli_ctx_mut(&cli_ctx); in BM_StreamingPingPong()
77 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_StreamingPingPong()
167 ClientContext cli_ctx; in BM_StreamingPingPongMsgs() local
168 ClientContextMutator cli_ctx_mut(&cli_ctx); in BM_StreamingPingPongMsgs()
169 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_StreamingPingPongMsgs()
272 ClientContext cli_ctx; in BM_StreamingPingPongWithCoalescingApi() local
273 ClientContextMutator cli_ctx_mut(&cli_ctx); in BM_StreamingPingPongWithCoalescingApi()
274 cli_ctx.set_initial_metadata_corked(true); in BM_StreamingPingPongWithCoalescingApi()
277 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_StreamingPingPongWithCoalescingApi()
Dcallback_streaming_ping_pong.h41 ClientContext* cli_ctx, EchoRequest* request, in BidiClient() argument
45 cli_ctx_{cli_ctx},
131 ClientContext cli_ctx; in BM_CallbackBidiStreaming() local
139 BidiClient test{&state, stub_.get(), &cli_ctx, &request, &response}; in BM_CallbackBidiStreaming()
Dfullstack_streaming_pump.h57 ClientContext cli_ctx; in BM_PumpStreamClientToServer() local
58 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_PumpStreamClientToServer()
126 ClientContext cli_ctx; in BM_PumpStreamServerToClient() local
127 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_PumpStreamServerToClient()
Dfullstack_unary_ping_pong.h77 ClientContext cli_ctx; in BM_UnaryPingPong() local
78 ClientContextMutator cli_ctx_mut(&cli_ctx); in BM_UnaryPingPong()
80 stub->AsyncEcho(&cli_ctx, send_request, fixture->cq())); in BM_UnaryPingPong()
Dbm_fullstack_trickle.cc276 ClientContext cli_ctx; in BM_PumpStreamServerToClient_Trickle() local
277 auto request_rw = stub->AsyncBidiStream(&cli_ctx, fixture->cq(), tag(1)); in BM_PumpStreamServerToClient_Trickle()
390 ClientContext cli_ctx; in BM_PumpUnbalancedUnary_Trickle() local
392 stub->AsyncEcho(&cli_ctx, send_request, fixture->cq())); in BM_PumpUnbalancedUnary_Trickle()
Dbm_call_create.cc144 grpc::ClientContext cli_ctx; in BM_LameChannelCallCreateCpp() local
145 auto reader = stub->AsyncEcho(&cli_ctx, send_request, &cq); in BM_LameChannelCallCreateCpp()
/third_party/grpc/test/cpp/end2end/
Dasync_end2end_test.cc315 ClientContext cli_ctx; in SendRpc() local
321 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
363 ClientContext cli_ctx; in TEST_P() local
374 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in TEST_P()
472 ClientContext cli_ctx; in TEST_P() local
478 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in TEST_P()
513 ClientContext cli_ctx; in TEST_P() local
519 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in TEST_P()
558 ClientContext cli_ctx; in TEST_P() local
564 stub_->AsyncRequestStream(&cli_ctx, &recv_response, cq_.get(), tag(1))); in TEST_P()
[all …]
Dgeneric_end2end_test.cc122 ClientContext cli_ctx; in SendRpc() local
130 cli_ctx.set_deadline(deadline); in SendRpc()
139 generic_stub_->PrepareCall(&cli_ctx, *method_name, &cli_cq_); in SendRpc()
276 ClientContext cli_ctx; in TEST_F() local
287 generic_stub_->PrepareUnaryCall(&cli_ctx, kMethodName, in TEST_F()
334 ClientContext cli_ctx; in TEST_F() local
338 cli_ctx.set_compression_algorithm(GRPC_COMPRESS_GZIP); in TEST_F()
341 generic_stub_->PrepareCall(&cli_ctx, kMethodName, &cli_cq_); in TEST_F()
401 ClientContext cli_ctx; in TEST_F() local
409 cli_ctx.set_deadline(gpr_time_add(gpr_now(GPR_CLOCK_MONOTONIC), in TEST_F()
[all …]
Dserver_interceptors_end2end_test.cc375 ClientContext cli_ctx; in TEST_F() local
380 cli_ctx.AddMetadata("testkey", "testvalue"); in TEST_F()
382 stub->AsyncEcho(&cli_ctx, send_request, cq.get())); in TEST_F()
401 EXPECT_TRUE(CheckMetadata(cli_ctx.GetServerTrailingMetadata(), "testkey", in TEST_F()
448 ClientContext cli_ctx; in TEST_F() local
453 cli_ctx.AddMetadata("testkey", "testvalue"); in TEST_F()
455 cli_stream(stub->AsyncBidiStream(&cli_ctx, cq.get(), tag(1))); in TEST_F()
484 EXPECT_TRUE(CheckMetadata(cli_ctx.GetServerTrailingMetadata(), "testkey", in TEST_F()
531 ClientContext cli_ctx; in TEST_F() local
537 cli_ctx.AddMetadata("testkey", "testvalue"); in TEST_F()
[all …]
Dinterceptors_util.cc105 ClientContext cli_ctx; in MakeAsyncCQCall() local
108 cli_ctx.AddMetadata("testkey", "testvalue"); in MakeAsyncCQCall()
110 stub->AsyncEcho(&cli_ctx, send_request, &cq)); in MakeAsyncCQCall()
127 ClientContext cli_ctx; in MakeAsyncCQServerStreamingCall() local
129 cli_ctx.AddMetadata("testkey", "testvalue"); in MakeAsyncCQServerStreamingCall()
132 stub->AsyncResponseStream(&cli_ctx, send_request, &cq, tag(1))); in MakeAsyncCQServerStreamingCall()
Dclient_callback_end2end_test.cc172 ClientContext cli_ctx; in SendRpcs() local
182 cli_ctx.AddMetadata("custom-bin", val); in SendRpcs()
185 cli_ctx.set_compression_algorithm(GRPC_COMPRESS_GZIP); in SendRpcs()
191 &cli_ctx, &request, &response, in SendRpcs()
192 [&cli_ctx, &request, &response, &done, &mu, &cv, val, in SendRpcs()
199 1u, cli_ctx.GetServerTrailingMetadata().count("custom-bin")); in SendRpcs()
200 EXPECT_EQ(val, ToString(cli_ctx.GetServerTrailingMetadata() in SendRpcs()
223 ClientContext cli_ctx; in SendRpcsRawReq() local
229 &cli_ctx, send_buf.get(), &response, in SendRpcsRawReq()
252 ClientContext cli_ctx; in SendRpcsGeneric() local
[all …]
Dfilter_end2end_test.cc181 ClientContext cli_ctx; in SendRpc() local
188 generic_stub_->PrepareCall(&cli_ctx, kMethodName, &cli_cq_); in SendRpc()
275 ClientContext cli_ctx; in TEST_F() local
279 cli_ctx.set_compression_algorithm(GRPC_COMPRESS_GZIP); in TEST_F()
282 generic_stub_->PrepareCall(&cli_ctx, kMethodName, &cli_cq_); in TEST_F()
Dhybrid_end2end_test.cc332 ClientContext cli_ctx; in SendEcho() local
333 cli_ctx.set_wait_for_ready(true); in SendEcho()
335 Status recv_status = stub_->Echo(&cli_ctx, send_request, &recv_response); in SendEcho()
346 ClientContext cli_ctx; in SendEchoToDupService() local
347 cli_ctx.set_wait_for_ready(true); in SendEchoToDupService()
349 Status recv_status = stub->Echo(&cli_ctx, send_request, &recv_response); in SendEchoToDupService()
358 ClientContext cli_ctx; in SendSimpleClientStreaming() local
359 cli_ctx.set_wait_for_ready(true); in SendSimpleClientStreaming()
361 auto stream = stub_->RequestStream(&cli_ctx, &recv_response); in SendSimpleClientStreaming()
Dnonblocking_test.cc132 ClientContext cli_ctx; in SendRpc() local
138 stub_->PrepareAsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
Dmessage_allocator_end2end_test.cc167 ClientContext cli_ctx; in SendRpcs() local
172 cli_ctx.set_compression_algorithm(GRPC_COMPRESS_GZIP); in SendRpcs()
178 &cli_ctx, &request, &response, in SendRpcs()
/third_party/grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/
DViewController.mm51 grpc::ClientContext cli_ctx;
53 generic_stub_->Call(&cli_ctx, kMethodName, &cq_, tag(1));
/third_party/grpc/test/cpp/cocoapods/generic/
Dgeneric.mm171 ClientContext cli_ctx;
179 cli_ctx.set_deadline(deadline);
183 generic_stub_->Call(&cli_ctx, kMethodName, &cli_cq_, tag(1));
/third_party/grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc189 ClientContext cli_ctx; in UnaryPingPong() local
191 stub->AsyncEcho(&cli_ctx, send_request, fixture->cq())); in UnaryPingPong()
/third_party/python/Lib/test/test_asyncio/
Dtest_sendfile.py256 cli_ctx = test_utils.simple_client_sslcontext()
259 cli_ctx = None
276 ssl=cli_ctx, server_hostname=server_hostname))