| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/ |
| D | cond_var.cc | 23 CondVar::CondVar() : svc_(nullptr), my_name_(Services::GetUniqueID()) {} in CondVar()
27 if (svc_ != nullptr) { in Wait()
49 if (svc_ != nullptr) { in ~CondVar()
50 (void)svc_->Deregister(my_name_); in ~CondVar()
51 svc_ = nullptr; in ~CondVar()
62 svc_ = svc; in Register()
75 if (svc_) { in Deregister()
76 Status rc = svc_->Deregister(my_name_); in Deregister()
77 svc_ = nullptr; in Deregister()
|
| D | cond_var.h | 52 std::shared_ptr<IntrpService> svc_; variable
|
| /third_party/boost/boost/beast/websocket/detail/ |
| D | service.ipp | 23 : svc_(net::use_service<service>(ctx))
25 std::lock_guard<std::mutex> g(svc_.m_);
26 index_ = svc_.v_.size();
27 svc_.v_.push_back(this);
35 std::lock_guard<std::mutex> g(svc_.m_);
36 auto& other = *svc_.v_.back();
38 svc_.v_[index_] = &other;
39 svc_.v_.pop_back();
|
| D | service.hpp | 31 service& svc_; member in boost::beast::websocket::detail::service::impl_type
|
| /third_party/boost/libs/beast/include/boost/beast/websocket/detail/ |
| D | service.ipp | 23 : svc_(net::use_service<service>(ctx))
25 std::lock_guard<std::mutex> g(svc_.m_);
26 index_ = svc_.v_.size();
27 svc_.v_.push_back(this);
35 std::lock_guard<std::mutex> g(svc_.m_);
36 auto& other = *svc_.v_.back();
38 svc_.v_[index_] = &other;
39 svc_.v_.pop_back();
|
| D | service.hpp | 31 service& svc_; member in boost::beast::websocket::detail::service::impl_type
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/ |
| D | graph_data_server.h | 178 builder->RegisterService(&svc_); in RegisterService()
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()
204 GnnGraphData::AsyncService svc_; variable
|
| /third_party/flutter/engine/flutter/shell/platform/fuchsia/flutter/ |
| D | runner_context.h | 31 const std::shared_ptr<sys::ServiceDirectory>& svc() const { return svc_; } in svc()
59 std::shared_ptr<sys::ServiceDirectory> svc_;
|
| D | component.cc | 125 svc_ = std::make_unique<sys::ServiceDirectory>( in Application()
127 dir = svc_->CloneChannel().TakeChannel(); in Application()
520 if (!svc_) { in CreateView()
530 svc_, // Component incoming services in CreateView()
|
| D | runner_context.cc | 11 : svc_(std::move(svc)), in RunnerContext()
|
| D | component.h | 74 std::shared_ptr<sys::ServiceDirectory> svc_; variable
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_grpc_server.cc | 65 builder.RegisterService(&svc_); in Run()
95 RETURN_IF_NOT_OK((*p)(&svc_, cq_.get())); in HandleRequest()
104 RETURN_IF_NOT_OK((*rq)(&svc_, cq_.get())); in HandleRequest()
|
| D | cache_grpc_server.h | 91 CacheServerGreeter::AsyncService svc_; variable
|