| /ohos5.0/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
| H A D | sequential_task_queue.cpp | 48 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in Submit()
55 auto it = std::find(tasks_.begin(), tasks_.end(), afterIdentifier); in SubmitAfter()
56 if (it != tasks_.end()) { in SubmitAfter()
68 auto it = std::find(tasks_.begin(), tasks_.end(), afterIdentifier); in SubmitAfter()
74 tasks_.emplace(tasks_.begin() + (pos + 1), taskIdentifier, std::move(task)); in SubmitAfter()
83 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in SubmitBefore()
85 auto it = std::find(tasks_.begin(), tasks_.end(), beforeIdentifier); in SubmitBefore()
86 if (it != tasks_.end()) { in SubmitBefore()
93 auto it = std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier); in Remove()
95 tasks_.erase(it); in Remove()
[all …]
|
| H A D | dispatcher_task_queue.cpp | 45 auto it = std::find(tasks_.begin(), tasks_.end(), taskIdentifier); in Remove()
46 if (it != tasks_.end()) { in Remove()
47 tasks_.erase(it); in Remove()
57 tasks_.clear(); in Clear()
72 auto it = std::find(tasks_.begin(), tasks_.end(), afterIdentifier); in SubmitAfter()
73 if (it != tasks_.end()) { in SubmitAfter()
85 auto it = std::find(tasks_.begin(), tasks_.end(), afterIdentifier); in SubmitAfter()
86 if (it != tasks_.end()) { in SubmitAfter()
91 tasks_.emplace(tasks_.begin() + (pos + 1), taskIdentifier, move(task)); in SubmitAfter()
106 if (!tasks_.empty()) { in Execute()
[all …]
|
| H A D | parallel_task_queue.cpp | 91 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in Submit()
98 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in SubmitAfter()
100 auto it = std::find(tasks_.begin(), tasks_.end(), afterIdentifier); in SubmitAfter()
101 if (it != tasks_.end()) { in SubmitAfter()
105 tasks_.push_back(std::move(entry)); in SubmitAfter()
130 auto it = std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier); in Remove()
131 if (it != tasks_.cend()) { in Remove()
132 tasks_.erase(it); in Remove()
139 tasks_.clear(); in Clear()
151 Entry& entry = tasks_[*it]; in QueueTasks()
[all …]
|
| /ohos5.0/foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | task_queue.h | 70 for (auto it = tasks_.begin(); it != tasks_.end();) { in META_BEGIN_NAMESPACE()
72 it = tasks_.erase(it); in META_BEGIN_NAMESPACE()
89 if (tasks_.empty()) { in META_BEGIN_NAMESPACE()
91 } else if (tasks_.size() == 1) { in META_BEGIN_NAMESPACE()
95 tasks_.insert(tasks_.begin(), { delay, excTime, BASE_NS::move(p) }); in META_BEGIN_NAMESPACE()
99 for (auto it = tasks_.end() - 1; it >= tasks_.begin(); --it) { in META_BEGIN_NAMESPACE()
109 tasks_.insert(tasks_.begin(), { delay, excTime, BASE_NS::move(p) }); in META_BEGIN_NAMESPACE()
135 while (!terminate_ && !tasks_.empty() && curTime >= tasks_.back().executeTime) { in META_BEGIN_NAMESPACE()
137 tasks_.pop_back(); in META_BEGIN_NAMESPACE()
181 tasks_.clear(); in META_BEGIN_NAMESPACE()
[all …]
|
| /ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | task_queue.cpp | 21 tasks_.emplace_back(taskId); in EnqueueTaskId()
26 auto it = std::find(tasks_.begin(), tasks_.end(), taskId); in EraseWaitingTaskId()
27 if (it != tasks_.end()) { in EraseWaitingTaskId()
28 tasks_.erase(it); in EraseWaitingTaskId()
36 if (!tasks_.empty()) { in DequeueTaskId()
37 uint64_t taskId = tasks_.front(); in DequeueTaskId()
38 tasks_.pop_front(); in DequeueTaskId()
46 return tasks_.empty(); in IsEmpty()
|
| /ohos5.0/base/update/updateservice/services/firmware/upgrade/data_processor/src/ |
| H A D | firmware_install_data_processor.cpp | 48 FirmwareTaskOperator().QueryTask(tasks_); in HasInstallSuccess()
49 FIRMWARE_LOGI("GetTaskStatus status: %{public}d", tasks_.status); in HasInstallSuccess()
50 return tasks_.status == UpgradeStatus::INSTALL_SUCCESS; in HasInstallSuccess()
56 FirmwareTaskOperator().QueryTask(tasks_); in HasUpdateSuccess()
57 FIRMWARE_LOGI("GetTaskStatus status: %{public}d", tasks_.status); in HasUpdateSuccess()
58 return tasks_.status == UpgradeStatus::UPDATE_SUCCESS; in HasUpdateSuccess()
63 if (!tasks_.isExistTask) { in GetTask()
64 FirmwareTaskOperator().QueryTask(tasks_); in GetTask()
65 … FIRMWARE_LOGI("GetTask has task %{public}s", StringUtils::GetBoolStr(tasks_.isExistTask).c_str()); in GetTask()
77 …DelayedSingleton<FirmwareCallbackUtils>::GetInstance()->NotifyEvent(tasks_.taskId, EventId::EVENT_… in SetInstallResult()
[all …]
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/eventlogger/log_catcher/ |
| H A D | event_log_task.cpp | 96 if (tasks_.size() == 0) { in AddLog()
116 if (tasks_.size() == 0) { in StartCompose()
241 tasks_.push_back(capture); in AppStackCapture()
258 tasks_.push_back(capture); in BinderLogCapture()
265 tasks_.push_back(capture); in MemoryUsageCapture()
285 tasks_.push_back(capture); in PeerBinderCapture()
293 tasks_.push_back(capture); in CpuUsageCapture()
300 tasks_.push_back(capture); in WMSUsageCapture()
307 tasks_.push_back(capture); in AMSUsageCapture()
314 tasks_.push_back(capture); in PMSUsageCapture()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | task_scheduler.h | 66 if (tasks_.size() >= capacity_) {
74 auto it = tasks_.insert({ begin, innerTask});
75 if (it == tasks_.begin()) {
97 if (it == tasks_.begin() || index->second == tasks_.begin()) { in Reset()
100 tasks_.erase(index->second); in Reset()
108 tasks_.clear(); in Clean()
126 tasks_.erase(index->second);
158 return !tasks_.empty(); in Loop()
165 auto it = tasks_.begin(); in Loop()
169 tasks_.erase(it); in Loop()
[all …]
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/ |
| H A D | task_board.cpp | 38 [this]() { return tasks_.empty(); }); in WaitForALLTaskFinish()
51 return this->tasks_.empty(); in IsAllTaskFinish()
63 if (this->tasks_.find(task->GetId()) != this->tasks_.end()) { in AddTask()
67 this->tasks_.emplace(task->GetId(), task); in AddTask()
75 if (tasks_.empty()) { in RemoveTask()
82 if (tasks_.find(taskId) == tasks_.end()) { in RemoveTaskInner()
87 tasks_.erase(taskId); in RemoveTaskInner()
93 for (auto t : tasks_) { in DumpAllTasks()
|
| /ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | priority_queue.h | 48 while (!tasks_.empty()) { in Pop()
49 auto waitTme = tasks_.begin()->first; in Pop()
54 auto temp = tasks_.begin(); in Pop()
58 tasks_.erase(temp); in Pop()
71 auto temp = tasks_.emplace(tme, PQMatrix(std::move(tsk), id)); in Push()
80 return tasks_.size(); in Size()
102 tasks_.erase(index->second); in Update()
103 index->second = tasks_.emplace(time, std::move(matrix)); in Update()
127 tasks_.erase(index->second); in Remove()
137 tasks_.clear(); in Clean()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | priority_queue.h | 49 while (!tasks_.empty()) { in Pop()
50 auto waitTme = tasks_.begin()->first; in Pop()
55 auto temp = tasks_.begin(); in Pop()
59 tasks_.erase(temp); in Pop()
72 auto temp = tasks_.emplace(tme, PQMatrix(std::move(tsk), id)); in Push()
81 return tasks_.size(); in Size()
100 tasks_.erase(index->second); in Update()
101 index->second = tasks_.emplace(time, std::move(matrix)); in Update()
129 tasks_.erase(index->second); in Remove()
139 tasks_.clear(); in Clean()
[all …]
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/parallel_render/ |
| H A D | rs_render_task.cpp | 25 tasks_.pop(); in ~RSSuperRenderTask()
35 tasks_.push(std::move(task)); in AddTask()
43 auto surfaceNode = tasks_.front()->GetNode(); in GetSurfaceNode()
44 tasks_.pop(); in GetSurfaceNode()
53 auto task = std::move(tasks_.front()); in GetNextRenderTask()
54 tasks_.pop(); in GetNextRenderTask()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | task_queue.cpp | 31 tasks_.push(task); in PutTask()
46 if (tasks_.empty()) { in GetTaskAutoLock()
51 Task task = tasks_.front(); in GetTaskAutoLock()
52 tasks_.pop(); in GetTaskAutoLock()
73 return tasks_.empty(); in IsEmptyAndUnlocked()
83 return !tasks_.empty(); in CanGetTask()
|
| /ohos5.0/commonlibrary/c_utils/base/src/ |
| H A D | thread_pool.cpp | 84 tasks_.push_back(f); in AddTask()
92 return tasks_.size(); in GetCurTaskNum()
99 while (tasks_.empty() && running_) { in ScheduleTask()
104 if (!tasks_.empty()) { in ScheduleTask()
105 task = tasks_.front(); in ScheduleTask()
106 tasks_.pop_front(); in ScheduleTask()
117 return (maxTaskNum_ > 0) && (tasks_.size() >= maxTaskNum_); in Overloaded()
|
| /ohos5.0/base/update/updateservice/services/firmware/upgrade/mode/src/ |
| H A D | firmware_install_apply_mode.cpp | 59 if (!tasks_.isExistTask) { in GetStepAfterInit()
66 … static_cast<int32_t>(tasks_.status), tasks_.taskId.c_str(), CAST_INT(upgradeOptions_.order)); in GetStepAfterInit()
82 if (tasks_.status != UpgradeStatus::DOWNLOAD_SUCCESS) { in GetStepForInstallAndApplyOrder()
149 if (!tasks_.isExistTask) { in GetTask()
150 FirmwareTaskOperator().QueryTask(tasks_); in GetTask()
151 … FIRMWARE_LOGI("FirmwareInstallApplyMode::GetTask status: %{public}d ", CAST_INT(tasks_.status)); in GetTask()
|
| /ohos5.0/foundation/ability/ability_runtime/services/common/src/ |
| H A D | task_handler_wrap.cpp | 108 auto it = tasks_.find(name); in SubmitTask()
109 if (it != tasks_.end()) { in SubmitTask()
119 tasks_.emplace(name, result); in SubmitTask()
165 auto it = tasks_.find(name); in CancelTask()
166 if (it == tasks_.end()) { in CancelTask()
171 tasks_.erase(it); in CancelTask()
182 auto it = tasks_.find(name); in RemoveTask()
183 if (it == tasks_.end() || !it->second.IsSame(taskHandle)) { in RemoveTask()
186 tasks_.erase(it); in RemoveTask()
|
| /ohos5.0/foundation/ability/ability_runtime/frameworks/native/appkit/app_startup/ |
| H A D | startup_task_dispatcher.cpp | 25 const std::shared_ptr<StartupSortResult> &sortResult) : tasks_(tasks), sortResult_(sortResult) in StartupTaskDispatcher()
40 for (auto &iter : tasks_) { in Run()
50 tasksCount_ = tasks_.size(); in Run()
63 auto findResult = tasks_.find(iter); in Run()
64 if (findResult == tasks_.end()) { in Run()
91 auto findResult = tasks_.find(name); in Dispatch()
92 if (findResult == tasks_.end() || findResult->second == nullptr) { in Dispatch()
136 auto childStartupTask = tasks_.find(child); in NotifyChildren()
137 if (childStartupTask == tasks_.end()) { in NotifyChildren()
|
| H A D | startup_task_manager.cpp | 26 : startupTaskManagerId_(startupTaskManagerId), tasks_(std::move(tasks)) in StartupTaskManager()
41 auto result = tasks_.emplace(name, task); in AddTask()
56 …FwkTag::STARTUP, "id: %{public}u, task number: %{public}zu", startupTaskManagerId_, tasks_.size()); in Prepare()
58 int32_t result = StartupTopologySort::Sort(tasks_, startupSortResult); in Prepare()
68 if (tasks_.empty()) { in Prepare()
72 dispatcher_ = std::make_shared<StartupTaskDispatcher>(tasks_, startupSortResult); in Prepare()
78 …FwkTag::STARTUP, "id: %{public}u, task number: %{public}zu", startupTaskManagerId_, tasks_.size()); in Run()
|
| /ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/ |
| H A D | thread_pool.cpp | 35 … name_(name), numThreads_(numThreads), workers_(), isStopped_(false), mutex_(), taskCv_(), tasks_() in ThreadPool()
135 taskCv_.wait(lock, [this] { return isStopped_.load() || !tasks_.empty(); }); in GetTask()
139 auto task = std::move(tasks_.front()); in GetTask()
140 tasks_.pop_front(); in GetTask()
147 return !tasks_.empty(); in HasPendingTasks()
157 tasks_.emplace_front([task = std::move(func)] { task(); }); in Submit()
159 tasks_.emplace_back([task = std::move(func)] { task(); }); in Submit()
|
| /ohos5.0/foundation/arkui/ace_engine/frameworks/core/components_ng/image_provider/ |
| H A D | image_provider.cpp | 213 auto it = tasks_.find(key); in RegisterTask()
214 if (it != tasks_.end()) { in RegisterTask()
218 tasks_[key].ctxs_.insert(ctx); in RegisterTask()
225 auto it = tasks_.find(key); in EndTask()
226 if (it == tasks_.end()) { in EndTask()
234 tasks_.erase(it); in EndTask()
241 auto it = tasks_.find(key); in CancelTask()
242 CHECK_NULL_VOID(it != tasks_.end()); in CancelTask()
248 tasks_.erase(it); in CancelTask()
268 tasks_[src.GetKey()].bgTask_ = task; in CreateImageObject()
[all …]
|
| /ohos5.0/foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/ |
| H A D | task_scheduler.cpp | 121 if (tasks_.empty()) { in PopPendingTaskList()
124 auto firstTask = tasks_.front(); in PopPendingTaskList()
128 tasks_.pop(); in PopPendingTaskList()
134 FI_HILOGD("tasks_ size:%{public}zu", tasks_.size()); in PostTask()
137 size_t tsize = tasks_.size(); in PostTask()
151 tasks_.push(task); in PostTask()
|
| /ohos5.0/base/update/updateservice/services/firmware/upgrade/executor/src/ |
| H A D | firmware_install_executor.cpp | 65 FirmwareTaskOperator().UpdateProgressByTaskId(tasks_.taskId, progress.status, progress.percent); in DoInstall()
81 DelayedSingleton<FirmwareCallbackUtils>::GetInstance()->NotifyEvent(tasks_.taskId, in DoInstall()
95 if (!tasks_.isExistTask) { in GetTask()
96 FirmwareTaskOperator().QueryTask(tasks_); in GetTask()
111 …FirmwareTaskOperator().UpdateProgressByTaskId(tasks_.taskId, taskProgress_.status, taskProgress_.p… in HandleInstallProgress()
134 …FirmwareTaskOperator().UpdateProgressByTaskId(tasks_.taskId, taskProgress_.status, taskProgress_.p… in HandleInstallResult()
|
| /ohos5.0/base/msdp/device_status/intention/scheduler/task_scheduler/src/ |
| H A D | task_scheduler.cpp | 121 if (tasks_.empty()) { in PopPendingTaskList()
124 auto firstTask = tasks_.front(); in PopPendingTaskList()
128 tasks_.pop(); in PopPendingTaskList()
134 FI_HILOGD("tasks_ size:%{public}zu", tasks_.size()); in PostTask()
137 size_t tsize = tasks_.size(); in PostTask()
151 tasks_.push(task); in PostTask()
|
| /ohos5.0/base/msdp/device_status/services/delegate_task/src/ |
| H A D | delegate_tasks.cpp | 120 if (tasks_.empty()) { in PopPendingTaskList()
123 auto taskDuty = tasks_.front(); in PopPendingTaskList()
127 tasks_.pop(); in PopPendingTaskList()
134 FI_HILOGD("tasks_ size:%{public}zu", tasks_.size()); in PostTask()
136 size_t tsize = tasks_.size(); in PostTask()
150 tasks_.push(task); in PostTask()
|
| /ohos5.0/foundation/multimodalinput/input/service/delegate_task/src/ |
| H A D | delegate_tasks.cpp | 130 if (tasks_.empty()) { in PopPendingTaskList()
133 auto task = tasks_.front(); in PopPendingTaskList()
137 tasks_.pop(); in PopPendingTaskList()
148 MMI_HILOGD("tasks_ size:%{public}d", static_cast<int32_t>(tasks_.size())); in PostTask()
150 auto tsize = tasks_.size(); in PostTask()
164 tasks_.push(task); in PostTask()
|