/foundation/filemanagement/dfs_service/test/unittests/cloud_file_kit_inner/data_sync/ |
H A D | task_state_manager_test.cpp | 32 MOCK_METHOD2(StartTask, void(string bundleName, TaskType task)); 33 MOCK_METHOD2(CompleteTask, void(string bundleName, TaskType task)); 34 MOCK_METHOD2(HasTask, bool(string bundleName, TaskType task)); 82 TaskStateManager::GetInstance().HasTask("testBundleName", TaskType::UPLOAD_ASSET_TASK); in HWTEST_F() 95 TaskStateManager::GetInstance().HasTask("testBundleName", TaskType::DOWNLOAD_ASSET_TASK); in HWTEST_F() 168 EXPECT_CALL(mockTaskStateManager, StartTask(bundleName, TaskType::SYNC_TASK)); in HWTEST_F() 169 EXPECT_CALL(mockTaskStateManager, StartTask(bundleName, TaskType::DOWNLOAD_TASK)); in HWTEST_F() 170 EXPECT_CALL(mockTaskStateManager, StartTask(bundleName, TaskType::UPLOAD_ASSET_TASK)); in HWTEST_F() 171 EXPECT_CALL(mockTaskStateManager, StartTask(bundleName, TaskType::DOWNLOAD_ASSET_TASK)); in HWTEST_F() 172 EXPECT_CALL(mockTaskStateManager, StartTask(bundleName, TaskType in HWTEST_F() [all...] |
/foundation/arkui/ace_engine/frameworks/core/common/ |
H A D | task_executor_impl.cpp | 127 FillTaskTypeTable(TaskType::PLATFORM); in InitPlatformThread() 139 jsRunner_, [weak = AceType::WeakClaim(this)] { FillTaskTypeTable(weak, TaskType::JS); }, 0, in InitJsThread() 162 uiRunner_, [weak = AceType::WeakClaim(this)] { FillTaskTypeTable(weak, TaskType::UI); }, 0, in InitOtherThreads() 165 ioRunner_, [weak = AceType::WeakClaim(this)] { FillTaskTypeTable(weak, TaskType::IO); }, 0, in InitOtherThreads() 168 gpuRunner_, [weak = AceType::WeakClaim(this)] { FillTaskTypeTable(weak, TaskType::GPU); }, 0, in InitOtherThreads() 173 Task&& task, TaskType type, uint32_t delayTime, const std::string& name, PriorityType priorityType) const in OnPostTask() 183 if (taskWrapper_ != nullptr && (type == TaskType::PLATFORM || type == TaskType::UI || type == TaskType::JS)) { in OnPostTask() 193 case TaskType in OnPostTask() [all...] |
H A D | task_executor_impl.h | 47 bool WillRunOnCurrentThread(TaskType type) const final; 48 void RemoveTask(TaskType type, const std::string &name) override; 50 int32_t GetTid(TaskType type) final 55 uint32_t GetTotalTaskNum(TaskType type) final 68 bool OnPostTask(Task&& task, TaskType type, uint32_t delayTime, const std::string& name, 72 bool OnPostTaskWithoutTraceId(Task&& task, TaskType type, uint32_t delayTime, const std::string& name, 76 bool OnPreSyncTask(TaskType type) const final; 79 void DumpDeadSyncTask(TaskType from, TaskType to) const; 83 void FillTaskTypeTable(TaskType typ [all...] |
H A D | thread_checker.cpp | 22 bool CheckThread(TaskExecutor::TaskType threadType) in CheckThread() 24 if (threadType == TaskExecutor::TaskType::UI || threadType == TaskExecutor::TaskType::JS) { in CheckThread() 32 if (threadType == TaskExecutor::TaskType::PLATFORM) { in CheckThread()
|
/foundation/arkui/ace_engine/frameworks/base/thread/ |
H A D | task_executor.h | 53 enum class TaskType : uint32_t { class in OHOS::Ace::TaskExecutor 74 Task&& task, TaskType type, const std::string& name, PriorityType priorityType = PriorityType::LOW) const in PostTask() 87 bool PostTask(const Task& task, TaskType type, const std::string& name, in PostTask() 102 bool PostTaskWithTraceId(Task&& task, TaskType type, int32_t id, const std::string& name) const in PostTaskWithTraceId() 117 bool PostTaskWithTraceId(const Task& task, TaskType type, int32_t id, const std::string& name) const in PostTaskWithTraceId() 133 bool PostDelayedTask(Task&& task, TaskType type, uint32_t delayTime, const std::string& name, in PostDelayedTask() 136 if (delayTime > 0 && type == TaskType::BACKGROUND) { in PostDelayedTask() 152 bool PostDelayedTask(const Task& task, TaskType type, uint32_t delayTime, const std::string& name, in PostDelayedTask() 168 Task&& task, TaskType type, const std::string& name, PriorityType priorityType = PriorityType::IMMEDIATE) const in PostSyncTask() 170 if (!task || type == TaskType in PostSyncTask() [all...] |
/foundation/arkui/ace_engine/test/unittest/core/common/task/ |
H A D | thread_test.cpp | 97 auto taskType = static_cast<TaskExecutor::TaskType>(id); in HWTEST_F() 100 case TaskExecutor::TaskType::PLATFORM: in HWTEST_F() 101 case TaskExecutor::TaskType::UI: in HWTEST_F() 102 case TaskExecutor::TaskType::IO: in HWTEST_F() 103 case TaskExecutor::TaskType::GPU: in HWTEST_F() 104 case TaskExecutor::TaskType::JS: in HWTEST_F() 105 case TaskExecutor::TaskType::BACKGROUND: in HWTEST_F() 127 auto taskType = static_cast<TaskExecutor::TaskType>(id); in HWTEST_F() 130 case TaskExecutor::TaskType::PLATFORM: in HWTEST_F() 133 case TaskExecutor::TaskType in HWTEST_F() [all...] |
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/task_fuzzer/ |
H A D | task_fuzzer.cpp | 38 const TaskType taskTypeFuzz[TASK_TYPE_SIZE] = { 39 TaskType::UNKNOWN, TaskType::ENABLE, TaskType::DISABLE, TaskType::ON_LINE, TaskType::OFF_LINE 60 TaskType taskType = taskTypeFuzz[data[0] % TASK_TYPE_SIZE]; in TaskFuzzTest()
|
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/task/src/ |
H A D | mock_task_factory.cpp | 30 std::shared_ptr<Task> MockTaskFactory::CreateTask(TaskType taskType, TaskParam taskParam, in CreateTask() 35 case TaskType::ENABLE: { in CreateTask() 40 case TaskType::DISABLE: { in CreateTask() 45 case TaskType::META_ENABLE: { in CreateTask() 50 case TaskType::META_DISABLE: { in CreateTask() 55 case TaskType::ON_LINE: { in CreateTask() 60 case TaskType::OFF_LINE: { in CreateTask()
|
H A D | task_test.cpp | 94 MockTaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, TASK_PARAM_1, nullptr)); in HWTEST_F() 112 MockTaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, TASK_PARAM_1, nullptr)); in HWTEST_F() 116 MockTaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, TASK_PARAM_2, nullptr)); in HWTEST_F() 135 MockTaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, TASK_PARAM_1, nullptr)); in HWTEST_F() 139 MockTaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, TASK_PARAM_2, nullptr)); in HWTEST_F() 173 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, taskParam, nullptr); in HWTEST_F() 186 auto task = TaskFactory::GetInstance().CreateTask(TaskType::DISABLE, taskParam, nullptr); in HWTEST_F() 199 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, taskParam, nullptr); in HWTEST_F() 212 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); in HWTEST_F() 225 auto task = TaskFactory::GetInstance().CreateTask(TaskType in HWTEST_F() [all...] |
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/ |
H A D | task_factory.cpp | 34 std::shared_ptr<Task> TaskFactory::CreateTask(TaskType taskType, TaskParam taskParam, std::shared_ptr<Task> fatherTask) in CreateTask() 41 case TaskType::ENABLE: { in CreateTask() 46 case TaskType::DISABLE: { in CreateTask() 51 case TaskType::ON_LINE: { in CreateTask() 56 case TaskType::OFF_LINE: { in CreateTask() 61 case TaskType::META_ENABLE: { in CreateTask() 66 case TaskType::META_DISABLE: { in CreateTask()
|
/foundation/arkui/ace_engine/test/mock/base/ |
H A D | mock_task_executor.h | 30 bool OnPostTask(Task&& task, TaskType type, uint32_t delayTime, const std::string& name, 41 bool WillRunOnCurrentThread(TaskType type) const override 55 void RemoveTask(TaskType type, const std::string &name) override {} 57 bool OnPostTaskWithoutTraceId(Task&& task, TaskType type, uint32_t delayTime, const std::string& name,
|
/foundation/filemanagement/dfs_service/interfaces/inner_api/native/cloud_file_kit_inner/ |
H A D | task_state_manager.h | 26 enum class TaskType : uint64_t { class 41 void StartTask(std::string bundleName, TaskType task); 42 void CompleteTask(std::string bundleName, TaskType task); 43 bool HasTask(std::string bundleName, TaskType task);
|
/foundation/multimedia/media_foundation/src/osal/task/pthread/ |
H A D | pipeline_threadpool.cpp | 52 static std::string TaskTypeConvert(TaskType type) in TaskTypeConvert() 54 static const std::map<TaskType, std::string> table = { in TaskTypeConvert() 55 {TaskType::GLOBAL, "G"}, in TaskTypeConvert() 56 {TaskType::VIDEO, "V"}, in TaskTypeConvert() 57 {TaskType::AUDIO, "A"}, in TaskTypeConvert() 58 {TaskType::SUBTITLE, "T"}, in TaskTypeConvert() 59 {TaskType::SINGLETON, "S"}, in TaskTypeConvert() 80 std::shared_ptr<PipeLineThread> PipeLineThreadPool::FindThread(std::string groupId, TaskType taskType, TaskPriority priority) in FindThread() 115 PipeLineThread::PipeLineThread(std::string groupId, TaskType type, TaskPriority priority) in PipeLineThread() 206 if (type_ == TaskType in RemoveTask() [all...] |
/foundation/arkui/ace_engine/frameworks/base/log/ |
H A D | frame_info.h | 42 enum class TaskType { LAYOUT, RENDER }; class 49 void AddTaskInfo(const std::string& tag, const int32_t id, uint64_t time, TaskType type) in AddTaskInfo() 52 case TaskType::LAYOUT: in AddTaskInfo() 55 case TaskType::RENDER: in AddTaskInfo()
|
/foundation/arkui/ace_engine/test/unittest/core/pattern/scroll/ |
H A D | mock_task_executor.h | 30 bool OnPostTask(Task&& task, TaskType type, uint32_t delayTime, const std::string& name, 48 bool WillRunOnCurrentThread(TaskType type) const override 62 void RemoveTask(TaskType type, const std::string& name) override {} 64 bool OnPostTaskWithoutTraceId(Task&& task, TaskType type, uint32_t delayTime, const std::string& name,
|
/foundation/bundlemanager/app_domain_verify/services/include/agent/core/ |
H A D | app_domain_verify_agent_service.h | 53 void QueryAndCompleteRefresh(TaskType type); 54 void CompleteVerifyRefresh(const BundleVerifyStatusInfo& bundleVerifyStatusInfo, TaskType type); 56 const AppVerifyBaseInfo& appVerifyBaseInfo, const VerifyResultInfo &verifyResultInfo, TaskType type); 60 void DoSync(const TaskType& type);
|
/foundation/arkui/ace_engine/frameworks/core/components/form/resource/ |
H A D | form_callback_client.h | 44 TaskExecutor::TaskType::UI, "ArkUIFormProcessUpdate"); 61 TaskExecutor::TaskType::UI, "ArkUIFormProcessUninstall"); 78 TaskExecutor::TaskType::UI, "ArkUIFormDeathReceived"); 95 TaskExecutor::TaskType::UI, "ArkUIFormError"); 122 TaskExecutor::TaskType::UI, "ArkUIFormProcessRecycleForm"); 142 TaskExecutor::TaskType::UI, "ArkUIFormProcessEnableForm");
|
/foundation/arkui/ace_engine/adapter/ohos/capability/clipboard/ |
H A D | clipboard_impl.cpp | 63 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardHasData"); in HasData() 85 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardHasDataType"); in HasDataType() 103 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardSetDataWithCopyOption"); in SetData() 106 [data]() { g_clipboard = data; }, TaskExecutor::TaskType::UI, "ArkUIClipboardSetTextPasteData"); in SetData() 127 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardSetPixelMapWithCopyOption"); in SetPixelMapData() 130 [pixmap]() { g_pixmap = pixmap; }, TaskExecutor::TaskType::UI, "ArkUIClipboardSetImagePasteData"); in SetPixelMapData() 156 TaskExecutor::TaskType::UI, "ArkUIClipboardTextDataCallback"); in GetData() 177 TaskExecutor::TaskType::UI, "ArkUIClipboardImageDataCallback"); in GetPixelMapData() 333 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardSetMixDataWithCopyOption"); in SetData() 409 TaskExecutor::TaskType in GetDataSync() [all...] |
/foundation/arkui/ace_engine/test/unittest/core/common/others/ |
H A D | thread_checker_test.cpp | 55 EXPECT_TRUE(CheckThread(TaskExecutor::TaskType::UI)); in HWTEST_F() 56 EXPECT_TRUE(CheckThread(TaskExecutor::TaskType::JS)); in HWTEST_F() 57 EXPECT_FALSE(CheckThread(TaskExecutor::TaskType::UNKNOWN)); in HWTEST_F()
|
/foundation/systemabilitymgr/samgr/services/samgr/native/include/ |
H A D | samgr_time_handler.h | 34 typedef std::function<void()> TaskType; typedef in OHOS::SamgrTimeHandler 37 bool PostTask(TaskType func, uint64_t delayTime); 58 ConcurrentMap <uint32_t, TaskType> timeFunc;
|
/foundation/arkui/ace_engine/frameworks/bridge/plugin_frontend/ |
H A D | plugin_frontend_delegate.cpp | 137 TaskExecutor::TaskType::PLATFORM, "ArkUIPluginChangeLocale"); in ChangeLocale() 259 TaskExecutor::TaskType::JS, "ArkUIPluginHandleJsCallback"); in OnJSCallback() 265 TaskExecutor::TaskType::JS, "ArkUIPluginSetJsMessageDispatcher"); in SetJsMessageDispatcher() 284 TaskExecutor::TaskType::UI, "ArkUIPluginTransferComponentResponseData"); in TransferComponentResponseData() 301 TaskExecutor::TaskType::JS, "ArkUIPluginTransferJsResponseData"); in TransferJsResponseData() 314 TaskExecutor::TaskType::JS, "ArkUIPluginTransferJsResponseData"); in TransferJsResponseDataPreview() 327 TaskExecutor::TaskType::JS, "ArkUITransferJsPluginGetError"); in TransferJsPluginGetError() 339 TaskExecutor::TaskType::JS, "ArkUIPluginTransferJsEventData"); in TransferJsEventData() 350 TaskExecutor::TaskType::JS, "ArkUILoadPluginJsCode"); in LoadPluginJsCode() 364 TaskExecutor::TaskType in LoadPluginJsByteCode() [all...] |
/foundation/ability/ability_runtime/services/quickfixmgr/include/ |
H A D | quick_fix_manager_apply_task.h | 36 enum TaskType { enum in OHOS::AAFwk::QuickFixManagerApplyTask 62 TaskType GetTaskType(); 91 TaskType taskType_ = TaskType::QUICK_FIX_APPLY;
|
/foundation/bundlemanager/app_domain_verify/frameworks/verifier/include/ |
H A D | verify_task.h | 39 OHOS::AppDomainVerify::TaskType GetType() override; 42 VerifyTask(OHOS::AppDomainVerify::TaskType type, const AppVerifyBaseInfo &appVerifyBaseInfo, 52 OHOS::AppDomainVerify::TaskType& GetTaskType(); 57 OHOS::AppDomainVerify::TaskType type_;
|
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/task/ |
H A D | task.h | 43 TaskType GetTaskType(); 44 void SetTaskType(TaskType taskType); 69 TaskType taskType_ { TaskType::UNKNOWN };
|
/foundation/arkui/ace_engine/frameworks/core/components_ng/image_provider/ |
H A D | image_utils.cpp | 21 std::function<void()>&& task, TaskExecutor::TaskType taskType, const char* taskTypeName, PriorityType priorityType) in PostTask() 37 void ImageUtils::PostDelayedTask(std::function<void()>&& task, TaskExecutor::TaskType taskType, uint32_t delayTime, in PostDelayedTask() 59 ImageUtils::PostDelayedTask(std::move(task), TaskExecutor::TaskType::UI, delayTime, name.c_str(), priorityType); in PostDelayedTaskToUI() 68 ImageUtils::PostTask(std::move(task), TaskExecutor::TaskType::UI, name.c_str(), priorityType); in PostToUI() 77 ImageUtils::PostTask(std::move(task), TaskExecutor::TaskType::BACKGROUND, name.c_str(), priorityType); in PostToBg()
|