| /ohos5.0/foundation/resourceschedule/work_scheduler/services/native/src/ |
| H A D | work_conn_manager.cpp | 67 … workStatus->workId_.c_str(), workStatus->bundleName_.c_str(), workStatus->abilityName_.c_str()); in StartWork()
78 … workStatus->workId_.c_str(), workStatus->bundleName_.c_str(), workStatus->abilityName_.c_str()); in StartWork()
97 workStatus->bundleName_.c_str(), workStatus->abilityName_.c_str(), workStatus->userId_); in StartWork()
105 want.SetElementName(workStatus->bundleName_, workStatus->abilityName_); in StartWork()
115 WriteStartWorkEvent(workStatus); in StartWork()
167 workStatus->duration_ += WorkSchedUtils::GetCurrentTimeMs() - workStatus->workStartTime_; in StopWork()
170 … workStatus->uid_, "PID", pid, "NAME", workStatus->bundleName_, "WORKID", workStatus->workId_, in StopWork()
174 workStatus->uid_, workStatus->duration_, workStatus->workStartTime_); in StopWork()
176 workStatus->uid_, workStatus->bundleName_); in StopWork()
218 …workStatus->uid_, "PID", pid, "NAME", workStatus->bundleName_, "WORKID", workStatus->workId_, "TRI… in WriteStartWorkEvent()
[all …]
|
| H A D | work_policy_manager.cpp | 159 …"NAME", workStatus->bundleName_, "WORKID", workStatus->workId_, "TRIGGER", GetConditionString(work… in AddWork()
212 if (workStatus->IsRunning()) { in StopWork()
486 watchId, workStatus->bundleName_.c_str(), workStatus->workId_.c_str(), watchdogTime_); in AddWatchdogForWork()
511 if (workStatus == nullptr) { in WatchdogTimeOut()
516 watchdogId, workStatus->bundleName_.c_str(), workStatus->workId_.c_str()); in WatchdogTimeOut()
752 if (workStatus->uid_ == uid && workStatus->IsRunning()) { in PauseRunningWorks()
756 workStatus->bundleName_.c_str(), workStatus->workId_.c_str()); in PauseRunningWorks()
772 it->first, workStatus->bundleName_.c_str(), workStatus->workId_.c_str(), in PauseRunningWorks()
794 if (workStatus->uid_ == uid && workStatus->IsRunning()) { in ResumePausedWorks()
798 workStatus->bundleName_.c_str(), workStatus->workId_.c_str()); in ResumePausedWorks()
[all …]
|
| H A D | work_queue.cpp | 111 void WorkQueue::Push(shared_ptr<WorkStatus> workStatus) in Push() argument
122 workList_.push_back(workStatus); in Push()
125 bool WorkQueue::Remove(shared_ptr<WorkStatus> workStatus) in Remove() argument
145 … (const shared_ptr<WorkStatus> &workStatus) { return workId->compare(workStatus->workId_) == 0; }); in Contains() argument
156 … [&workId](const shared_ptr<WorkStatus> &workStatus) { return workStatus->workId_ == workId; }); in Find() argument
168 return workStatus->userId_ == userId && workStatus->bundleName_ == bundleName; in Find()
178 shared_ptr<WorkStatus> workStatus = nullptr; in GetWorkToRunByPriority() local
181 workStatus = *work; in GetWorkToRunByPriority()
182 workStatus->priority_++; in GetWorkToRunByPriority()
187 return workStatus; in GetWorkToRunByPriority()
[all …]
|
| H A D | work_queue_manager.cpp | 50 bool WorkQueueManager::AddWork(shared_ptr<WorkStatus> workStatus) in AddWork() argument
52 if (!workStatus || !workStatus->workInfo_ || !workStatus->workInfo_->GetConditionMap()) { in AddWork()
57 auto map = workStatus->workInfo_->GetConditionMap(); in AddWork()
66 queueMap_.at(it.first)->Push(workStatus); in AddWork()
70 workStatus->workInfo_->SetCallBySystemApp(true); in AddWork()
75 bool WorkQueueManager::RemoveWork(shared_ptr<WorkStatus> workStatus) in RemoveWork() argument
79 auto map = workStatus->workInfo_->GetConditionMap(); in RemoveWork()
82 queueMap_.at(it.first)->Remove(workStatus); in RemoveWork()
91 bool WorkQueueManager::CancelWork(shared_ptr<WorkStatus> workStatus) in CancelWork() argument
96 it.second->CancelWork(workStatus); in CancelWork()
[all …]
|
| H A D | work_scheduler_service.cpp | 692 workQueueManager_->AddWork(workStatus); in StartWork()
696 persistedMap_.emplace(workStatus->workId_, workStatus->workInfo_); in StartWork()
732 if (workStatus == nullptr) { in StopWork()
736 StopWorkInner(workStatus, uid, false, false); in StopWork()
752 if (workStatus == nullptr) { in StopAndCancelWork()
756 StopWorkInner(workStatus, uid, true, false); in StopAndCancelWork()
757 if (workStatus->persisted_) { in StopAndCancelWork()
759 persistedMap_.erase(workStatus->workId_); in StopAndCancelWork()
779 StopWorkInner(workStatus, workStatus->uid_, false, true); in WatchdogTimeOut()
1377 workStatus->bundleName_.c_str(), workStatus->workId_.c_str()); in StopDeepIdleWorks()
[all …]
|
| /ohos5.0/foundation/resourceschedule/work_scheduler/services/test/src/ |
| H A D | work_policy_manager_test.cpp | 110 workPolicyManager_->AddWork(workStatus, uid);
138 workPolicyManager_->AddWork(workStatus, uid);
185 workPolicyManager_->AddWork(workStatus, uid);
242 workStatus->MarkStatus(WorkStatus::Status::RUNNING);
243 workStatus->paused_ = true;
265 workStatus->MarkStatus(WorkStatus::Status::RUNNING);
266 workStatus->paused_ = false;
267 workStatus->workStartTime_ = 120000;
331 workStatus->paused_ = false;
354 workStatus->paused_ = true;
[all …]
|
| H A D | work_conn_manager_test.cpp | 126 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); variable
127 bool ret = workConnManager_->StartWork(workStatus);
144 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); variable
145 bool ret = workConnManager_->StartWork(workStatus);
177 bool ret = workConnManager_->StopWork(workStatus, false);
199 bool ret = workConnManager_->StopWork(workStatus, false);
220 workStatus->workId_ = workId;
224 bool ret = myWorkConnManager.StopWork(workStatus, false);
245 workStatus->workId_ = workId;
249 bool ret = myWorkConnManager.StopWork(workStatus, true);
[all …]
|
| H A D | workschedulerservice_test.cpp | 895 std::shared_ptr<WorkStatus> workStatus = nullptr; variable
896 workSchedulerService_->UpdateWorkBeforeRealStart(workStatus);
899 workStatus = std::make_shared<WorkStatus>(workInfo, 1);
900 workStatus->conditionMap_.clear();
901 workSchedulerService_->UpdateWorkBeforeRealStart(workStatus);
905 workStatus->conditionMap_.emplace(WorkCondition::Type::TIMER, repeatCycle);
906 workSchedulerService_->UpdateWorkBeforeRealStart(workStatus);
|
| /ohos5.0/foundation/resourceschedule/work_scheduler/services/native/include/ |
| H A D | work_policy_manager.h | 65 int32_t AddWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid);
73 bool RemoveWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid);
83 …bool StopWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid, const bool needCancel, bool isT…
266 void RemoveWatchDog(std::shared_ptr<WorkStatus> workStatus);
281 void RemoveFromUidQueue(std::shared_ptr<WorkStatus> workStatus, int32_t uid);
282 void RemoveFromReadyQueue(std::shared_ptr<WorkStatus> workStatus);
284 void RealStartWork(std::shared_ptr<WorkStatus> workStatus);
285 void AddToRunningQueue(std::shared_ptr<WorkStatus> workStatus);
290 void AddWatchdogForWork(std::shared_ptr<WorkStatus> workStatus);
298 std::string GetConditionString(const std::shared_ptr<WorkStatus> workStatus);
|
| H A D | work_conn_manager.h | 38 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 D | work_queue.h | 58 void Push(std::shared_ptr<WorkStatus> workStatus);
71 bool Remove(std::shared_ptr<WorkStatus> workStatus);
98 bool CancelWork(std::shared_ptr<WorkStatus> workStatus);
|
| H A D | work_queue_manager.h | 55 bool AddWork(std::shared_ptr<WorkStatus> workStatus);
62 bool RemoveWork(std::shared_ptr<WorkStatus> workStatus);
69 bool CancelWork(std::shared_ptr<WorkStatus> workStatus);
|
| H A D | work_scheduler_service.h | 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/test/fuzztest/workschedulerstartwork_fuzzer/ |
| H A D | workschedulerstartwork_fuzzer.cpp | 330 …std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workInfo, workInfo.GetUid()); in TriggerWork() local
331 workConnManager->WriteStartWorkEvent(workStatus); in TriggerWork()
|