Home
last modified time | relevance | path

Searched refs:callback_cq_ (Results 1 – 6 of 6) sorted by relevance

/third_party/grpc/src/cpp/client/
Dchannel_cc.cc58 if (callback_cq_ != nullptr) { in ~Channel()
59 callback_cq_->Shutdown(); in ~Channel()
240 if (callback_cq_ == nullptr) { in CallbackCQ()
242 callback_cq_ = new ::grpc::CompletionQueue(grpc_completion_queue_attributes{ in CallbackCQ()
247 shutdown_callback->TakeCQ(callback_cq_); in CallbackCQ()
249 return callback_cq_; in CallbackCQ()
/third_party/grpc/src/cpp/server/
Dserver_cc.cc975 if (callback_cq_ != nullptr) { in ~Server()
976 callback_cq_->Shutdown(); in ~Server()
977 callback_cq_ = nullptr; in ~Server()
1279 if (callback_cq_ != nullptr) { in ShutdownInternal()
1280 callback_cq_->Shutdown(); in ShutdownInternal()
1281 callback_cq_ = nullptr; in ShutdownInternal()
1349 if (callback_cq_ != nullptr) { in CallbackCQ()
1350 return callback_cq_; in CallbackCQ()
1353 callback_cq_ = new grpc::CompletionQueue(grpc_completion_queue_attributes{ in CallbackCQ()
1358 shutdown_callback->TakeCQ(callback_cq_); in CallbackCQ()
[all …]
/third_party/grpc/include/grpcpp/
Dchannel.h117 ::grpc::CompletionQueue* callback_cq_ = nullptr;
Dchannel_impl.h121 ::grpc_impl::CompletionQueue* callback_cq_ = nullptr;
Dserver.h381 CompletionQueue* callback_cq_ /* GUARDED_BY(mu_) */ = nullptr; variable
Dserver_impl.h376 CompletionQueue* callback_cq_ /* GUARDED_BY(mu_) */ = nullptr; variable