Home
last modified time | relevance | path

Searched refs:tasks (Results 1 - 25 of 32) sorted by relevance

12

/foundation/distributeddatamgr/pasteboard/framework/test/src/
H A Dffrt_utils_test.cpp84 std::vector<FFRTTask> tasks; in HWTEST_F() local
86 std::vector<FFRTTask>().swap(tasks); in HWTEST_F()
87 FFRTUtils::SubmitQueueTasks(tasks, que); in HWTEST_F()
96 tasks.push_back(task1); in HWTEST_F()
97 tasks.push_back(task2); in HWTEST_F()
98 FFRTUtils::SubmitQueueTasks(tasks, que); in HWTEST_F()
/foundation/arkui/ace_engine/frameworks/core/components/custom_paint/
H A Dcustom_paint_element.h34 std::list<TaskFunc> tasks; variable
38 tasks = paint->GetTasks();
44 paint->SetTasks(tasks);
H A Drender_custom_paint.h59 void SetTasks(const std::list<TaskFunc>& tasks) in SetTasks() argument
61 tasks_ = tasks; in SetTasks()
/foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/
H A Dtask_scheduler.cpp35 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()
/foundation/arkui/ace_engine/frameworks/core/pipeline_ng/
H A Dui_task_scheduler.cpp108 auto tasks = std::move(syncGeometryNodeTasks_); in FlushSyncGeometryNodeTasks() local
109 for (auto& task : tasks) { in FlushSyncGeometryNodeTasks()
267 // clear caches after all process tasks in FlushSafeAreaPaddingProcess()
290 decltype(predictTask_) tasks(std::move(predictTask_)); in FlushPredictTask()
291 for (const auto& task : tasks) { in FlushPredictTask()
338 decltype(afterLayoutTasks_) tasks(std::move(afterLayoutTasks_)); in FlushAfterLayoutTask()
339 for (const auto& task : tasks) { in FlushAfterLayoutTask()
350 decltype(afterLayoutCallbacksInImplicitAnimationTask_) tasks( in FlushAfterLayoutCallbackInImplicitAnimationTask()
352 for (const auto& task : tasks) { in FlushAfterLayoutCallbackInImplicitAnimationTask()
395 decltype(afterRenderTasks_) tasks(st in FlushAfterRenderTask()
[all...]
/foundation/multimodalinput/input/service/delegate_task/test/
H A Ddelegate_tasks_test.cpp131 std::vector<DelegateTasks::TaskPtr> tasks; in HWTEST_F() local
132 ASSERT_NO_FATAL_FAILURE(delegateTasks.PopPendingTaskList(tasks)); in HWTEST_F()
145 std::vector<DelegateTasks::TaskPtr> tasks; in HWTEST_F() local
147 delegateTasks.PopPendingTaskList(tasks); in HWTEST_F()
149 ASSERT_NO_FATAL_FAILURE(delegateTasks.PopPendingTaskList(tasks)); in HWTEST_F()
/foundation/multimodalinput/input/service/delegate_task/src/
H A Ddelegate_tasks.cpp36 MMI_HILOGE("Expired tasks will be discarded. id:%{public}d", id_); in ProcessTask()
82 std::vector<TaskPtr> tasks; in ProcessTasks() local
83 PopPendingTaskList(tasks); in ProcessTasks()
84 for (const auto &it : tasks) { in ProcessTasks()
125 void DelegateTasks::PopPendingTaskList(std::vector<TaskPtr> &tasks) in PopPendingTaskList() argument
136 tasks.push_back(task->GetSharedPtr()); in PopPendingTaskList()
/foundation/distributeddatamgr/pasteboard/test/fuzztest/ffrtutils_fuzzer/
H A Dffrtutils_fuzzer.cpp50 std::vector<FFRTTask> tasks; in FuzzFfrtUtilsSubmitQueueTasks() local
51 tasks.push_back(task); in FuzzFfrtUtilsSubmitQueueTasks()
52 tasks.push_back(task1); in FuzzFfrtUtilsSubmitQueueTasks()
54 FFRTUtils::SubmitQueueTasks(tasks, serialQueue); in FuzzFfrtUtilsSubmitQueueTasks()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_scheduler.cpp61 std::queue<std::unique_ptr<SCPUEUTask>> tasks; in HWTEST_F() local
121 tasks.push(std::make_unique<SCPUEUTask>( in HWTEST_F()
125 while (!tasks.empty()) { in HWTEST_F()
126 auto task = std::move(tasks.front()); in HWTEST_F()
127 tasks.pop(); in HWTEST_F()
149 tasks.push(std::move(task)); in HWTEST_F()
/foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/
H A Dffrt_utils.cpp26 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask> &tasks, FFRTQueue &queue) in SubmitQueueTasks() argument
28 if (tasks.empty()) { in SubmitQueueTasks()
31 for (auto task : tasks) { in SubmitQueueTasks()
/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Dparallel_task_queue.cpp115 afterIdentifiers.cbegin(), afterIdentifiers.cend(), [&tasks = tasks_](const uint64_t afterIdentifier) { in SubmitAfter()
116 return std::any_of(tasks.cbegin(), tasks.cend(), in SubmitAfter()
145 // No more tasks to proecss. in QueueTasks()
191 // Keep on pushing tasks to queue until all done. in Execute()
194 // Push new tasks to queue. in Execute()
/foundation/systemabilitymgr/samgr_lite/samgr/source/
H A Dtask_manager.h45 ThreadId tasks[0]; member
H A Dtask_manager.c87 pool->tasks[pool->top] = threadId; in SAMGR_StartTaskPool()
/foundation/ability/ability_runtime/frameworks/native/appkit/app_startup/
H A Dstartup_task_manager.cpp25 std::map<std::string, std::shared_ptr<StartupTask>> tasks) in StartupTaskManager()
26 : startupTaskManagerId_(startupTaskManagerId), tasks_(std::move(tasks)) in StartupTaskManager()
69 TAG_LOGE(AAFwkTag::STARTUP, "no tasks"); in Prepare()
24 StartupTaskManager(uint32_t startupTaskManagerId, std::map<std::string, std::shared_ptr<StartupTask>> tasks) StartupTaskManager() argument
H A Dstartup_task_dispatcher.cpp24 StartupTaskDispatcher::StartupTaskDispatcher(const std::map<std::string, std::shared_ptr<StartupTask>> &tasks, in StartupTaskDispatcher() argument
25 const std::shared_ptr<StartupSortResult> &sortResult) : tasks_(tasks), sortResult_(sortResult) in StartupTaskDispatcher()
/foundation/graphic/graphic_3d/lume/Lume_3D/src/ecs/systems/
H A Dskinning_system.cpp319 const auto tasks = resultCount / (taskSize == 0 ? 1 : taskSize); in Update() local
322 tasks_.reserve(tasks); in Update()
325 taskResults_.reserve(tasks); in Update()
326 for (size_t i = 0; i < tasks; ++i) { in Update()
332 if (const auto remaining = resultCount - (tasks * taskSize); remaining) { in Update()
333 auto finalBatch = array_view(queryResults.data() + tasks * taskSize, remaining); in Update()
/foundation/ability/ability_runtime/interfaces/kits/native/appkit/app_startup/
H A Dstartup_task_dispatcher.h29 StartupTaskDispatcher(const std::map<std::string, std::shared_ptr<StartupTask>> &tasks,
/foundation/multimodalinput/input/intention/scheduler/task_scheduler/include/
H A Dtask_scheduler.h96 void PopPendingTaskList(std::vector<TaskPtr> &tasks);
/foundation/multimodalinput/input/service/delegate_task/include/
H A Ddelegate_tasks.h94 void PopPendingTaskList(std::vector<TaskPtr> &tasks);
/foundation/distributeddatamgr/pasteboard/framework/framework/include/ffrt/
H A Dffrt_utils.h42 * The mutex for FFRT tasks.
60 static void SubmitQueueTasks(const std::vector<FFRTTask> &tasks, FFRTQueue &queue);
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_uifirst_manager.h150 void CollectSkipSyncBuffer(std::vector<std::function<void()>>& tasks, NodeId id);
151 void ReleaseSkipSyncBuffer(std::vector<std::function<void()>>& tasks);
H A Drs_uni_render_thread.cpp264 std::vector<Callback> tasks; in RunImageReleaseTask() local
267 std::swap(imageReleaseTasks_, tasks); in RunImageReleaseTask()
269 if (tasks.empty()) { in RunImageReleaseTask()
274 for (auto task : tasks) { in RunImageReleaseTask()
H A Drs_uifirst_manager.cpp250 void RSUifirstManager::CollectSkipSyncBuffer(std::vector<std::function<void()>>& tasks, NodeId id) in CollectSkipSyncBuffer() argument
270 tasks.emplace_back(releaseTask); in CollectSkipSyncBuffer()
280 void RSUifirstManager::ReleaseSkipSyncBuffer(std::vector<std::function<void()>>& tasks) in ReleaseSkipSyncBuffer() argument
283 if (tasks.empty()) { in ReleaseSkipSyncBuffer()
286 auto releaseBufferTask = [tasks]() { in ReleaseSkipSyncBuffer()
287 for (const auto& task : tasks) { in ReleaseSkipSyncBuffer()
/foundation/resourceschedule/ffrt/tools/ffrt_trace_process/
H A Dffrt_trace_process.py246 parser trace record of ffrt tasks：
392 # check suspect tasks, i.e. not ready, not execute, not finish
600 def print_task_info(task_name, tasks):
602 lines.append("Task Label: " + task_name + ", Total Count: " + str(len(tasks)) + "\n\n")
606 for task in tasks:
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service/unittest/pipeline/
H A Drs_uifirst_manager_test.cpp649 std::vector<std::function<void()>> tasks; in HWTEST_F() local
650 tasks.push_back(task); in HWTEST_F()
651 uifirstManager_.ReleaseSkipSyncBuffer(tasks); in HWTEST_F()
652 ASSERT_NE(tasks.empty(), true); in HWTEST_F()
665 std::vector<std::function<void()>> tasks; in HWTEST_F() local
666 tasks.push_back(task); in HWTEST_F()
667 uifirstManager_.CollectSkipSyncBuffer(tasks, id); in HWTEST_F()
668 ASSERT_NE(tasks.empty(), true); in HWTEST_F()

Completed in 18 milliseconds

12