| /foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/ |
| H A D | thread_pool.cpp | 76 auto task = GetTask(); in WorkerLoop() local
138 auto task = std::move(tasks_.front()); in GetTask() local
[all...] |
| H A D | task_manager.cpp | 116 bool TaskManager::SubmitTask(std::function<void()> task) in SubmitTask() argument
121 bool TaskManager::SubmitTask(std::function<void()> task, uint32_t delayMilli) in SubmitTask() argument
159 auto task in DoDefaultWorks() local
[all...] |
| /foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/task_group/ |
| H A D | base_task_group.cpp | 89 auto task = [param = que_.Pop(), weakThis]() { in GetTaskUnlocked() local
117 auto task = GetTaskUnlocked(); DispatchTaskUnlocked() local
[all...] |
| /foundation/multimedia/player_framework/services/services/player/server/ |
| H A D | player_server_task_mgr.cpp | 55 int32_t PlayerServerTaskMgr::EnqueueTask(const std::shared_ptr<ITaskHandler> &task, PlayerServerTaskType type, in EnqueueTask() argument
73 int32_t PlayerServerTaskMgr::LaunchTask(const std::shared_ptr<ITaskHandler> &task, PlayerServerTaskType type, in LaunchTask() argument
105 SpeedTask(const std::shared_ptr<ITaskHandler> &task, const std::shared_ptr<ITaskHandler> &cancelTask, const std::string &taskName, int32_t speedMode) SpeedTask() argument
132 EnqueueSeekTask(const std::shared_ptr<ITaskHandler> &task, PlayerServerTaskType type, const std::string &taskName, int32_t seekMode, int32_t seekTime) EnqueueSeekTask() argument
146 SeekTask(const std::shared_ptr<ITaskHandler> &task, const std::shared_ptr<ITaskHandler> &cancelTask, const std::string &taskName, int32_t seekMode, int32_t seekTime) SeekTask() argument
178 SeekContinousTask(const std::shared_ptr<ITaskHandler> &task, const std::string &taskName) SeekContinousTask() argument
[all...] |
| /foundation/multimedia/media_library/frameworks/services/media_multistages_capture/src/dfx/ |
| H A D | multistages_capture_dfx_first_visit.cpp | 51 FirstVisitAsyncTaskData *task = static_cast<FirstVisitAsyncTaskData*>(taskData);
in ReportInternal() local
|
| /foundation/multimedia/player_framework/services/services/player/player_mem_manage/ |
| H A D | player_service_stub_mem.cpp | 67 auto task = std::make_shared<TaskHandler<void>>([&, this] {
in ~PlayerServiceStubMem() local
113 auto task = std::make_shared<TaskHandler<void>>([&, this] {
in ResetFrontGroundForMemManageRecall() local
124 auto task = std::make_shared<TaskHandler<void>>([&, this] {
in ResetBackGroundForMemManageRecall() local
135 auto task = std::make_shared<TaskHandler<void>>([&, this] {
in ResetMemmgrForMemManageRecall() local
146 auto task in RecoverByMemManageRecall() local
[all...] |
| /foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/ |
| H A D | task_scheduler.cpp | 91 auto task = PostTask(cb, &promise); in PostSyncTask() local
111 auto task = PostTask(callback); in PostAsyncTask() local
150 TaskPtr task = std::make_shared<Task>(id, callback, promise); in PostTask() local
[all...] |
| /foundation/multimodalinput/input/service/delegate_task/src/ |
| H A D | delegate_tasks.cpp | 98 auto task = PostTask(callback, &promise); in PostSyncTask() local
133 auto task = tasks_.front(); in PopPendingTaskList() local
163 TaskPtr task = std::make_shared<Task>(id, callback, promise); in PostTask() local
[all...] |
| /foundation/resourceschedule/background_task_mgr/services/common/src/ |
| H A D | system_event_observer.cpp | 89 auto task = [bgContinuousTaskMgr, userId]() { bgContinuousTaskMgr->OnAccountsStateChanged(userId); };
in OnReceiveEventContinuousTask() local
97 auto task = [bgContinuousTaskMgr, action, bundleName, uid]() {
in OnReceiveEventContinuousTask() local
|
| /foundation/resourceschedule/ffrt/src/sync/ |
| H A D | shared_mutex.cpp | 99 auto task = ctx->task; in Wait() local
128 CPUEUTask* task = we->task; NotifyOne() local
149 CPUEUTask* task = we->task; NotifyAll() local
[all...] |
| H A D | mutex.cpp | 40 uint64_t task = ExecuteCtx::Cur()->task ? reinterpret_cast<uint64_t>(ExecuteCtx::Cur()->task) : GetTid(); in try_lock() local
51 uint64_t task; in lock() local
82 auto task = ctx->task; try_lock() local
133 auto task = ctx->task; lock() local
167 auto task = ctx->task; unlock() local
219 auto task = ctx->task; wait() local
263 CPUEUTask* task = we->task; wake() local
[all...] |
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | cpu_worker.cpp | 37 void CPUWorker::Run(CPUEUTask* task, CPUWorker* worker) in Run() argument
71 Run(ffrt_executor_task_t* task, ffrt_qos_t qos) Run() argument
108 CPUEUTask* task = reinterpret_cast<CPUEUTask*>(curtask); RunTask() local
135 RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worker) RunTaskLifo() argument
155 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker); GetTask() local
169 void* task = worker->priority_task; GetTask() local
246 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker); WorkerLooperDefault() local
[all...] |
| /foundation/resourceschedule/ffrt/src/sched/ |
| H A D | scheduler.h | 91 void ResetDeadline(CPUEUTask* task, int64_t deadline) in ResetDeadline() argument
102 updateTask(CPUEUTask* task, int64_t deadline) updateTask() argument
114 UpdateChildTask(CPUEUTask* task, int64_t deadline) UpdateChildTask() argument
[all...] |
| H A D | scheduler.cpp | 45 ffrt_executor_task_t* task = reinterpret_cast<ffrt_executor_task_t*>(reinterpret_cast<char*>(node) - in InsertNode() local
84 bool FFRTScheduler::WakeupTask(CPUEUTask* task) in WakeupTask() argument
[all...] |
| H A D | task_scheduler.h | 39 CPUEUTask* task = que->DeQueue(); in PickNextTask() local
44 bool WakeupTask(CPUEUTask* task) in WakeupTask() argument
|
| /foundation/resourceschedule/ffrt/src/core/ |
| H A D | task_io.cpp | 32 static void work_finish_callable(IOTaskExecutor* task) in work_finish_callable() argument
41 IOTaskExecutor* task = static_cast<IOTaskExecutor*>(data); in ExecuteIOTask() local
82 ffrt::IOTaskExecutor* task = new ffrt::IOTaskExecutor(qos); ffrt_submit_coroutine() local
99 ffrt_wake_coroutine(void* task) ffrt_wake_coroutine() argument
[all...] |
| /foundation/resourceschedule/ffrt/src/dm/ |
| H A D | dependence_manager.h | 85 void onSubmitUV(ffrt_executor_task_t *task, const task_attr_private *attr) in onSubmitUV() argument
|
| /foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_dfx.cpp | 121 auto task = ffrt::submit_h(basic2Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_background))); in HWTEST_F() local
158 auto task = ffrt::submit_h(basic3Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_background))); in HWTEST_F() local
|
| /foundation/window/window_manager/window_scene/intention_event/framework/anr_handler/src/ |
| H A D | anr_handler.cpp | 54 auto task = [this, eventId, sessionStage]() { in SetSessionStage() local
70 auto task = [this, eventId, actionTime]() { in HandleEventConsumed() local
94 auto task = [this, persistentId]() { in OnWindowDestroyed() local
108 bool ANRHandler::PostTask(Task &&task, const std::string& name, int64_t delayTime) in PostTask() argument
172 auto task in SendEvent() local
[all...] |
| /foundation/systemabilitymgr/samgr/services/samgr/native/source/collect/ |
| H A D | device_param_collect.cpp | 141 auto task = [this] () { in OnAddSystemAbility() local
|
| /foundation/window/window_manager/extension/modal_system_ui_extension/src/ |
| H A D | modal_system_ui_extension.cpp | 130 auto task = [weakThis = wptr(this)] { in OnAbilityConnectDone() local
|
| /foundation/window/window_manager/window_scene/common/src/ |
| H A D | task_scheduler.cpp | 26 auto task = [&tid]() mutable { in TaskScheduler() local
39 void TaskScheduler::PostAsyncTask(Task&& task, const std::string& name, int64_t delayTime) in PostAsyncTask() argument
56 void TaskScheduler::PostVoidSyncTask(Task&& task, const std::string& name) in PostVoidSyncTask() argument
73 PostTask(Task&& task, const std::string& name, int64_t delayTime) PostTask() argument
95 AddExportTask(std::string taskName, Task task) AddExportTask() argument
117 auto task = [funcMap = std::move(exportFuncMap_)]() { ExecuteExportTask() local
[all...] |
| /foundation/communication/netstack/utils/common_utils/include/ |
| H A D | thread_pool.h | 80 void Push(const Task &task)
in Push() argument
98 bool GetTask(Task &task)
in GetTask() argument
113 void PushTask(const Task &task)
in PushTask() argument
162 Task task;
in RunTask() local
[all...] |
| /foundation/communication/netstack/frameworks/js/napi/socket/task_queue/src/ |
| H A D | task_queue.cpp | 59 Task task; in Executor() local
94 Task task; in Callback() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/common/test/ |
| H A D | executor_pool_test.cpp | 106 auto task = [data] { in HWTEST_F() local
132 auto task = [data] { in HWTEST_F() local
153 auto task = [data] { in HWTEST_F() local
179 auto task = [&testNum] { in HWTEST_F() local
[all...] |