Home
last modified time | relevance | path

Searched refs:cq_ (Results 1 – 25 of 41) sorted by relevance

12

/external/grpc-grpc/test/cpp/end2end/
Dasync_end2end_test.cc265 cq_->Shutdown(); in TearDown()
266 while (cq_->Next(&ignored_tag, &ignored_ok)) in TearDown()
282 cq_ = builder.AddCompletionQueue(); in BuildAndStartServer()
317 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
320 cq_.get(), cq_.get(), tag(2)); in SendRpc()
324 Verifier().Expect(2, true).Verify(cq_.get()); in SendRpc()
329 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get()); in SendRpc()
336 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::__anon60ba754e0111::AsyncEnd2endTest
373 cq_->Shutdown(); in TEST_P()
374 while (cq_->Next(&ignored_tag, &ignored_ok)) in TEST_P()
[all …]
Draw_end2end_test.cc112 cq_->Shutdown(); in TearDown()
113 while (cq_->Next(&ignored_tag, &ignored_ok)) in TearDown()
126 cq_ = builder.AddCompletionQueue(); in BuildAndStartServer()
138 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::__anonef537dfa0111::RawEnd2EndTest
177 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get())); in TEST_F()
178 service->RequestEcho(&srv_ctx_, &recv_request_, &response_writer, cq_.get(), in TEST_F()
179 cq_.get(), tag(2)); in TEST_F()
181 Verifier().Expect(2, true).Verify(cq_.get()); in TEST_F()
185 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get()); in TEST_F()
202 stub_->AsyncEcho(&cli_ctx_, send_request_, cq_.get())); in TEST_F()
[all …]
Dnonblocking_test.cc78 auto r = cq_->AsyncNext(tag, ok, gpr_time_0(GPR_CLOCK_REALTIME)); in LoopForTag()
91 cq_->Shutdown(); in TearDown()
104 cq_ = builder.AddCompletionQueue(); in BuildAndStartServer()
128 stub_->PrepareAsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
134 cq_.get(), cq_.get(), tag(2)); in SendRpc()
165 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::__anone80365650211::NonblockingTest
Dthread_stress_test.cc179 cq_ = builder.AddCompletionQueue(); in SetUp()
194 cq_->Shutdown(); in TearDown()
203 while (cq_->Next(&ignored_tag, &ignored_ok)) in TearDown()
212 while (cq_->Next(&tag, &ok)) { in ProcessRpcs()
241 contexts_[i].response_writer.get(), cq_.get(), in RefreshContext()
242 cq_.get(), (void*)static_cast<intptr_t>(i)); in RefreshContext()
254 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::CommonStressTestAsyncServer
338 while (cq_.Next(&ignored_tag, &ignored_ok)) in TearDown()
349 cq_.Shutdown(); in Wait()
365 common_.GetStub()->AsyncEcho(&call->context, request, &cq_); in AsyncSendRpc()
[all …]
Dserver_builder_plugin_test.cc180 cq_ = builder_->AddCompletionQueue(); in StartServer()
198 cq_->Shutdown(); in TearDown()
213 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::ServerBuilderPluginTest
235 while (cq_->Next(&tag, &ok)) in RunCQ()
Dhealth_service_end2end_test.cc147 cq_ = builder.AddCompletionQueue(); in SetUpServer()
155 if (cq_ != nullptr) { in TearDown()
156 cq_->Shutdown(); in TearDown()
224 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::__anon697682d60111::HealthServiceEnd2endTest
260 cq_thread_ = std::thread(LoopCompletionQueue, cq_.get()); in TEST_F()
/external/grpc-grpc/examples/cpp/helloworld/
Dgreeter_async_server.cc44 cq_->Shutdown(); in ~ServerImpl()
59 cq_ = builder.AddCompletionQueue(); in Run()
76 : service_(service), cq_(cq), responder_(&ctx_), status_(CREATE) { in CallData()
91 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_, in Proceed()
97 new CallData(service_, cq_); in Proceed()
120 ServerCompletionQueue* cq_; member in ServerImpl::CallData
142 new CallData(&service_, cq_.get()); in HandleRpcs()
151 GPR_ASSERT(cq_->Next(&tag, &ok)); in HandleRpcs()
157 std::unique_ptr<ServerCompletionQueue> cq_; member in ServerImpl
Dgreeter_async_client2.cc57 stub_->PrepareAsyncSayHello(&call->context, request, &cq_); in SayHello()
76 while (cq_.Next(&got_tag, &ok)) { in AsyncCompleteRpc()
118 CompletionQueue cq_; member in GreeterClient
/external/grpc-grpc/src/cpp/common/
Dcompletion_queue_cc.cc36 : GrpcLibraryCodegen(false), cq_(take) { in CompletionQueue()
49 grpc_completion_queue_shutdown(cq_); in CompleteAvalanching()
56 auto ev = grpc_completion_queue_next(cq_, deadline, nullptr); in AsyncNextInternal()
76 : cq_(cq), flushed_(false) { in CompletionQueueTLSCache()
77 grpc_completion_queue_thread_local_cache_init(cq_->cq_); in CompletionQueueTLSCache()
88 if (grpc_completion_queue_thread_local_cache_flush(cq_->cq_, &res_tag, in Flush()
Dalarm.cc39 AlarmImpl() : cq_(nullptr), tag_(nullptr) { in AlarmImpl()
45 if (cq_ != nullptr) { in ~AlarmImpl()
46 GRPC_CQ_INTERNAL_UNREF(cq_, "alarm"); in ~AlarmImpl()
57 cq_ = cq->cq(); in Set()
59 GPR_ASSERT(grpc_cq_begin_op(cq_, this)); in Set()
66 alarm->cq_, alarm, error, in Set()
111 grpc_completion_queue* cq_; member in grpc::internal::AlarmImpl
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dsync_stream.h192 cq_.Pluck(&ops); /// status ignored in WaitForInitialMetadata()
214 return cq_.Pluck(&ops) && ops.got_message; in Read()
227 GPR_CODEGEN_ASSERT(cq_.Pluck(&ops)); in Finish()
234 CompletionQueue cq_; variable
245 cq_(grpc_completion_queue_attributes{ in ClientReader()
248 call_(channel->CreateCall(method, context, &cq_)) {
259 cq_.Pluck(&ops);
309 cq_.Pluck(&ops); // status ignored in WaitForInitialMetadata()
339 return cq_.Pluck(&ops); in Write()
346 return cq_.Pluck(&ops); in WritesDone()
[all …]
Dcompletion_queue.h111 g_core_codegen_interface->grpc_completion_queue_destroy(cq_); in ~CompletionQueue()
234 grpc_completion_queue* cq() { return cq_; } in cq()
239 cq_ = g_core_codegen_interface->grpc_completion_queue_create( in CompletionQueue()
291 CompletionQueue* cq_;
303 cq_, tag, deadline, nullptr); in Pluck()
323 cq_, tag, deadline, nullptr); in TryPluck()
338 cq_, tag, deadline, nullptr); in TryPluck()
363 grpc_completion_queue* cq_; // owned variable
/external/grpc-grpc/src/cpp/server/
Dserver_cc.cc108 cq_(cq) {} in UnimplementedAsyncRequest()
117 ServerCompletionQueue* const cq_; member in grpc::Server::UnimplementedAsyncRequest
151 cq_(nullptr) { in SyncRequest()
162 void SetupRequest() { cq_ = grpc_completion_queue_create_for_pluck(nullptr); } in SetupRequest()
165 grpc_completion_queue_destroy(cq_); in TeardownRequest()
166 cq_ = nullptr; in TeardownRequest()
170 GPR_ASSERT(cq_ && !in_flight_); in Request()
176 has_request_payload_ ? &request_payload_ : nullptr, cq_, in Request()
187 &request_metadata_, cq_, notify_cq, in Request()
197 grpc_completion_queue_destroy(cq_); in FinalizeResult()
[all …]
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_fixtures.h82 cq_ = b.AddCompletionQueue(true); in FullstackFixture()
100 grpc_server_shutdown_and_notify(server_->c_server(), cq_->cq(), in ~FullstackFixture()
102 cq_->Shutdown(); in ~FullstackFixture()
105 while (cq_->Next(&tag, &ok)) { in ~FullstackFixture()
116 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
121 std::unique_ptr<ServerCompletionQueue> cq_; variable
179 cq_ = b.AddCompletionQueue(true); in EndpointPairFixture()
229 grpc_server_shutdown_and_notify(server_->c_server(), cq_->cq(), in ~EndpointPairFixture()
231 cq_->Shutdown(); in ~EndpointPairFixture()
234 while (cq_->Next(&tag, &ok)) { in ~EndpointPairFixture()
[all …]
/external/grpc-grpc/test/cpp/util/
Dcli_call.cc64 call_ = stub_->PrepareCall(&ctx_, method, &cq_); in CliCall()
68 cq_.Next(&got_tag, &ok); in CliCall()
85 cq_.Next(&got_tag, &ok); in Write()
97 if (!cq_.Next(&got_tag, &ok) || !ok) { in Read()
119 cq_.Next(&got_tag, &ok); in WritesDone()
154 bool cq_result = cq_.Next(&got_tag, &ok); in ReadAndMaybeNotifyWrite()
162 cq_result = cq_.Next(&got_tag, &ok); in ReadAndMaybeNotifyWrite()
174 cq_.Next(&got_tag, &ok); in ReadAndMaybeNotifyWrite()
203 cq_.Next(&got_tag, &ok); in Finish()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc32 cq_ = server_builder->AddCompletionQueue(); in GrpcEagerServiceImpl()
41 EnqueueRequest(&service_, cq_.get(), \ in HandleRPCsLoop()
58 if (!cq_->Next(&tag, &ok)) { in HandleRPCsLoop()
68 cq_->Shutdown(); in HandleRPCsLoop()
79 cq_.get(), gpr_now(GPR_CLOCK_MONOTONIC), nullptr); in Shutdown()
Dgrpc_eager_client.cc34 : stub_(channel), cq_(cq) {} in GrpcEagerClient()
42 &stub_, cq_, "/tensorflow.eager.EagerService/" #method, *request, \
58 ::grpc::CompletionQueue* cq_;
/external/grpc-grpc/test/cpp/qps/
Dclient_async.cc77 cq_(nullptr), in ClientRpcContextUnaryImpl()
93 response_reader_ = prepare_req_(stub_, &context_, req_, cq_); in RunNextState()
121 CompletionQueue* cq_; member in grpc::testing::ClientRpcContextUnaryImpl
139 cq_ = cq; in StartInternal()
144 alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this)); in StartInternal()
178 cq_.emplace_back(i % cli_cqs_.size()); in AsyncClient()
247 while (cli_cqs_[cq_[thread_idx]]->Next(&tag, &ok)) { in ProcessTag()
263 if (!cli_cqs_[cq_[thread_idx]]->Next(&got_tag, &ok)) { in ThreadFunc()
273 while (cli_cqs_[cq_[thread_idx]]->DoThenAsyncNext( in ThreadFunc()
278 ctx->StartNewClone(cli_cqs_[cq_[thread_idx]].get()); in ThreadFunc()
[all …]
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service.cc32 cq_ = builder->AddCompletionQueue().release(); in GrpcVerbsService()
37 delete cq_; in ~GrpcVerbsService()
52 new ::grpc::Alarm(cq_, gpr_now(GPR_CLOCK_MONOTONIC), nullptr); in Shutdown()
73 EnqueueRequest(&verbs_service_, cq_, \
89 while (cq_->Next(&tag, &ok)) { in HandleRPCsLoop()
95 cq_->Shutdown(); in HandleRPCsLoop()
/external/grpc-grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/
DViewController.mm35 grpc::CompletionQueue cq_; field
53 generic_stub_->Call(&cli_ctx, kMethodName, &cq_, tag(1));
54 cq_.Next(&got_tag, &ok);
62 cq_.Next(&got_tag, &ok);
69 cq_.Next(&got_tag, &ok);
77 cq_.Next(&got_tag, &ok);
/external/grpc-grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.cc34 : cq_(std::move(cq)) { in LoadReporterAsyncServiceImpl()
52 cq_->Shutdown(); in ~LoadReporterAsyncServiceImpl()
70 next_fetch_and_sample_alarm_->Set(cq_.get(), next_fetch_and_sample_time, in ScheduleNextFetchAndSample()
94 ReportLoadHandler::CreateAndStart(service->cq_.get(), service, in Work()
99 if (!service->cq_->Next(&tag, &ok)) { in Work()
141 : cq_(cq), in ReportLoadHandler()
165 CreateAndStart(cq_, service_, load_reporter_); in OnRequestDelivered()
270 next_report_alarm_->Set(cq_, next_report_time, &next_outbound_); in ScheduleNextReport()
/external/grpc-grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc59 cq_ = grpc_completion_queue_create_for_next(nullptr); in Start()
60 grpc_server_register_completion_queue(server_, cq_, nullptr); in Start()
75 grpc_completion_queue_destroy(cq_); in Shutdown()
83 cq_, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in Serve()
89 grpc_completion_queue* cq_ = nullptr; member in grpc_core::test::__anon707ef09f0111::ServerThread
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service.cc56 cq_ = builder->AddCompletionQueue(); in GrpcMasterService()
76 new ::grpc::Alarm(cq_.get(), gpr_now(GPR_CLOCK_MONOTONIC), nullptr); in Shutdown()
97 EnqueueRequest(&master_service_, cq_.get(), \
122 while (cq_->Next(&tag, &ok)) { in HandleRPCsLoop()
130 cq_->Shutdown(); in HandleRPCsLoop()
137 std::unique_ptr<::grpc::ServerCompletionQueue> cq_; member in tensorflow::GrpcMasterService
Dgrpc_state.h59 cq_(cq), in RPCState()
93 stub_->PrepareUnaryCall(context_.get(), method_, request_buf_, cq_)); in StartCall()
165 ::grpc::CompletionQueue* cq_;
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc80 cq_ = b.AddCompletionQueue(true); in EndpointPairFixture()
127 cq_->Shutdown(); in ~EndpointPairFixture()
130 while (cq_->Next(&tag, &ok)) { in ~EndpointPairFixture()
134 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
139 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::EndpointPairFixture

12