Home
last modified time | relevance | path

Searched refs:WorkStatus (Results 1 - 18 of 18) sorted by relevance

/foundation/resourceschedule/work_scheduler/services/native/include/
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();
149 std::list<std::shared_ptr<WorkStatus>> workList
[all...]
H A Dwork_policy_manager.h65 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 isTimeOut);
107 std::shared_ptr<WorkStatus> FindWorkStatus(WorkInfo& workInfo, int32_t uid);
113 void OnConditionReady(std::shared_ptr<std::vector<std::shared_ptr<WorkStatus>>> workStatusVector);
142 std::list<std::shared_ptr<WorkStatus>> GetAllWorkStatus(int32_t &uid);
266 void RemoveWatchDog(std::shared_ptr<WorkStatus> workStatus);
273 std::list<std::shared_ptr<WorkStatus>> GetDeepIdleWorks();
279 void RemoveFromUidQueue(std::shared_ptr<WorkStatus> workStatus, int32_t uid);
280 void RemoveFromReadyQueue(std::shared_ptr<WorkStatus> workStatu
[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<WorkStatus>> &result);
H A Dwork_conn_manager.h38 bool StartWork(std::shared_ptr<WorkStatus> workStatus);
46 bool StopWork(std::shared_ptr<WorkStatus> workStatus, bool isTimeOut);
53 void WriteStartWorkEvent(std::shared_ptr<WorkStatus> workStatus);
H A Dwork_status.h30 class WorkStatus { class
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);
295 bool StopWorkInner(std::shared_ptr<WorkStatus> workStatus, int32_t uid, const bool needCancel, bool isTimeOut);
/foundation/resourceschedule/work_scheduler/services/native/src/
H A Dwork_status.cpp38 std::map<int32_t, time_t> WorkStatus::s_uid_last_time_map;
43 ffrt::mutex WorkStatus::s_uid_last_time_mutex;
60 WorkStatus::WorkStatus(WorkInfo &workInfo, int32_t uid) in WorkStatus() function in OHOS::WorkScheduler::WorkStatus
87 WorkStatus::~WorkStatus() {} in ~WorkStatus()
89 int32_t WorkStatus::OnConditionChanged(WorkCondition::Type &type, shared_ptr<Condition> value) in OnConditionChanged()
124 string WorkStatus::MakeWorkId(int32_t workId, int32_t uid) in MakeWorkId()
129 void WorkStatus::MarkTimeout() in MarkTimeout()
134 void WorkStatus
[all...]
H A Dwork_queue.cpp27 vector<shared_ptr<WorkStatus>> WorkQueue::OnConditionChanged(WorkCondition::Type type, in OnConditionChanged()
31 vector<shared_ptr<WorkStatus>> result; in OnConditionChanged()
50 it->MarkStatus(WorkStatus::Status::WAIT_CONDITION); in OnConditionChanged()
102 void WorkQueue::Push(shared_ptr<vector<shared_ptr<WorkStatus>>> workStatusVector) in Push()
111 void WorkQueue::Push(shared_ptr<WorkStatus> workStatus) in Push()
125 bool WorkQueue::Remove(shared_ptr<WorkStatus> workStatus) in Remove()
145 (const shared_ptr<WorkStatus> &workStatus) { return workId->compare(workStatus->workId_) == 0; }); in Contains()
152 shared_ptr<WorkStatus> WorkQueue::Find(string workId) in Find()
156 [&workId](const shared_ptr<WorkStatus> &workStatus) { return workStatus->workId_ == workId; }); in Find()
163 shared_ptr<WorkStatus> WorkQueu
[all...]
H A Dwork_policy_manager.cpp95 std::string WorkPolicyManager::GetConditionString(const shared_ptr<WorkStatus> workStatus) in GetConditionString()
129 int32_t WorkPolicyManager::AddWork(shared_ptr<WorkStatus> workStatus, int32_t uid) in AddWork()
164 bool WorkPolicyManager::RemoveWork(shared_ptr<WorkStatus> workStatus, int32_t uid) in RemoveWork()
179 shared_ptr<WorkStatus> WorkPolicyManager::FindWorkStatus(WorkInfo& workInfo, int32_t uid) in FindWorkStatus()
184 return uidQueueMap_.at(uid)->Find(WorkStatus::MakeWorkId(workInfo.GetWorkId(), uid)); in FindWorkStatus()
189 void WorkPolicyManager::RemoveFromUidQueue(std::shared_ptr<WorkStatus> workStatus, int32_t uid) in RemoveFromUidQueue()
200 void WorkPolicyManager::RemoveFromReadyQueue(std::shared_ptr<WorkStatus> workStatus) in RemoveFromReadyQueue()
205 bool WorkPolicyManager::StopWork(std::shared_ptr<WorkStatus> workStatus, int32_t uid, in StopWork()
214 workStatus->MarkStatus(WorkStatus::Status::REMOVED); in StopWork()
222 workStatus->MarkStatus(WorkStatus in StopWork()
[all...]
H A 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()
111 vector<shared_ptr<WorkStatus>> WorkQueueManager::GetReayQueue(WorkCondition::Type conditionType, in GetReayQueue()
114 vector<shared_ptr<WorkStatus>> result; in GetReayQueue()
147 void WorkQueueManager::PushWork(vector<shared_ptr<WorkStatus>> &works, vector<shared_ptr<WorkStatus>> &result) in PushWork()
166 vector<shared_ptr<WorkStatus>> readyWorkVector = GetReayQueue(conditionType, conditionVal); in OnConditionChanged()
171 it->MarkStatus(WorkStatus::Status::CONDITION_READY); in OnConditionChanged()
177 wss_.lock()->OnConditionReady(make_shared<vector<shared_ptr<WorkStatus>>>(readyWorkVecto in OnConditionChanged()
[all...]
H A Dwork_scheduler_service.cpp620 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in StartWork()
641 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, workInfo.GetUid()); in AddWorkInner()
662 shared_ptr<WorkStatus> workStatus = workPolicyManager_->FindWorkStatus(workInfo, uid); in StopWork()
682 shared_ptr<WorkStatus> workStatus = workPolicyManager_->FindWorkStatus(workInfo, uid); in StopAndCancelWork()
696 bool WorkSchedulerService::StopWorkInner(std::shared_ptr<WorkStatus> workStatus, int32_t uid, in StopWorkInner()
705 void WorkSchedulerService::WatchdogTimeOut(std::shared_ptr<WorkStatus> workStatus) in WatchdogTimeOut()
724 list<std::shared_ptr<WorkStatus>> allWorks = workPolicyManager_->GetAllWorkStatus(uid); in StopAndClearWorksByUid()
727 [](std::shared_ptr<WorkStatus> wor in StopAndClearWorksByUid()
[all...]
H A Dwork_conn_manager.cpp63 bool WorkConnManager::StartWork(shared_ptr<WorkStatus> workStatus) in StartWork()
145 bool WorkConnManager::StopWork(shared_ptr<WorkStatus> workStatus, bool isTimeOut) in StopWork()
181 void WorkConnManager::WriteStartWorkEvent(shared_ptr<WorkStatus> workStatus) in WriteStartWorkEvent()
/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); in HWTEST_F()
90 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); in HWTEST_F()
109 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinfo, uid); in HWTEST_F()
116 std::shared_ptr<WorkStatus> workStatus1 = std::make_shared<WorkStatus>(workinfo1, uid); in HWTEST_F()
137 std::shared_ptr<WorkStatus> workStatus = std::make_shared<WorkStatus>(workinf in HWTEST_F()
[all...]
H A Dwork_conn_manager_test.cpp126 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F()
144 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F()
176 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F()
198 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInfo, uid); in HWTEST_F()
219 shared_ptr<WorkStatus> workStatus = make_shared<WorkStatus>(workInf in HWTEST_F()
[all...]
H A Dwork_queue_test.cpp179 vector<std::shared_ptr<WorkStatus>> workVector; in HWTEST_F()
186 auto workStatus = std::make_shared<WorkStatus>(workInfo_, i); in HWTEST_F()
189 std::shared_ptr<vector<std::shared_ptr<WorkStatus>>> workStatusVector = in HWTEST_F()
190 std::make_shared<vector<std::shared_ptr<WorkStatus>>>(workVector); in HWTEST_F()
209 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); in HWTEST_F()
228 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); in HWTEST_F()
248 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); in HWTEST_F()
268 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); in HWTEST_F()
288 auto workStatus = std::make_shared<WorkStatus>(workInfo_, 1); in HWTEST_F()
308 auto workStatus = std::make_shared<WorkStatus>(workInfo in HWTEST_F()
[all...]
H A Dwork_status_test.cpp35 static std::shared_ptr<WorkStatus> workStatus_;
39 std::shared_ptr<WorkStatus> WorkStatusTest::workStatus_ = nullptr;
53 workStatus_ = std::make_shared<WorkStatus>(*(workInfo_.get()), -1); in SetUpTestCase()
58 * @tc.desc: Test WorkStatus MakeWorkId.
70 * @tc.desc: Test WorkStatus IsSameUser.
83 * @tc.desc: Test WorkStatus IsSameUser.
96 * @tc.desc: Test WorkStatus IsUriKeySwitchOn.
111 * @tc.desc: Test WorkStatus IsUriKeySwitchOn.
127 * @tc.desc: Test WorkStatus IsUriKeySwitchOn.
144 * @tc.desc: Test WorkStatus IsRead
[all...]
H A Dworkschedulerservice_test.cpp903 std::shared_ptr<WorkStatus> workStatus = nullptr; in HWTEST_F()
907 workStatus = std::make_shared<WorkStatus>(workInfo, 1); in HWTEST_F()
/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()

Completed in 10 milliseconds