Home
last modified time | relevance | path

Searched refs:taskType (Results 1 - 25 of 59) sorted by relevance

123

/foundation/resourceschedule/ffrt/src/dfx/trace_record/
H A Dffrt_trace_record.h71 template<ffrt_executor_task_type_t taskType>
75 g_recordTaskCounter_[taskType][qos].submitCounter.fetch_add(1, std::memory_order_relaxed); in AddSubmitCounter()
87 template<ffrt_executor_task_type_t taskType>
93 AddSubmitCounter<taskType>(qos); in TaskSubmit()
104 template<ffrt_executor_task_type_t taskType>
110 AddSubmitCounter<taskType>(qos); in TaskSubmit()
121 template<ffrt_executor_task_type_t taskType>
125 g_recordTaskCounter_[taskType][qos].runCounter.fetch_add(1, std::memory_order_relaxed); in TaskExecute()
129 template<ffrt_executor_task_type_t taskType>
133 g_recordTaskCounter_[taskType][qo in TaskDone()
[all...]
/foundation/multimedia/media_library/frameworks/services/media_thumbnail/src/
H A Dthumbnail_generate_worker_manager.cpp28 ThumbnailWorkerPtr ThumbnailGenerateWorkerManager::GetThumbnailWorker(const ThumbnailTaskType &taskType) in GetThumbnailWorker() argument
31 if (thumbnailWorkerMap_.Find(taskType, ptr)) { in GetThumbnailWorker()
35 int status = InitThumbnailWorker(taskType); in GetThumbnailWorker()
40 thumbnailWorkerMap_.Find(taskType, ptr); in GetThumbnailWorker()
44 int32_t ThumbnailGenerateWorkerManager::InitThumbnailWorker(const ThumbnailTaskType &taskType) in InitThumbnailWorker() argument
48 if (thumbnailWorkerMap_.Find(taskType, ptr)) { in InitThumbnailWorker()
53 int32_t status = ptr->Init(taskType); in InitThumbnailWorker()
58 thumbnailWorkerMap_.Insert(taskType, ptr); in InitThumbnailWorker()
70 thumbnailWorkerMap_.Iterate([](ThumbnailTaskType taskType, ThumbnailWorkerPtr &ptr) { in ClearAllTask()
86 thumbnailWorkerMap_.Iterate([](ThumbnailTaskType taskType, ThumbnailWorkerPt in TryCloseThumbnailWorkerTimer()
[all...]
H A Dthumbnail_generate_worker.cpp42 int32_t ThumbnailGenerateWorker::Init(const ThumbnailTaskType &taskType) in Init() argument
49 MEDIA_INFO_LOG("threads empty, need to init, taskType:%{public}d", taskType_); in Init()
52 taskType_ = taskType; in Init()
53 if (taskType == ThumbnailTaskType::FOREGROUND) { in Init()
56 } else if (taskType == ThumbnailTaskType::BACKGROUND) { in Init()
150 MEDIA_INFO_LOG("ThumbnailGenerateWorker thread start, taskType:%{public}d, id:%{public}d", in StartWorker()
186 MEDIA_INFO_LOG("ThumbnailGenerateWorker thread finish, taskType:%{public}d, id:%{public}d", in StartWorker()
259 MEDIA_INFO_LOG("Clear ThumbnailGenerateWorker threads successfully, taskType:%{public}d", taskType_); in ClearWorkerThreads()
266 MEDIA_INFO_LOG("task queue is not empty, no need to clear worker threads, taskType:%{public}d", taskType_); in IsAllThreadWaiting()
272 MEDIA_INFO_LOG("thread is running, taskType in IsAllThreadWaiting()
[all...]
/foundation/arkui/ace_engine/frameworks/component_test/
H A Dtest_task_scheduler.cpp40 TaskExecutor::TaskType taskType, void* data, uint32_t delay) in PushTask()
45 finish_ = [this, onFinish = std::move(onFinish), taskType, data]() { in PushTask()
46 idleWatcher_->RequestNextIdleStatusNotification([this, onFinish = std::move(onFinish), taskType, data]() { in PushTask()
47 taskExecutor_->PostTask([data, onFinish = move(onFinish)]() { onFinish(data); }, taskType, {}); in PushTask()
63 [this, task = std::move(task_), taskType]() { in PushTask()
65 [this, task = std::move(task), taskType]() { in PushTask()
66 taskExecutor_->PostTask([task = std::move(task)]() { task(); }, taskType, {}); in PushTask()
39 PushTask(std::function<void(void*)>&& task, std::function<void(void*)>&& onFinish, TaskExecutor::TaskType taskType, void* data, uint32_t delay) PushTask() argument
H A Dtest_task_scheduler.h38 TaskExecutor::TaskType taskType, void* data, uint32_t delay);
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/
H A Dtask_factory.cpp34 std::shared_ptr<Task> TaskFactory::CreateTask(TaskType taskType, TaskParam taskParam, std::shared_ptr<Task> fatherTask) in CreateTask() argument
36 DHLOGI("taskType: %{public}d, networkId: %{public}s, uuid: %{public}s, dhId: %{public}s", in CreateTask()
37 static_cast<int32_t>(taskType), GetAnonyString(taskParam.networkId).c_str(), in CreateTask()
40 switch (taskType) { in CreateTask()
72 DHLOGE("CreateTask type invalid, type: %{public}d", taskType); in CreateTask()
H A Dtask.cpp68 void Task::SetTaskType(TaskType taskType) in SetTaskType() argument
70 this->taskType_ = taskType; in SetTaskType()
/foundation/arkui/ace_engine/test/unittest/core/common/task/
H A Dthread_test.cpp92 * @tc.steps1: set the taskType. in HWTEST_F()
97 auto taskType = static_cast<TaskExecutor::TaskType>(id); in HWTEST_F() local
98 auto result = taskExecutorImpl_->WillRunOnCurrentThread(taskType); in HWTEST_F()
99 switch (taskType) { in HWTEST_F()
122 * @tc.steps1: set the taskType. in HWTEST_F()
127 auto taskType = static_cast<TaskExecutor::TaskType>(id); in HWTEST_F() local
128 auto result = taskExecutorImpl_->WillRunOnCurrentThread(taskType); in HWTEST_F()
129 switch (taskType) { in HWTEST_F()
292 auto taskType = static_cast<TaskExecutor::TaskType>(id); in HWTEST_F() local
293 auto result = taskExecutorImpl_->OnPostTask(callBack, taskType, in HWTEST_F()
[all...]
/foundation/arkui/ace_engine/frameworks/core/components_ng/image_provider/
H A Dimage_utils.cpp21 std::function<void()>&& task, TaskExecutor::TaskType taskType, const char* taskTypeName, PriorityType priorityType) in PostTask()
34 taskType, std::string(taskTypeName), priorityType); in PostTask()
37 void ImageUtils::PostDelayedTask(std::function<void()>&& task, TaskExecutor::TaskType taskType, uint32_t delayTime, in PostDelayedTask() argument
51 taskType, delayTime, std::string(taskTypeName), priorityType); in PostDelayedTask()
20 PostTask( std::function<void()>&& task, TaskExecutor::TaskType taskType, const char* taskTypeName, PriorityType priorityType) PostTask() argument
H A Dimage_utils.h42 static void PostTask(std::function<void()>&& task, TaskExecutor::TaskType taskType, const char* taskTypeName,
44 static void PostDelayedTask(std::function<void()>&& task, TaskExecutor::TaskType taskType, uint32_t delayTime,
/foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/
H A Dtask_scheduler.cpp39 std::string taskType = ((promise_ == nullptr) ? "Async" : "Sync"); in ProcessTask() local
40 FI_HILOGD("process:%{public}s, task id:%{public}d, ret:%{public}d", taskType.c_str(), id_, ret); in ProcessTask()
152 std::string taskType = ((promise == nullptr) ? "Async" : "Sync"); in PostTask() local
153 FI_HILOGD("Post %{public}s", taskType.c_str()); in PostTask()
/foundation/resourceschedule/ffrt/src/sched/
H A Dscheduler.cpp47 uintptr_t taskType = task->type; in InsertNode() local
49 if (taskType == ffrt_uv_task || taskType == ffrt_io_task) { in InsertNode()
57 if (taskType == ffrt_io_task) { in InsertNode()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/task/src/
H A Dmock_task_factory.cpp30 std::shared_ptr<Task> MockTaskFactory::CreateTask(TaskType taskType, TaskParam taskParam, in CreateTask() argument
34 switch (taskType) { in CreateTask()
66 DHLOGE("CreateTask type invalid, type: %{public}d", taskType); in CreateTask()
/foundation/multimedia/media_library/frameworks/services/media_thumbnail/include/
H A Dthumbnail_generate_worker_manager.h37 EXPORT ThumbnailWorkerPtr GetThumbnailWorker(const ThumbnailTaskType &taskType);
47 EXPORT int32_t InitThumbnailWorker(const ThumbnailTaskType &taskType);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_target.cpp36 void SyncTarget::SetTaskType(int taskType) in SetTaskType() argument
38 taskType_ = taskType; in SetTaskType()
H A Disync_target.h36 virtual void SetTaskType(int taskType) = 0;
/foundation/multimodalinput/input/service/delegate_task/src/
H A Ddelegate_tasks.cpp40 std::string taskType = ((promise_ == nullptr) ? "Async" : "Sync"); in ProcessTask() local
41 MMI_HILOGD("Process taskType:%{public}s, taskId:%{public}d, ret:%{public}d", taskType.c_str(), id_, ret); in ProcessTask()
165 std::string taskType = ((promise == nullptr) ? "Async" : "Sync"); in PostTask() local
166 MMI_HILOGD("Post taskType:%{public}s", taskType.c_str()); in PostTask()
/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/include/
H A Ddscreen.h53 Task(TaskType taskType, const std::string &taskId, const std::string &taskParam) : taskType_(taskType), in Task() argument
55 Task(TaskType taskType, const std::string &taskParam) : taskType_(taskType), in Task() argument
/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/1.0/include/
H A Ddscreen.h55 Task(TaskType taskType, const std::string &taskId, const std::string &taskParam) : taskType_(taskType), in Task() argument
57 Task(TaskType taskType, const std::string &taskParam) : taskType_(taskType), in Task() argument
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/task_fuzzer/
H A Dtask_fuzzer.cpp60 TaskType taskType = taskTypeFuzz[data[0] % TASK_TYPE_SIZE]; in TaskFuzzTest() local
62 auto task = TaskFactory::GetInstance().CreateTask(taskType, taskParam, nullptr); in TaskFuzzTest()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/task/include/
H A Dmock_task_factory.h29 std::shared_ptr<Task> CreateTask(TaskType taskType, TaskParam taskParam, std::shared_ptr<Task> fatherTask);
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/task/
H A Dtask_factory.h29 std::shared_ptr<Task> CreateTask(TaskType taskType, TaskParam taskParam, std::shared_ptr<Task> fatherTask);
/foundation/multimedia/media_library/frameworks/services/media_async_worker/include/
H A Dmedialibrary_async_worker.h42 MediaLibraryAsyncTask(MediaLibraryExecute executor, AsyncTaskData *data, TaskType taskType = BUTT) in MediaLibraryAsyncTask()
43 : executor_(executor), data_(data), taskType_(taskType) {} in MediaLibraryAsyncTask()
/foundation/resourceschedule/background_task_mgr/interfaces/innerkits/src/
H A Dbackground_task_mgr_helper.cpp95 ErrCode BackgroundTaskMgrHelper::StopContinuousTask(int32_t uid, int32_t pid, uint32_t taskType, const std::string &key) in StopContinuousTask() argument
97 return DelayedSingleton<BackgroundTaskManager>::GetInstance()->StopContinuousTask(uid, pid, taskType, key); in StopContinuousTask()
/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Dpipeline_threadpool.cpp80 std::shared_ptr<PipeLineThread> PipeLineThreadPool::FindThread(std::string groupId, TaskType taskType, TaskPriority priority) in FindThread() argument
88 if (thread->type_ == taskType) { in FindThread()
92 std::shared_ptr<PipeLineThread> newThread = std::make_shared<PipeLineThread>(groupId, taskType, priority); in FindThread()

Completed in 9 milliseconds

123