Home
last modified time | relevance | path

Searched refs:workStatus (Results 1 - 15 of 15) sorted by relevance

/foundation/resourceschedule/work_scheduler/services/native/src/
H A Dwork_conn_manager.cpp63 bool WorkConnManager::StartWork(shared_ptr<WorkStatus> workStatus) in StartWork() argument
65 if (GetConnInfo(workStatus->workId_)) { in StartWork()
67 workStatus->workId_.c_str(), workStatus->bundleName_.c_str(), workStatus->abilityName_.c_str()); in StartWork()
71 if (!workStatus->workInfo_->GetExtension()) { in StartWork()
77 workStatus->workId_.c_str(), workStatus->bundleName_.c_str(), workStatus->abilityName_.c_str()); in StartWork()
96 workStatus in StartWork()
145 StopWork(shared_ptr<WorkStatus> workStatus, bool isTimeOut) StopWork() argument
181 WriteStartWorkEvent(shared_ptr<WorkStatus> workStatus) WriteStartWorkEvent() argument
[all...]
H A Dwork_policy_manager.cpp95 std::string WorkPolicyManager::GetConditionString(const shared_ptr<WorkStatus> workStatus) in GetConditionString() argument
98 if (workStatus->workInfo_->GetConditionMap()->count(WorkCondition::Type::NETWORK) > 0) { in GetConditionString()
102 if (workStatus->workInfo_->GetConditionMap()->count(WorkCondition::Type::CHARGER) > 0) { in GetConditionString()
106 if (workStatus->workInfo_->GetConditionMap()->count(WorkCondition::Type::BATTERY_STATUS) > 0) { in GetConditionString()
110 if (workStatus->workInfo_->GetConditionMap()->count(WorkCondition::Type::BATTERY_LEVEL) > 0) { in GetConditionString()
114 if (workStatus->workInfo_->GetConditionMap()->count(WorkCondition::Type::STORAGE) > 0) { in GetConditionString()
118 if (workStatus->workInfo_->GetConditionMap()->count(WorkCondition::Type::TIMER) > 0) { in GetConditionString()
122 if (workStatus->workInfo_->GetConditionMap()->count(WorkCondition::Type::DEEP_IDLE) > 0) { in GetConditionString()
129 int32_t WorkPolicyManager::AddWork(shared_ptr<WorkStatus> workStatus, int32_t uid) in AddWork() argument
134 if (uidQueueMap_.at(uid)->Contains(make_shared<string>(workStatus in AddWork()
164 RemoveWork(shared_ptr<WorkStatus> workStatus, int32_t uid) RemoveWork() argument
189 RemoveFromUidQueue(std::shared_ptr<WorkStatus> workStatus, int32_t uid) RemoveFromUidQueue() argument
200 RemoveFromReadyQueue(std::shared_ptr<WorkStatus> workStatus) RemoveFromReadyQueue() argument
205 StopWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid, const bool needCancel, bool isTimeOut) StopWork() argument
263 shared_ptr<WorkStatus> workStatus = uidQueueMap_.at(uid)->Find(workIdStr); IsLastWorkTimeout() local
457 AddWatchdogForWork(std::shared_ptr<WorkStatus> workStatus) AddWatchdogForWork() argument
485 std::shared_ptr<WorkStatus> workStatus = GetWorkFromWatchdog(watchdogId); WatchdogTimeOut() local
523 auto workStatus = queue->Find(string("u") + to_string(uid) + "_" + to_string(workId)); GetWorkStatus() local
726 auto workStatus = it->second; PauseRunningWorks() local
763 auto workStatus = it->second; ResumePausedWorks() local
783 RemoveWatchDog(std::shared_ptr<WorkStatus> workStatus) RemoveWatchDog() argument
[all...]
H A Dwork_queue_manager.cpp50 bool WorkQueueManager::AddWork(shared_ptr<WorkStatus> workStatus) in AddWork() argument
52 if (!workStatus || !workStatus->workInfo_ || !workStatus->workInfo_->GetConditionMap()) { in AddWork()
55 WS_HILOGD("workStatus ID: %{public}s", workStatus->workId_.c_str()); in AddWork()
57 auto map = workStatus->workInfo_->GetConditionMap(); in AddWork()
65 queueMap_.at(it.first)->Push(workStatus); in AddWork()
69 workStatus->workInfo_->SetCallBySystemApp(true); in AddWork()
74 bool WorkQueueManager::RemoveWork(shared_ptr<WorkStatus> workStatus) in RemoveWork() argument
90 CancelWork(shared_ptr<WorkStatus> workStatus) CancelWork() argument
[all...]
H A Dwork_queue.cpp111 void WorkQueue::Push(shared_ptr<WorkStatus> workStatus) in Push() argument
114 if (this->Contains(make_shared<string>(workStatus->workId_))) { in Push()
116 if (it->workId_.compare(workStatus->workId_) == 0) { in Push()
122 workList_.push_back(workStatus); in Push()
125 bool WorkQueue::Remove(shared_ptr<WorkStatus> workStatus) in Remove() argument
128 auto iter = std::find(workList_.cbegin(), workList_.cend(), workStatus); in Remove()
145 (const shared_ptr<WorkStatus> &workStatus) { return workId->compare(workStatus->workId_) == 0; }); in Contains()
156 [&workId](const shared_ptr<WorkStatus> &workStatus) { return workStatus in Find()
168 shared_ptr<WorkStatus> workStatus = nullptr; GetWorkToRunByPriority() local
180 CancelWork(shared_ptr<WorkStatus> workStatus) CancelWork() argument
[all...]
H A Dwork_scheduler_service.cpp620 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in StartWork() local
621 int32_t ret = workPolicyManager_->AddWork(workStatus, uid); in StartWork()
623 workQueueManager_->AddWork(workStatus); in StartWork()
626 workStatus->workInfo_->RefreshUid(uid); in StartWork()
627 persistedMap_.emplace(workStatus->workId_, workStatus->workInfo_); in StartWork()
641 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, workInfo.GetUid()); in AddWorkInner() local
642 if (workPolicyManager_->AddWork(workStatus, workInfo.GetUid()) == ERR_OK) { in AddWorkInner()
643 workQueueManager_->AddWork(workStatus); in AddWorkInner()
662 shared_ptr<WorkStatus> workStatus in StopWork() local
682 shared_ptr<WorkStatus> workStatus = workPolicyManager_->FindWorkStatus(workInfo, uid); StopAndCancelWork() local
696 StopWorkInner(std::shared_ptr<WorkStatus> workStatus, int32_t uid, const bool needCancel, bool isTimeOut) StopWorkInner() argument
705 WatchdogTimeOut(std::shared_ptr<WorkStatus> workStatus) WatchdogTimeOut() argument
[all...]
/foundation/resourceschedule/work_scheduler/services/test/src/
H A Dwork_queue_test.cpp183 std::string bundleName = "com.example.workStatus"; in HWTEST_F()
186 auto workStatus = std::make_shared<WorkStatus>(workInfo_, i); in HWTEST_F() local
187 workVector.push_back(workStatus); in HWTEST_F()
206 std::string bundleName = "com.example.workStatus"; in HWTEST_F()
209 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); in HWTEST_F() local
210 workQueue_->Push(workStatus); in HWTEST_F()
225 std::string bundleName = "com.example.workStatus"; in HWTEST_F()
228 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); in HWTEST_F() local
229 workQueue_->Push(workStatus); in HWTEST_F()
230 workQueue_->Remove(workStatus); in HWTEST_F()
248 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
268 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
288 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
308 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
328 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
349 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
370 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
391 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
412 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
432 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
453 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); HWTEST_F() local
[all...]
H A Dwork_conn_manager_test.cpp126 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F() local
127 bool ret = workConnManager_->StartWork(workStatus); in HWTEST_F()
144 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F() local
145 bool ret = workConnManager_->StartWork(workStatus); in HWTEST_F()
176 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F() local
177 bool ret = workConnManager_->StopWork(workStatus, false); in HWTEST_F()
198 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F() local
199 bool ret = workConnManager_->StopWork(workStatus, false); in HWTEST_F()
219 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F() local
220 workStatus in HWTEST_F()
244 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); HWTEST_F() local
272 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); HWTEST_F() local
[all...]
H A Dwork_policy_manager_test.cpp90 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); in HWTEST_F() local
91 int32_t ret = workPolicyManager_->AddWork(workStatus, uid); in HWTEST_F()
109 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); in HWTEST_F() local
110 workPolicyManager_->AddWork(workStatus, uid); in HWTEST_F()
137 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); in HWTEST_F() local
138 workPolicyManager_->AddWork(workStatus, uid); in HWTEST_F()
165 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); in HWTEST_F() local
166 bool ret = workPolicyManager_->RemoveWork(workStatus, uid); in HWTEST_F()
184 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); in HWTEST_F() local
185 workPolicyManager_->AddWork(workStatus, ui in HWTEST_F()
220 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); HWTEST_F() local
241 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); HWTEST_F() local
264 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); HWTEST_F() local
308 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); HWTEST_F() local
329 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); HWTEST_F() local
352 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); HWTEST_F() local
[all...]
H A Dworkschedulerservice_test.cpp903 std::shared_ptr<WorkStatus> workStatus = nullptr; in HWTEST_F() local
904 workSchedulerService_->UpdateWorkBeforeRealStart(workStatus); in HWTEST_F()
907 workStatus = std::make_shared<WorkStatus>(workInfo, 1); in HWTEST_F()
908 workStatus->conditionMap_.clear(); in HWTEST_F()
909 workSchedulerService_->UpdateWorkBeforeRealStart(workStatus); in HWTEST_F()
913 workStatus->conditionMap_.emplace(WorkCondition::Type::TIMER, repeatCycle); in HWTEST_F()
914 workSchedulerService_->UpdateWorkBeforeRealStart(workStatus); in HWTEST_F()
/foundation/resourceschedule/work_scheduler/services/native/include/
H A Dwork_policy_manager.h61 * @param workStatus The status of work.
65 int32_t AddWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid);
69 * @param workStatus The status of work.
73 bool RemoveWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid);
77 * @param workStatus The status of work.
83 bool StopWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid, const bool needCancel, bool isTimeOut);
264 * @param workStatus The workStatus.
266 void RemoveWatchDog(std::shared_ptr<WorkStatus> workStatus);
279 void RemoveFromUidQueue(std::shared_ptr<WorkStatus> workStatus, int32_
[all...]
H A Dwork_conn_manager.h35 * @param workStatus The status of work.
38 bool StartWork(std::shared_ptr<WorkStatus> workStatus);
42 * @param workStatus The status of work.
46 bool StopWork(std::shared_ptr<WorkStatus> workStatus, bool isTimeOut);
53 void WriteStartWorkEvent(std::shared_ptr<WorkStatus> workStatus);
H A Dwork_queue_manager.h52 * @param workStatus The status of work.
55 bool AddWork(std::shared_ptr<WorkStatus> workStatus);
59 * @param workStatus The status of work.
62 bool RemoveWork(std::shared_ptr<WorkStatus> workStatus);
66 * @param workStatus The status of work.
69 bool CancelWork(std::shared_ptr<WorkStatus> workStatus);
H A Dwork_queue.h56 * @param workStatus The status of work.
58 void Push(std::shared_ptr<WorkStatus> workStatus);
68 * @param workStatus The status of work.
71 bool Remove(std::shared_ptr<WorkStatus> workStatus);
95 * @param workStatus The status of work.
98 bool CancelWork(std::shared_ptr<WorkStatus> workStatus);
H A Dwork_scheduler_service.h183 * @param workStatus The status of work.
185 void WatchdogTimeOut(std::shared_ptr<WorkStatus> workStatus);
295 bool StopWorkInner(std::shared_ptr<WorkStatus> workStatus, int32_t uid, const bool needCancel, bool isTimeOut);
/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() local
331 workConnManager->WriteStartWorkEvent(workStatus); in TriggerWork()

Completed in 9 milliseconds