Home
last modified time | relevance | path

Searched refs:taskName (Results 1 - 25 of 82) sorted by relevance

1234

/foundation/window/window_manager/window_scene/session/host/src/
H A Dws_ffrt_helper.cpp46 void SaveTask(const std::string& taskName, ffrt::task_handle handle) in SaveTask() argument
49 taskMap_[taskName] = std::move(handle); in SaveTask()
52 void RemoveTask(const std::string& taskName) in RemoveTask() argument
55 if (auto iter = taskMap_.find(taskName); iter != taskMap_.end()) { in RemoveTask()
59 WLOGI("Failed to cancel task, taskName = %{public}s, retcode = %{public}d", taskName.c_str(), ret); in RemoveTask()
64 WLOGI("Task is not existed, taskName = %{public}s", taskName.c_str()); in RemoveTask()
68 bool IsTaskExisted(const std::string& taskName) in IsTaskExisted() argument
71 auto iter = taskMap_.find(taskName); in IsTaskExisted()
90 SubmitTask(std::function<void()>&& task, const std::string& taskName, uint64_t delayTime, TaskQos qos) SubmitTask() argument
110 CancelTask(const std::string& taskName) CancelTask() argument
[all...]
/foundation/multimedia/player_framework/services/services/player/server/
H A Dplayer_server_task_mgr.cpp56 const std::string &taskName) in EnqueueTask()
61 currTwoPhaseTaskName_ = taskName; in EnqueueTask()
62 if (taskName.compare("volume") == 0) { in EnqueueTask()
74 const std::string &taskName, const std::shared_ptr<ITaskHandler> &cancelTask) in LaunchTask()
79 if (taskName == "play" || taskName == "prepare") { in LaunchTask()
81 } else if (taskName == "pause") { in LaunchTask()
90 return EnqueueTask(task, type, taskName); in LaunchTask()
93 if (taskName.compare("volume") == 0) { in LaunchTask()
95 FAKE_POINTER(this), currTwoPhaseTaskName_.c_str(), taskName in LaunchTask()
55 EnqueueTask(const std::shared_ptr<ITaskHandler> &task, PlayerServerTaskType type, const std::string &taskName) EnqueueTask() argument
73 LaunchTask(const std::shared_ptr<ITaskHandler> &task, PlayerServerTaskType type, const std::string &taskName, const std::shared_ptr<ITaskHandler> &cancelTask) 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
191 MarkTaskDone(const std::string &taskName) MarkTaskDone() argument
[all...]
H A Dplayer_server_task_mgr.h51 const std::string &taskName, const std::shared_ptr<ITaskHandler> &cancelTask = nullptr);
53 const std::string &taskName, int32_t seekMode, int32_t seekTime);
55 const std::string &taskName, int32_t speedMode);
56 int32_t SeekContinousTask(const std::shared_ptr<ITaskHandler> &task, const std::string &taskName);
58 int32_t MarkTaskDone(const std::string &taskName);
64 const std::string &taskName);
66 const std::string &taskName, int32_t seekMode, int32_t seekTime);
71 std::string taskName; member
/foundation/ability/form_fwk/test/unittest/frs_form_render_serial_queue_test/
H A Dfrs_form_render_serial_queue_test.cpp121 auto taskName{ "" }; in HWTEST_F()
124 serialQueueTask.ScheduleDelayTask(taskName, execTime, func); in HWTEST_F()
126 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F()
139 auto taskName{ "task1" }; in HWTEST_F()
142 serialQueueTask.ScheduleDelayTask(taskName, execTime, func); in HWTEST_F()
143 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F()
156 auto taskName{ "task2" }; in HWTEST_F()
159 serialQueueTask.ScheduleDelayTask(taskName, execTime, func); in HWTEST_F()
160 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F()
173 auto taskName{ "task00 in HWTEST_F()
[all...]
/foundation/ability/form_fwk/services/form_render_service/src/
H A Dform_render_serial_queue.cpp56 void FormRenderSerialQueue::ScheduleDelayTask(const std::string &taskName, in ScheduleDelayTask() argument
59 HILOG_DEBUG("begin to ScheduleDelayTask %{public}s", taskName.c_str()); in ScheduleDelayTask()
66 taskMap_[taskName] = std::move(task_handle); in ScheduleDelayTask()
70 void FormRenderSerialQueue::CancelDelayTask(const std::string &taskName) in CancelDelayTask() argument
72 HILOG_DEBUG("begin to CancelDelayTask %{public}s", taskName.c_str()); in CancelDelayTask()
74 auto item = taskMap_.find(taskName); in CancelDelayTask()
76 HILOG_DEBUG("invalid task,CancelDelayTask %{public}s failed", taskName.c_str()); in CancelDelayTask()
82 HILOG_ERROR("CancelDelayTask %{public}s failed,errCode:%{public}d", taskName.c_str(), ret); in CancelDelayTask()
85 taskMap_.erase(taskName); in CancelDelayTask()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/unittest/bms_bundle_common_test/
H A Dbms_bundle_common_test.cpp82 std::string taskName = "task"; in HWTEST_F() local
83 serialQueue.CancelDelayTask(taskName); in HWTEST_F()
99 std::string taskName = "task"; in HWTEST_F() local
100 serialQueue.ScheduleDelayTask(taskName, DISCONNECT_DELAY, registerEventListenerFunc); in HWTEST_F()
102 serialQueue.CancelDelayTask(taskName); in HWTEST_F()
118 std::string taskName = "task"; in HWTEST_F() local
121 serialQueue.CancelDelayTask(taskName); in HWTEST_F()
137 std::string taskName = "task"; in HWTEST_F() local
140 serialQueue.CancelDelayTask(taskName); in HWTEST_F()
156 std::string taskName in HWTEST_F() local
[all...]
/foundation/window/window_manager/window_scene/test/unittest/
H A Dws_ffrt_helper_test.cpp72 std::string taskName = "testTask"; in HWTEST_F() local
76 wsFfrtHelper_->SubmitTask(mockTask, taskName, delayTime, qos); in HWTEST_F()
77 bool result = wsFfrtHelper_->IsTaskExisted(taskName); in HWTEST_F()
98 std::string taskName = "testTask" + std::to_string(id); in HWTEST_F()
101 g_wsFfrtHelper->SubmitTask(mockTask, taskName, delayTime, qos); in HWTEST_F()
121 std::string taskName = "testTask"; in HWTEST_F() local
125 wsFfrtHelper_->SubmitTask(mockTask, taskName, delayTime, qos); in HWTEST_F()
126 wsFfrtHelper_->CancelTask(taskName); in HWTEST_F()
127 bool result = wsFfrtHelper_->IsTaskExisted(taskName); in HWTEST_F()
153 std::string taskName in HWTEST_F()
[all...]
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/common/
H A Dserial_queue.cpp38 void SerialQueue::ScheduleDelayTask(const std::string &taskName, uint64_t ms, std::function<void()> func) in ScheduleDelayTask() argument
40 APP_LOGI("begin, taskName %{public}s", taskName.c_str()); in ScheduleDelayTask()
51 taskMap_[taskName] = std::move(task_handle); in ScheduleDelayTask()
55 void SerialQueue::CancelDelayTask(const std::string &taskName) in CancelDelayTask() argument
57 APP_LOGI("begin, taskName %{public}s", taskName.c_str()); in CancelDelayTask()
59 auto item = taskMap_.find(taskName); in CancelDelayTask()
70 taskMap_.erase(taskName); in CancelDelayTask()
/foundation/ability/ability_runtime/test/unittest/runtime_test/
H A Dohos_js_environment_test.cpp61 std::string taskName = "task001"; in HWTEST_F() local
62 auto task = [name = taskName]() { in HWTEST_F()
66 jsEnvImpl->PostTask(task, taskName, delayTime); in HWTEST_F()
67 jsEnvImpl->RemoveTask(taskName); in HWTEST_F()
89 std::string taskName = "syncTask001"; in HWTEST_F() local
91 auto task = [taskName, &taskExecuted]() { in HWTEST_F()
92 TAG_LOGI(AAFwkTag::TEST, "%{public}s called.", taskName.c_str()); in HWTEST_F()
95 jsEnvImpl->PostSyncTask(task, taskName); in HWTEST_F()
/foundation/multimedia/camera_framework/frameworks/js/camera_napi/src/
H A Dcamera_napi_worker_queue_keeper.cpp58 std::shared_ptr<NapiWorkerQueueTask> CameraNapiWorkerQueueKeeper::AcquireWorkerQueueTask(const std::string& taskName) in AcquireWorkerQueueTask() argument
60 auto queueTask = std::make_shared<NapiWorkerQueueTask>(taskName); in AcquireWorkerQueueTask()
71 queueTask->taskName.c_str()); in WorkerLockCondition()
93 queueTask->taskName.c_str(), firstTask->taskName.c_str(), diffTime.count()); in WorkerLockCondition()
101 queueTask->taskName.c_str(), frontTask->taskName.c_str()); in WorkerLockCondition()
128 queueTask->taskName.c_str()); in ConsumeWorkerQueueTask()
/foundation/arkui/ace_engine/frameworks/core/common/
H A Dupdate_config_manager.h51 const std::string& taskName, TaskExecutor::TaskType type = TaskExecutor::TaskType::PLATFORM) in UpdatePromiseConfig()
59 taskExecutor->PostTask(std::move(task), type, taskName); in UpdatePromiseConfig() local
63 const std::string& taskName, TaskExecutor::TaskType type = TaskExecutor::TaskType::PLATFORM) in UpdateConfig()
75 PostUpdateConfigTaskLocked(config, std::move(cancelableTask), container, taskName, type); in UpdateConfig()
90 const RefPtr<Container>& container, const std::string& taskName, TaskExecutor::TaskType type) in PostUpdateConfigTaskLocked()
98 taskExecutor->PostTask(currentTask_.updateTask, type, taskName); in PostUpdateConfigTaskLocked()
50 UpdatePromiseConfig(const T& config, std::function<void()> &&task, const RefPtr<Container>& container, const std::string& taskName, TaskExecutor::TaskType type = TaskExecutor::TaskType::PLATFORM) UpdatePromiseConfig() argument
62 UpdateConfig(const T& config, std::function<void()> &&task, const RefPtr<Container>& container, const std::string& taskName, TaskExecutor::TaskType type = TaskExecutor::TaskType::PLATFORM) UpdateConfig() argument
89 PostUpdateConfigTaskLocked(const T& config, CancelableCallback<void()> &&task, const RefPtr<Container>& container, const std::string& taskName, TaskExecutor::TaskType type) PostUpdateConfigTaskLocked() argument
/foundation/window/window_manager/window_scene/session/host/include/
H A Dws_ffrt_helper.h42 void SubmitTask(std::function<void()>&& task, const std::string& taskName, uint64_t delayTime = 0,
44 void CancelTask(const std::string& taskName);
45 bool IsTaskExisted(const std::string& taskName) const;
/foundation/multimedia/camera_framework/interfaces/kits/js/camera_napi/include/
H A Dcamera_napi_const.h48 explicit NapiWorkerQueueTask(std::string taskName) : taskName(taskName) in NapiWorkerQueueTask()
53 std::string taskName; member
/foundation/multimedia/camera_framework/services/camera_service/src/avcodec/
H A Dmoving_photo_video_cache.cpp63 void MovingPhotoVideoCache::DoMuxerVideo(std::vector<sptr<FrameRecord>> frameRecords, uint64_t taskName, in DoMuxerVideo() argument
74 taskManager_->DoMuxerVideo(frameRecords, taskName, rotation); in DoMuxerVideo()
97 EncodedEndCbFunc encodedEndCbFunc, uint64_t taskName, int32_t rotation) in GetFrameCachedResult()
102 new CachedFrameCallbackHandle(frameRecords, encodedEndCbFunc, taskName, rotation); in GetFrameCachedResult()
136 EncodedEndCbFunc encodedEndCbFunc, uint64_t taskName, int32_t rotation) in CachedFrameCallbackHandle()
137 : encodedEndCbFunc_(encodedEndCbFunc), isAbort_(false), taskName_(taskName), rotation_(rotation) in CachedFrameCallbackHandle()
96 GetFrameCachedResult(std::vector<sptr<FrameRecord>> frameRecords, EncodedEndCbFunc encodedEndCbFunc, uint64_t taskName, int32_t rotation) GetFrameCachedResult() argument
135 CachedFrameCallbackHandle(std::vector<sptr<FrameRecord>> frameRecords, EncodedEndCbFunc encodedEndCbFunc, uint64_t taskName, int32_t rotation) CachedFrameCallbackHandle() argument
/foundation/multimedia/camera_framework/services/camera_service/include/avcodec/
H A Dmoving_photo_video_cache.h50 EncodedEndCbFunc encodedEndCbFunc, uint64_t taskName, int32_t rotation);
51 void DoMuxerVideo(vector<sptr<FrameRecord>> frameRecords, uint64_t taskName, int32_t rotation);
64 EncodedEndCbFunc encodedEndCbFunc, uint64_t taskName, int32_t rotation);
/foundation/ability/form_fwk/services/form_render_service/include/
H A Dform_render_serial_queue.h33 void ScheduleDelayTask(const std::string &taskName, uint32_t ms, std::function<void()> func);
34 void CancelDelayTask(const std::string &taskName);
/foundation/bundlemanager/bundle_framework/services/bundlemgr/include/common/
H A Dserial_queue.h31 void ScheduleDelayTask(const std::string &taskName, uint64_t ms, std::function<void()> func);
32 void CancelDelayTask(const std::string &taskName);
/foundation/communication/netmanager_base/services/netconnmanager/src/
H A Dnet_conn_event_handler.cpp30 bool NetConnEventHandler::PostAsyncTask(const Callback &callback, const std::string& taskName, int64_t delayTime) in PostAsyncTask() argument
32 return AppExecFwk::EventHandler::PostTask(callback, taskName, delayTime, Priority::HIGH); in PostAsyncTask()
/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Dconnection_record.cpp108 std::string taskName("DisconnectTimeout_"); in DisconnectAbility()
109 taskName += std::to_string(recordId_); in DisconnectAbility()
116 handler->SubmitTask(disconnectTask, taskName, disconnectTimeout); in DisconnectAbility()
210 std::string taskName = std::string("DisconnectTimeout_") + std::to_string(recordId_); in ScheduleDisconnectAbilityDone() local
211 handler->CancelTask(taskName); in ScheduleDisconnectAbilityDone()
246 std::string taskName = std::string("ConnectTimeout_") + std::to_string(recordId_); in CancelConnectTimeoutTask() local
247 handler->CancelTask(taskName); in CancelConnectTimeoutTask()
/foundation/multimedia/av_session/frameworks/js/napi/session/src/
H A Dnapi_async_work.cpp84 ctxt->taskName = name; in Enqueue()
100 if (!ctxt->taskName.empty() && ctxt->taskId > INVALID_TASK_ID) { in Enqueue()
101 AVSESSION_TRACE_ASYNC_START("NapiAsyncWork::" + ctxt->taskName, ctxt->taskId); in Enqueue()
116 if (!ctxt->taskName.empty() && ctxt->taskId > INVALID_TASK_ID) { in Enqueue()
117 AVSESSION_TRACE_ASYNC_END("NapiAsyncWork::" + ctxt->taskName, ctxt->taskId); in Enqueue()
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/cycle_task/
H A Dcycle_task.cpp22 CycleTask::CycleTask(std::string taskName, in CycleTask() argument
27 taskName_(taskName), in CycleTask()
/foundation/ability/ability_runtime/frameworks/native/appkit/app_startup/
H A Dstartup_manager.cpp208 auto taskName = taskStack.top(); in AddStartupTask() local
210 auto findResult = startupTasks_.find(taskName); in AddStartupTask()
212 TAG_LOGE(AAFwkTag::STARTUP, "startup task not found %{public}s", taskName.c_str()); in AddStartupTask()
215 taskMap.emplace(taskName, findResult->second); in AddStartupTask()
217 TAG_LOGE(AAFwkTag::STARTUP, "null task:%{public}s", taskName.c_str()); in AddStartupTask()
/foundation/CastEngine/castengine_wifi_display/services/network/eventhandler/
H A Devent_descriptor_listener.cpp51 const std::string &taskName, uint32_t events) in AddFdListener()
67 return ERR_OK == eventHandler->AddFileDescriptorListener(fd, events, listener, taskName); in AddFdListener()
49 AddFdListener(int32_t fd, const std::shared_ptr<FileDescriptorListener> &listener, const std::shared_ptr<OHOS::AppExecFwk::EventHandler> &handler, const std::string &taskName, uint32_t events) AddFdListener() argument
/foundation/window/window_manager/window_scene/common/src/
H A Dtask_scheduler.cpp95 void TaskScheduler::AddExportTask(std::string taskName, Task task) in AddExportTask() argument
100 exportFuncMap_[taskName] = task; in AddExportTask()
/foundation/communication/dsoftbus/core/connection/common/src/
H A Dsoftbus_conn_common.c52 int32_t ConnStartActionAsync(void *arg, void *(*runnable)(void *), const char *taskName) in ConnStartActionAsync() argument
57 attr.taskName = taskName; in ConnStartActionAsync()

Completed in 10 milliseconds

1234