Searched refs:GetIntrpService (Results 1 – 9 of 9) sorted by relevance
49 vg_.GetIntrpService()->InterruptAll(); in TEST_F()65 vg_.GetIntrpService()->InterruptAll(); in TEST_F()
65 rc = cv.Register(vg.GetIntrpService()); in TEST_F()
57 rc_ = vg->GetIntrpService()->Register(ss.str(), this); in operator ()()143 auto interrupt_svc = MyTaskGroup()->GetIntrpService(); in Join()
33 Status Semaphore::Register(TaskGroup *vg) { return wait_cond_.Register(vg->GetIntrpService()); } in Register()
153 Status rc1 = empty_cv_.Register(vg->GetIntrpService()); in Register()154 Status rc2 = full_cv_.Register(vg->GetIntrpService()); in Register()
39 Status WaitPost::Register(TaskGroup *vg) { return wait_cond_.Register(vg->GetIntrpService()); } in Register()
82 auto svc = vg->GetIntrpService(); in interrupt_all()365 std::shared_ptr<IntrpService> TaskGroup::GetIntrpService() { return intrp_svc_; } in GetIntrpService() function in mindspore::dataset::TaskGroup
154 std::shared_ptr<IntrpService> GetIntrpService();
183 rc = cv_.Register(vg->GetIntrpService()); in Register()