Searched refs:wss_ (Results 1 – 4 of 4) sorted by relevance
71 if (wss_.expired()) { in Init()76 handler_ = wss_.lock()->GetHandler(); in Init()81 watchdog_ = std::make_shared<Watchdog>(wss_.lock()->GetWorkPolicyManager(), runner); in Init()321 if (wss_.expired()) { in OnPolicyChanged()325 auto service = wss_.lock(); in OnPolicyChanged()374 if (wss_.lock() == nullptr) { in CheckWorkToRun()427 if (wss_.expired()) { in RealStartWork()431 UpdateWatchdogTime(wss_.lock(), topWork); in RealStartWork()433 wss_.lock()->UpdateWorkBeforeRealStart(topWork); in RealStartWork()506 if (wss_.expired()) { in WatchdogTimeOut()[all …]
30 WorkQueueManager::WorkQueueManager(const std::shared_ptr<WorkSchedulerService>& wss) : wss_(wss) in WorkQueueManager()199 auto service = wss_.lock(); in OnConditionChanged()
129 const std::weak_ptr<WorkSchedulerService> wss_; variable
300 const std::weak_ptr<WorkSchedulerService> wss_; variable