Home
last modified time | relevance | path

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

123

/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::__anonf10ab8ac0111::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::__anoncd5f51d80111::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::__anonc60f39430211::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 …]
/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
/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/rust/crates/grpcio-sys/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
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc34 cq_ = server_builder->AddCompletionQueue(); in GrpcEagerServiceImpl()
47 EnqueueRequest(&service_, cq_.get(), \ in HandleRPCsLoop()
64 EnqueueRequest(&service_, cq_.get(), in HandleRPCsLoop()
72 if (!cq_->Next(&tag, &ok)) { in HandleRPCsLoop()
82 cq_->Shutdown(); in HandleRPCsLoop()
93 cq_.get(), gpr_now(GPR_CLOCK_MONOTONIC), nullptr); in Shutdown()
/external/rust/crates/grpcio-sys/grpc/spm-cpp-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.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.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
/external/rust/crates/grpcio-sys/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.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.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
/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/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/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/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/rust/crates/grpcio-sys/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::__anone10e12df0411::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 …]
/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/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/tensorflow/tensorflow/core/tpu/kernels/
Dtpu_compilation_cache_service.cc38 cq_(server_builder_->AddCompletionQueue()), in TpuCompilationCacheService()
53 cq_->Shutdown(); in ~TpuCompilationCacheService()
147 &service_, cq_.get(), in HandleGetTpuProgram()
160 &service_, cq_.get(), in HandleRPCsLoop()
166 while (cq_->Next(&tag, &ok)) { in HandleRPCsLoop()

123