Home
last modified time | relevance | path

Searched refs:WorkStatus (Results 1 – 17 of 17) sorted by relevance

/ohos5.0/foundation/resourceschedule/work_scheduler/services/native/include/
H A Dwork_policy_manager.h65 int32_t AddWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid);
266 void RemoveWatchDog(std::shared_ptr<WorkStatus> workStatus);
273 std::list<std::shared_ptr<WorkStatus>> GetDeepIdleWorks();
284 void RealStartWork(std::shared_ptr<WorkStatus> workStatus);
285 void AddToRunningQueue(std::shared_ptr<WorkStatus> workStatus);
287 std::shared_ptr<WorkStatus> GetWorkToRun();
290 void AddWatchdogForWork(std::shared_ptr<WorkStatus> workStatus);
291 std::shared_ptr<WorkStatus> GetWorkFromWatchdog(uint32_t id);
293 std::shared_ptr<WorkStatus> &topWork);
315 std::map<uint32_t, std::shared_ptr<WorkStatus>> watchdogIdMap_;
[all …]
H A Dwork_queue.h37 std::vector<std::shared_ptr<WorkStatus>> OnConditionChanged(
52 void Push(std::shared_ptr<std::vector<std::shared_ptr<WorkStatus>>> workStatusVector);
58 void Push(std::shared_ptr<WorkStatus> workStatus);
64 std::shared_ptr<WorkStatus> GetWorkToRunByPriority();
71 bool Remove(std::shared_ptr<WorkStatus> workStatus);
85 std::shared_ptr<WorkStatus> Find(std::string workId);
98 bool CancelWork(std::shared_ptr<WorkStatus> workStatus);
104 std::list<std::shared_ptr<WorkStatus>> GetWorkList();
126 std::list<std::shared_ptr<WorkStatus>> GetDeepIdleWorks();
150 std::list<std::shared_ptr<WorkStatus>> workList_;
[all …]
H A Dwork_queue_manager.h55 bool AddWork(std::shared_ptr<WorkStatus> workStatus);
62 bool RemoveWork(std::shared_ptr<WorkStatus> workStatus);
69 bool CancelWork(std::shared_ptr<WorkStatus> workStatus);
85 bool StopAndClearWorks(std::list<std::shared_ptr<WorkStatus>> workList);
121 std::vector<std::shared_ptr<WorkStatus>> GetReayQueue(WorkCondition::Type conditionType,
123 …void PushWork(std::vector<std::shared_ptr<WorkStatus>> &works, std::vector<std::shared_ptr<WorkSta…
H A Dwork_conn_manager.h38 bool StartWork(std::shared_ptr<WorkStatus> workStatus);
46 bool StopWork(std::shared_ptr<WorkStatus> workStatus, bool isTimeOut);
52 void WriteStartWorkEvent(std::shared_ptr<WorkStatus> workStatus);
H A Dwork_status.h30 class WorkStatus {
38 WorkStatus(WorkInfo &workInfo, int32_t uid);
39 ~WorkStatus();
H A Dwork_scheduler_service.h173 void UpdateWorkBeforeRealStart(std::shared_ptr<WorkStatus> work);
179 … void OnConditionReady(std::shared_ptr<std::vector<std::shared_ptr<WorkStatus>>> workStatusVector);
185 void WatchdogTimeOut(std::shared_ptr<WorkStatus> workStatus);
331 …bool StopWorkInner(std::shared_ptr<WorkStatus> workStatus, int32_t uid, const bool needCancel, boo…
/ohos5.0/foundation/resourceschedule/work_scheduler/services/test/src/
H A Dwork_policy_manager_test.cpp58 std::shared_ptr<WorkStatus> topWork = std::make_shared<WorkStatus>(workinfo, uid);
90 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid);
109 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid);
116 std::shared_ptr<WorkStatus> workStatus1 = std::make_shared<WorkStatus>(workinfo1, uid);
145 std::shared_ptr<WorkStatus> workStatus1 = std::make_shared<WorkStatus>(workinfo1, uid);
165 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid);
184 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid);
220 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid);
241 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid);
264 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid);
[all …]
H A Dwork_conn_manager_test.cpp126 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid);
144 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid);
176 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid);
198 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid);
219 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid);
244 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid);
272 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid);
H A Dwork_status_test.cpp35 static std::shared_ptr<WorkStatus> workStatus_;
39 std::shared_ptr<WorkStatus> WorkStatusTest::workStatus_ = nullptr;
152 workStatus_->MarkStatus(WorkStatus::Status::RUNNING);
169 workStatus_->MarkStatus(WorkStatus::Status::WAIT_CONDITION);
185 workStatus_->MarkStatus(WorkStatus::Status::WAIT_CONDITION);
205 workStatus_->MarkStatus(WorkStatus::Status::WAIT_CONDITION);
229 workStatus_->MarkStatus(WorkStatus::Status::WAIT_CONDITION);
245 workStatus_->MarkStatus(WorkStatus::Status::WAIT_CONDITION);
266 workStatus_->MarkStatus(WorkStatus::Status::WAIT_CONDITION);
521 workStatus_->MarkStatus(WorkStatus::Status::REMOVED);
[all …]
H A Dworkschedulerservice_test.cpp895 std::shared_ptr<WorkStatus> workStatus = nullptr;
899 workStatus = std::make_shared<WorkStatus>(workInfo, 1);
/ohos5.0/foundation/resourceschedule/work_scheduler/services/native/src/
H A Dwork_status.cpp76 WorkStatus::WorkStatus(WorkInfo &workInfo, int32_t uid) in WorkStatus() function in OHOS::WorkScheduler::WorkStatus
103 WorkStatus::~WorkStatus() {} in ~WorkStatus()
142 void WorkStatus::MarkTimeout() in MarkTimeout()
152 void WorkStatus::MarkRound() {} in MarkRound()
171 bool WorkStatus::NeedRemove() in NeedRemove()
186 bool WorkStatus::IsSameUser() in IsSameUser()
213 bool WorkStatus::IsReady() in IsReady()
480 bool WorkStatus::IsRunning() in IsRunning()
485 bool WorkStatus::IsPaused() in IsPaused()
495 bool WorkStatus::IsRemoved() in IsRemoved()
[all …]
H A Dwork_queue.cpp31 vector<shared_ptr<WorkStatus>> result; in OnConditionChanged()
111 void WorkQueue::Push(shared_ptr<WorkStatus> workStatus) in Push()
125 bool WorkQueue::Remove(shared_ptr<WorkStatus> workStatus) in Remove()
152 shared_ptr<WorkStatus> WorkQueue::Find(string workId) in Find()
178 shared_ptr<WorkStatus> workStatus = nullptr; in GetWorkToRunByPriority()
197 list<shared_ptr<WorkStatus>> WorkQueue::GetWorkList() in GetWorkList()
215 for (shared_ptr<WorkStatus> work : workList_) { in GetRunningCount()
227 for (shared_ptr<WorkStatus> work : workList_) { in GetRunningWorks()
240 std::list<std::shared_ptr<WorkStatus>> works; in GetDeepIdleWorks()
242 for (shared_ptr<WorkStatus> work : workList_) { in GetDeepIdleWorks()
[all …]
H A Dwork_policy_manager.cpp250 it->MarkStatus(WorkStatus::Status::REMOVED); in StopAndClearWorks()
263 string workIdStr = WorkStatus::MakeWorkId(workId, uid); in IsLastWorkTimeout()
344 WorkStatus::ClearUidLastTimeMap(uid); in OnPolicyChanged()
384 shared_ptr<WorkStatus> topWork = GetWorkToRun(); in CheckWorkToRun()
418 std::shared_ptr<WorkStatus> WorkPolicyManager::GetWorkToRun() in GetWorkToRun()
432 topWork->MarkStatus(WorkStatus::Status::RUNNING); in RealStartWork()
450 std::shared_ptr<WorkStatus> &topWork) in UpdateWatchdogTime()
560 list<shared_ptr<WorkStatus>> allWorks; in GetAllWorkStatus()
691 topWork->MarkStatus(WorkStatus::Status::RUNNING); in TriggerIdeWork()
721 std::list<shared_ptr<WorkStatus>> allWorks; in GetAllIdeWorkStatus()
[all …]
H A Dwork_queue_manager.cpp50 bool WorkQueueManager::AddWork(shared_ptr<WorkStatus> workStatus) in AddWork()
75 bool WorkQueueManager::RemoveWork(shared_ptr<WorkStatus> workStatus) in RemoveWork()
91 bool WorkQueueManager::CancelWork(shared_ptr<WorkStatus> workStatus) in CancelWork()
112 vector<shared_ptr<WorkStatus>> WorkQueueManager::GetReayQueue(WorkCondition::Type conditionType, in GetReayQueue()
115 vector<shared_ptr<WorkStatus>> result; in GetReayQueue()
180 void WorkQueueManager::PushWork(vector<shared_ptr<WorkStatus>> &works, vector<shared_ptr<WorkStatus… in PushWork()
210 …vector<shared_ptr<WorkStatus>> readyWorkVector = strong->GetReayQueue(conditionType, conditionVal); in OnConditionChanged()
215 it->MarkStatus(WorkStatus::Status::CONDITION_READY); in OnConditionChanged()
217 service->OnConditionReady(make_shared<vector<shared_ptr<WorkStatus>>>(readyWorkVector)); in OnConditionChanged()
227 bool WorkQueueManager::StopAndClearWorks(list<shared_ptr<WorkStatus>> workList) in StopAndClearWorks()
H A Dwork_scheduler_service.cpp689 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in StartWork()
710 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, workInfo.GetUid()); in AddWorkInner()
731 shared_ptr<WorkStatus> workStatus = workPolicyManager_->FindWorkStatus(workInfo, uid); in StopWork()
751 shared_ptr<WorkStatus> workStatus = workPolicyManager_->FindWorkStatus(workInfo, uid); in StopAndCancelWork()
765 bool WorkSchedulerService::StopWorkInner(std::shared_ptr<WorkStatus> workStatus, int32_t uid, in StopWorkInner()
777 void WorkSchedulerService::WatchdogTimeOut(std::shared_ptr<WorkStatus> workStatus) in WatchdogTimeOut()
796 list<std::shared_ptr<WorkStatus>> allWorks = workPolicyManager_->GetAllWorkStatus(uid); in StopAndClearWorksByUid()
799 [](std::shared_ptr<WorkStatus> work) { return work->workId_; }); in StopAndClearWorksByUid()
868 void WorkSchedulerService::UpdateWorkBeforeRealStart(std::shared_ptr<WorkStatus> work) in UpdateWorkBeforeRealStart()
1369 std::list<std::shared_ptr<WorkStatus>> works = workPolicyManager_->GetDeepIdleWorks(); in StopDeepIdleWorks()
[all …]
H A Dwork_conn_manager.cpp63 bool WorkConnManager::StartWork(shared_ptr<WorkStatus> workStatus) in StartWork()
146 bool WorkConnManager::StopWork(shared_ptr<WorkStatus> workStatus, bool isTimeOut) in StopWork()
182 void WorkConnManager::WriteStartWorkEvent(shared_ptr<WorkStatus> workStatus) in WriteStartWorkEvent()
/ohos5.0/foundation/resourceschedule/work_scheduler/test/fuzztest/workschedulerstartwork_fuzzer/
H A Dworkschedulerstartwork_fuzzer.cpp330 …std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workInfo, workInfo.GetUid()); in TriggerWork()