Home
last modified time | relevance | path

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

12

/third_party/grpc/test/cpp/end2end/
Dasync_end2end_test.cc269 cq_->Shutdown(); in TearDown()
270 while (cq_->Next(&ignored_tag, &ignored_ok)) in TearDown()
286 cq_ = builder.AddCompletionQueue(); in BuildAndStartServer()
321 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
324 cq_.get(), cq_.get(), tag(2)); in SendRpc()
328 Verifier().Expect(2, true).Verify(cq_.get()); in SendRpc()
333 Verifier().Expect(3, true).Expect(4, true).Verify(cq_.get()); in SendRpc()
340 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::__anon598b16bd0111::AsyncEnd2endTest
374 stub_->AsyncEcho(&cli_ctx, send_request, cq_.get())); in TEST_P()
377 service_->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq_.get(), 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::__anonb75ef7a90111::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.cc86 auto r = cq_->AsyncNext(tag, ok, gpr_time_0(GPR_CLOCK_REALTIME)); in LoopForTag()
101 cq_->Shutdown(); in TearDown()
114 cq_ = builder.AddCompletionQueue(); in BuildAndStartServer()
138 stub_->PrepareAsyncEcho(&cli_ctx, send_request, cq_.get())); in SendRpc()
144 cq_.get(), cq_.get(), tag(2)); in SendRpc()
175 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::__anonb00edf140211::NonblockingTest
Dthread_stress_test.cc186 cq_ = builder.AddCompletionQueue(); in SetUp()
201 cq_->Shutdown(); in TearDown()
210 while (cq_->Next(&ignored_tag, &ignored_ok)) in TearDown()
219 while (cq_->Next(&tag, &ok)) { in ProcessRpcs()
248 contexts_[i].response_writer.get(), cq_.get(), in RefreshContext()
249 cq_.get(), (void*)static_cast<intptr_t>(i)); in RefreshContext()
261 std::unique_ptr<ServerCompletionQueue> cq_; member in grpc::testing::CommonStressTestAsyncServer
345 while (cq_.Next(&ignored_tag, &ignored_ok)) in TearDown()
356 cq_.Shutdown(); in Wait()
372 common_.GetStub()->AsyncEcho(&call->context, request, &cq_); in AsyncSendRpc()
[all …]
/third_party/grpc/examples/cpp/helloworld/
Dgreeter_async_server.cc48 cq_->Shutdown(); in ~ServerImpl()
63 cq_ = builder.AddCompletionQueue(); in Run()
80 : service_(service), cq_(cq), responder_(&ctx_), status_(CREATE) { in CallData()
95 service_->RequestSayHello(&ctx_, &request_, &responder_, cq_, cq_, in Proceed()
101 new CallData(service_, cq_); in Proceed()
124 ServerCompletionQueue* cq_; member in ServerImpl::CallData
146 new CallData(&service_, cq_.get()); in HandleRpcs()
155 GPR_ASSERT(cq_->Next(&tag, &ok)); in HandleRpcs()
161 std::unique_ptr<ServerCompletionQueue> cq_; member in ServerImpl
Dgreeter_async_client2.cc61 stub_->PrepareAsyncSayHello(&call->context, request, &cq_); in SayHello()
80 while (cq_.Next(&got_tag, &ok)) { in AsyncCompleteRpc()
122 CompletionQueue cq_; member in GreeterClient
/third_party/grpc/src/cpp/common/
Dcompletion_queue_cc.cc36 : GrpcLibraryCodegen(false), cq_(take) { in CompletionQueue()
54 auto ev = grpc_completion_queue_next(cq_, deadline, nullptr); in AsyncNextInternal()
75 : cq_(cq), flushed_(false) { in CompletionQueueTLSCache()
76 grpc_completion_queue_thread_local_cache_init(cq_->cq_); in CompletionQueueTLSCache()
87 if (grpc_completion_queue_thread_local_cache_flush(cq_->cq_, &res_tag, in Flush()
Dalarm.cc40 AlarmImpl() : cq_(nullptr), tag_(nullptr) { in AlarmImpl()
54 cq_ = cq->cq(); in Set()
56 GPR_ASSERT(grpc_cq_begin_op(cq_, this)); in Set()
65 grpc_completion_queue* cq = alarm->cq_; in Set()
66 alarm->cq_ = nullptr; in Set()
123 grpc_completion_queue* cq_; member in grpc::internal::AlarmImpl
/third_party/grpc/include/grpcpp/impl/codegen/
Dcall.h39 cq_(nullptr), in Call()
45 cq_(cq), in Call()
52 cq_(cq), in Call()
60 cq_(cq), in Call()
70 ::grpc::CompletionQueue* cq() const { return cq_; } in cq()
84 ::grpc::CompletionQueue* cq_;
Dsync_stream_impl.h192 cq_.Pluck(&ops); /// status ignored in WaitForInitialMetadata()
215 return cq_.Pluck(&ops) && ops.got_message; in Read()
228 GPR_CODEGEN_ASSERT(cq_.Pluck(&ops)); in Finish()
235 ::grpc_impl::CompletionQueue cq_;
246 cq_(grpc_completion_queue_attributes{ in ClientReader()
249 call_(channel->CreateCall(method, context, &cq_)) {
260 cq_.Pluck(&ops);
311 cq_.Pluck(&ops); // status ignored in WaitForInitialMetadata()
341 return cq_.Pluck(&ops); in Write()
348 return cq_.Pluck(&ops); in WritesDone()
[all …]
Dsync_stream.h192 cq_.Pluck(&ops); /// status ignored in WaitForInitialMetadata()
215 return cq_.Pluck(&ops) && ops.got_message; in Read()
228 GPR_CODEGEN_ASSERT(cq_.Pluck(&ops)); in Finish()
235 ::grpc::CompletionQueue cq_;
246 cq_(grpc_completion_queue_attributes{ in ClientReader()
249 call_(channel->CreateCall(method, context, &cq_)) {
260 cq_.Pluck(&ops);
310 cq_.Pluck(&ops); // status ignored in WaitForInitialMetadata()
340 return cq_.Pluck(&ops); in Write()
347 return cq_.Pluck(&ops); in WritesDone()
[all …]
Dcompletion_queue_impl.h119 ::grpc::g_core_codegen_interface->grpc_completion_queue_destroy(cq_); in ~CompletionQueue()
243 grpc_completion_queue* cq() { return cq_; } in cq()
248 cq_ = ::grpc::g_core_codegen_interface->grpc_completion_queue_create( in CompletionQueue()
308 CompletionQueue* cq_;
321 cq_, tag, deadline, nullptr); in Pluck()
343 cq_, tag, deadline, nullptr); in TryPluck()
359 cq_, tag, deadline, nullptr); in TryPluck()
385 ::grpc::g_core_codegen_interface->grpc_completion_queue_shutdown(cq_); in CompleteAvalanching()
411 grpc_completion_queue* cq_; // owned variable
Dcompletion_queue.h118 ::grpc::g_core_codegen_interface->grpc_completion_queue_destroy(cq_); in ~CompletionQueue()
242 grpc_completion_queue* cq() { return cq_; } in cq()
247 cq_ = ::grpc::g_core_codegen_interface->grpc_completion_queue_create( in CompletionQueue()
309 CompletionQueue* cq_;
322 cq_, tag, deadline, nullptr); in Pluck()
344 cq_, tag, deadline, nullptr); in TryPluck()
360 cq_, tag, deadline, nullptr); in TryPluck()
386 ::grpc::g_core_codegen_interface->grpc_completion_queue_shutdown(cq_); in CompleteAvalanching()
412 grpc_completion_queue* cq_; // owned variable
/third_party/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()
153 bool cq_result = cq_.Next(&got_tag, &ok); in ReadAndMaybeNotifyWrite()
161 cq_result = cq_.Next(&got_tag, &ok); in ReadAndMaybeNotifyWrite()
173 cq_.Next(&got_tag, &ok); in ReadAndMaybeNotifyWrite()
202 cq_.Next(&got_tag, &ok); in Finish()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/
Dgraph_data_server.h110 cq_(cq), in CallData()
128 (async_service_->*enqueue_function_)(&ctx_, &request_, &responder_, cq_, cq_, this); in operator()
130 …RETURN_IF_NOT_OK(EnqueueRequest(service_impl_, async_service_, cq_, enqueue_function_, handle_requ… in operator()
152 grpc::ServerCompletionQueue *cq_; variable
183 ENQUEUE_REQUEST(service_impl_, &svc_, cq_.get(), ClientRegister, GnnClientRegisterRequestPb, in EnqueueRequest()
185 ENQUEUE_REQUEST(service_impl_, &svc_, cq_.get(), ClientUnRegister, GnnClientUnRegisterRequestPb, in EnqueueRequest()
187 …ENQUEUE_REQUEST(service_impl_, &svc_, cq_.get(), GetGraphData, GnnGraphDataRequestPb, GnnGraphData… in EnqueueRequest()
188 …ENQUEUE_REQUEST(service_impl_, &svc_, cq_.get(), GetMetaInfo, GnnMetaInfoRequestPb, GnnMetaInfoRes… in EnqueueRequest()
Dgrpc_async_server.cc38 cq_ = builder.AddCompletionQueue(); in Run()
60 while (cq_->Next(&tag, &success)) { in HandleRequest()
76 if (cq_) { in Stop()
77 cq_->Shutdown(); in Stop()
/third_party/grpc/src/cpp/server/
Dserver_cc.cc152 context_->cq_ = call_cq_; in FinalizeResult()
277 void TakeCQ(CompletionQueue* cq) { cq_ = cq; } in TakeCQ()
283 delete callback->cq_; in Run()
288 CompletionQueue* cq_ = nullptr; member in grpc::__anon2fd9673c0411::ShutdownCallback
348 cq_(nullptr) { in SyncRequest()
359 void SetupRequest() { cq_ = grpc_completion_queue_create_for_pluck(nullptr); } in SetupRequest()
362 grpc_completion_queue_destroy(cq_); in TeardownRequest()
363 cq_ = nullptr; in TeardownRequest()
367 GPR_ASSERT(cq_ && !in_flight_); in Request()
372 has_request_payload_ ? &request_payload_ : nullptr, cq_, in Request()
[all …]
/third_party/grpc/test/cpp/microbenchmarks/
Dfullstack_fixtures.h73 cq_ = b.AddCompletionQueue(true); in FullstackFixture()
89 cq_->Shutdown(); in ~FullstackFixture()
92 while (cq_->Next(&tag, &ok)) { in ~FullstackFixture()
103 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
108 std::unique_ptr<ServerCompletionQueue> cq_; variable
166 cq_ = b.AddCompletionQueue(true); in EndpointPairFixture()
214 cq_->Shutdown(); in ~EndpointPairFixture()
217 while (cq_->Next(&tag, &ok)) { in ~EndpointPairFixture()
228 ServerCompletionQueue* cq() { return cq_.get(); } in cq()
238 std::unique_ptr<ServerCompletionQueue> cq_; variable
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/
Dcache_grpc_server.cc38 if (cq_) { in Shutdown()
39 cq_->Shutdown(); in Shutdown()
42 while (cq_->Next(&tag, &success)) { in Shutdown()
66 cq_ = builder.AddCompletionQueue(); in Run()
95 RETURN_IF_NOT_OK((*p)(&svc_, cq_.get())); in HandleRequest()
99 auto r = cq_->AsyncNext(&tag, &success, deadline); in HandleRequest()
104 RETURN_IF_NOT_OK((*rq)(&svc_, cq_.get())); in HandleRequest()
/third_party/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 …]
/third_party/grpc/test/core/iomgr/
Dstranded_event_test.cc216 cq_ = grpc_completion_queue_create_for_next(nullptr); in TestServer()
220 grpc_server_register_completion_queue(server_, cq_, nullptr); in TestServer()
227 grpc_server_shutdown_and_notify(server_, cq_, nullptr); in ~TestServer()
230 grpc_completion_queue_shutdown(cq_); in ~TestServer()
231 while (grpc_completion_queue_next(cq_, gpr_inf_future(GPR_CLOCK_REALTIME), in ~TestServer()
235 grpc_completion_queue_destroy(cq_); in ~TestServer()
249 server_, &call, &call_details, &request_metadata_recv, cq_, cq_, tag); in AcceptThread()
252 cq_, gpr_inf_future(GPR_CLOCK_REALTIME), nullptr); in AcceptThread()
267 event = grpc_completion_queue_next(cq_, gpr_inf_future(GPR_CLOCK_REALTIME), in AcceptThread()
273 ReceiveMessage(call, cq_); in AcceptThread()
[all …]
/third_party/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);
/third_party/grpc/src/cpp/server/load_reporter/
Dload_reporter_async_service_impl.cc38 : cq_(std::move(cq)) { in LoadReporterAsyncServiceImpl()
56 cq_->Shutdown(); in ~LoadReporterAsyncServiceImpl()
75 next_fetch_and_sample_alarm_->Set(cq_.get(), next_fetch_and_sample_time, in ScheduleNextFetchAndSample()
99 ReportLoadHandler::CreateAndStart(service->cq_.get(), service, in Work()
104 if (!service->cq_->Next(&tag, &ok)) { in Work()
146 : cq_(cq), in ReportLoadHandler()
170 CreateAndStart(cq_, service_, load_reporter_); in OnRequestDelivered()
275 next_report_alarm_->Set(cq_, next_report_time, &next_outbound_); in ScheduleNextReport()
/third_party/grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc61 cq_ = grpc_completion_queue_create_for_next(nullptr); in Start()
62 grpc_server_register_completion_queue(server_, cq_, nullptr); in Start()
77 grpc_completion_queue_destroy(cq_); in Shutdown()
85 cq_, gpr_inf_future(GPR_CLOCK_MONOTONIC), nullptr); in Serve()
91 grpc_completion_queue* cq_ = nullptr; member in grpc_core::test::__anon50662e6e0111::ServerThread
/third_party/grpc/src/cpp/server/health/
Ddefault_health_check_service.cc156 : database_(database), cq_(std::move(cq)) { in HealthCheckServiceImpl()
173 cq_->Shutdown(); in ~HealthCheckServiceImpl()
182 CheckCallHandler::CreateAndStart(cq_.get(), database_, this); in StartServingThread()
183 WatchCallHandler::CreateAndStart(cq_.get(), database_, this); in StartServingThread()
193 if (!service->cq_->Next(&tag, &ok)) { in Serve()
291 : cq_(cq), database_(database), service_(service), writer_(&ctx_) {} in CheckCallHandler()
301 CreateAndStart(cq_, database_, service_); in OnCallReceived()
379 : cq_(cq), database_(database), service_(service), stream_(&ctx_) {} in WatchCallHandler()
395 CreateAndStart(cq_, database_, service_); in OnCallReceived()

12