Home
last modified time | relevance | path

Searched defs:workStatus (Results 1 – 5 of 5) sorted by relevance

/foundation/resourceschedule/work_scheduler/services/native/src/
Dwork_queue.cpp102 void WorkQueue::Push(shared_ptr<WorkStatus> workStatus) in Push()
116 bool WorkQueue::Remove(shared_ptr<WorkStatus> workStatus) in Remove()
135 … (const shared_ptr<WorkStatus> &workStatus) { return workId->compare(workStatus->workId_) == 0; }); in Contains()
146 … [&workId](const shared_ptr<WorkStatus> &workStatus) { return workStatus->workId_ == workId; }); in Find()
158 shared_ptr<WorkStatus> workStatus = nullptr; in GetWorkToRunByPriority() local
169 bool WorkQueue::CancelWork(shared_ptr<WorkStatus> workStatus) in CancelWork()
Dwork_conn_manager.cpp60 bool WorkConnManager::StartWork(shared_ptr<WorkStatus> workStatus) in StartWork()
130 bool WorkConnManager::StopWork(shared_ptr<WorkStatus> workStatus) in StopWork()
157 void WorkConnManager::WriteStartWorkEvent(shared_ptr<WorkStatus> workStatus) in WriteStartWorkEvent()
Dwork_policy_manager.cpp90 int32_t WorkPolicyManager::AddWork(shared_ptr<WorkStatus> workStatus, int32_t uid) in AddWork()
151 bool WorkPolicyManager::RemoveWork(shared_ptr<WorkStatus> workStatus, int32_t uid) in RemoveWork()
176 void WorkPolicyManager::RemoveFromUidQueue(std::shared_ptr<WorkStatus> workStatus, int32_t uid) in RemoveFromUidQueue()
187 void WorkPolicyManager::RemoveFromReadyQueue(std::shared_ptr<WorkStatus> workStatus) in RemoveFromReadyQueue()
193 bool WorkPolicyManager::StopWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid, in StopWork()
244 shared_ptr<WorkStatus> workStatus = uidQueueMap_.at(uid)->Find(workIdStr); in IsLastWorkTimeout() local
401 void WorkPolicyManager::AddWatchdogForWork(std::shared_ptr<WorkStatus> workStatus) in AddWatchdogForWork()
422 std::shared_ptr<WorkStatus> workStatus = GetWorkFromWatchdog(watchdogId); in WatchdogTimeOut() local
457 auto workStatus = queue->Find(string("u") + to_string(uid) + "_" + to_string(workId)); in GetWorkStatus() local
Dwork_queue_manager.cpp50 bool WorkQueueManager::AddWork(shared_ptr<WorkStatus> workStatus) in AddWork()
74 bool WorkQueueManager::RemoveWork(shared_ptr<WorkStatus> workStatus) in RemoveWork()
90 bool WorkQueueManager::CancelWork(shared_ptr<WorkStatus> workStatus) in CancelWork()
Dwork_scheduler_service.cpp396 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in StartWork() local
414 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, workInfo.GetUid()); in InitPersistedWork() local
433 shared_ptr<WorkStatus> workStatus = workPolicyManager_->FindWorkStatus(workInfo, uid); in StopWork() local
452 shared_ptr<WorkStatus> workStatus = workPolicyManager_->FindWorkStatus(workInfo, uid); in StopAndCancelWork() local
466 bool WorkSchedulerService::StopWorkInner(std::shared_ptr<WorkStatus> workStatus, int32_t uid, in StopWorkInner()
475 void WorkSchedulerService::WatchdogTimeOut(std::shared_ptr<WorkStatus> workStatus) in WatchdogTimeOut()