| /base/request/request/services/src/manage/scheduler/qos/ |
| H A D | apps.rs | 85 tasks: Vec<Task>,
92 tasks: Vec::new(), in new()
96 fn from_raw(uid: u64, tasks: Vec<Task>) -> Self { in from_raw()
97 Self { uid, tasks } in from_raw()
101 self.tasks.is_empty()
105 self.tasks.binary_insert(task) in insert()
110 .tasks in remove()
115 self.tasks.remove(i); in remove()
127 &self.tasks in deref()
191 let mut tasks in reload_all_app_from_database() variables
[all...] |
| H A D | mod.rs | 41 // Only tasks that can run automatically can be added to the qos queue.
103 // Here if the number of all uncompleted tasks is less than `m1 + m2`, in reschedule_inner()
117 for tasks in self.apps.iter().skip(app_i + 1).map(|app| &app[..]) { in reschedule_inner()
118 let task = match tasks.get(i) { in reschedule_inner()
145 // supplement fair position with remaining tasks in reschedule_inner()
|
| /base/hiviewdfx/hiview/plugins/performance/executor/ |
| H A D | ThrTaskContainer.cpp | 43 tasks.push_back(task); in PostTask()
50 if (tasks.size() < maxTaskSize) { in IsTaskOverLimit()
54 for (auto& task: tasks) { in IsTaskOverLimit()
58 tasks.clear(); in IsTaskOverLimit()
67 while (tasks.empty()) { in Entry()
71 ITask* task = tasks.front(); in Entry()
77 tasks.erase(tasks.begin()); in Entry()
|
| H A D | ThrTaskContainer.h | 36 std::vector<ITask*> tasks; member in OHOS::HiviewDFX::ThrTaskContainer
|
| /base/security/device_auth/deps_adapter/os_adapter/impl/src/ |
| H A D | hc_task_thread.c | 32 HcBool ret = thread->tasks.popFront(&thread->tasks, &task);
in PopTask()
49 thread->tasks.pushBack(&thread->tasks, &taskWarp);
in PushTask()
59 FOR_EACH_HC_VECTOR(thread->tasks, index, taskWarp) {
in Clear()
65 thread->tasks.clear(&thread->tasks);
in Clear()
140 thread->tasks = CREATE_HC_VECTOR(TaskVec);
in InitHcTaskThread()
146 DESTROY_HC_VECTOR(TaskVec, &thread->tasks);
in DestroyHcTaskThread()
|
| /base/update/updateservice/services/startup/manage/src/ |
| H A D | startup_schedule.cpp | 74 bool StartupSchedule::OnDemandSchedule(const std::vector<ScheduleTask> &tasks) in OnDemandSchedule() argument
76 if (tasks.empty()) { in OnDemandSchedule()
80 for (const auto &task : tasks) { in OnDemandSchedule()
83 auto isSuccess = SystemAbilityOperator().UpdateStartupPolicy(tasks); in OnDemandSchedule()
|
| H A D | startup_schedule_empty.cpp | 55 bool StartupSchedule::OnDemandSchedule(const std::vector<ScheduleTask> &tasks) in OnDemandSchedule() argument
|
| /base/msdp/device_status/intention/scheduler/task_scheduler/src/ |
| H A D | task_scheduler.cpp | 35 FI_HILOGE("Expired tasks will be discarded, id:%{public}d", id_);
in ProcessTask()
75 std::vector<TaskPtr> tasks;
in ProcessTasks() local
76 PopPendingTaskList(tasks);
in ProcessTasks()
77 for (const auto &it : tasks) {
in ProcessTasks()
116 void TaskScheduler::PopPendingTaskList(std::vector<TaskPtr> &tasks)
in PopPendingTaskList() argument
127 tasks.push_back(firstTask->GetSharedPtr());
in PopPendingTaskList()
|
| /base/msdp/device_status/services/delegate_task/src/ |
| H A D | delegate_tasks.cpp | 74 std::vector<TaskPtr> tasks;
in ProcessTasks() local
75 PopPendingTaskList(tasks);
in ProcessTasks()
76 for (const auto &it : tasks) {
in ProcessTasks()
115 void DelegateTasks::PopPendingTaskList(std::vector<TaskPtr> &tasks)
in PopPendingTaskList() argument
126 tasks.push_back(taskDuty->GetSharedPtr());
in PopPendingTaskList()
|
| /base/update/updateservice/services/startup/manage/include/ |
| H A D | startup_schedule.h | 33 virtual bool OnDemandSchedule(const std::vector<ScheduleTask> &tasks) = 0;
43 bool OnDemandSchedule(const std::vector<ScheduleTask> &tasks) final;
|
| /base/update/updateservice/services/startup/access/src/ |
| H A D | access_manager.cpp | 57 std::vector<ScheduleTask> tasks = access->GetScheduleTasks(); in GetScheduleTasks() local
58 scheduleTasks.insert(scheduleTasks.end(), tasks.begin(), tasks.end()); in GetScheduleTasks()
|
| /base/request/request/services/src/manage/events/ |
| H A D | dump.rs | 20 .tasks()
37 .tasks()
|
| /base/powermgr/power_manager/utils/ffrt/src/ |
| H A D | ffrt_utils.cpp | 32 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask>& tasks, FFRTQueue& queue)
in SubmitQueueTasks() argument
34 if (tasks.empty()) {
in SubmitQueueTasks()
37 for (auto task : tasks) {
in SubmitQueueTasks()
|
| /base/hiviewdfx/hisysevent/interfaces/js/kits/napi/include/ |
| H A D | js_callback_manager.h | 40 void Clear(TaskQueue& tasks);
|
| /base/security/device_auth/deps_adapter/os_adapter/interfaces/ |
| H A D | hc_task_thread.h | 35 TaskVec tasks;
member
|
| /base/hiviewdfx/hisysevent/interfaces/js/kits/napi/src/ |
| H A D | js_callback_manager.cpp | 151 void JsCallbackManager::Clear(TaskQueue& tasks) in Clear() argument
154 swap(empty, tasks); in Clear()
|
| /base/powermgr/power_manager/utils/ffrt/include/ |
| H A D | ffrt_utils.h | 43 * The mutex for FFRT tasks.
68 static void SubmitQueueTasks(const std::vector<FFRTTask>& tasks, FFRTQueue& queue);
|
| /base/msdp/device_status/intention/scheduler/task_scheduler/include/ |
| H A D | task_scheduler.h | 96 void PopPendingTaskList(std::vector<TaskPtr> &tasks);
|
| /base/msdp/device_status/services/delegate_task/include/ |
| H A D | delegate_tasks.h | 98 void PopPendingTaskList(std::vector<TaskPtr> &tasks);
|
| /base/request/request/frameworks/cj/ffi/include/ |
| H A D | cj_request_ffi.h | 186 RequestCArrString tasks; member
|
| /base/request/request/services/src/manage/scheduler/ |
| H A D | mod.rs | 105 pub(crate) fn tasks(&self) -> impl Iterator<Item = &Arc<RequestTask>> {
106 self.running_queue.tasks()
114 info!("reschedule restore all tasks");
115 // Reschedule tasks based on the current `QOS` status.
435 .tasks()
|
| /base/request/request/test/unittest/cpp_test/fwkTest/src/ |
| H A D | request_manager_impl_test.cpp | 710 std::map<std::string, std::shared_ptr<Request>> tasks = RequestManagerImpl::GetInstance()->tasks_; in HWTEST_F() local
711 tasks.erase(taskId); in HWTEST_F()
716 tasks.erase(taskId); in HWTEST_F()
|
| /base/inputmethod/imf/services/src/ |
| H A D | peruser_session.cpp | 1365 int32_t tasks = 0;
1372 tasks = ++restartTasks_;
1374 if (tasks == 1 && !RestartIme()) {
1389 int32_t tasks = 0;
1392 tasks = --restartTasks_;
1394 if (tasks > 0 && !RestartIme()) {
|
| /base/request/request/services/src/manage/scheduler/queue/ |
| H A D | mod.rs | 111 pub(crate) fn tasks(&self) -> impl Iterator<Item = &Arc<RequestTask>> {
144 // We need to decide which tasks need to continue running based on `QosChanges`.
219 // every satisfied tasks in running has been moved, set left tasks to Waiting
|
| /base/request/request/services/src/manage/ |
| H A D | query.rs | 100 .tasks()
|