Home
last modified time | relevance | path

Searched refs:taskHandle (Results 1 - 20 of 20) sorted by relevance

/foundation/ability/ability_runtime/test/unittest/task_handler_wrap_test/
H A Dtask_handler_wrap_test.cpp59 auto taskHandle = queueHandler_->SubmitTask([&input]() { in HWTEST_F() local
62 EXPECT_TRUE(taskHandle); in HWTEST_F()
63 taskHandle.Sync(); in HWTEST_F()
75 auto taskHandle = queueHandler_->SubmitTask([&input]() { in HWTEST_F() local
78 EXPECT_TRUE(taskHandle); in HWTEST_F()
79 taskHandle.Sync(); in HWTEST_F()
90 auto taskHandle = queueHandler_->SubmitTask([]() {}); in HWTEST_F() local
91 EXPECT_TRUE(taskHandle); in HWTEST_F()
92 auto result = taskHandle.Cancel(); in HWTEST_F()
103 auto taskHandle in HWTEST_F() local
117 auto taskHandle = queueHandler_->SubmitTask([&input]() { HWTEST_F() local
134 auto taskHandle = ffrtHandler_->SubmitTask([&input]() { HWTEST_F() local
150 auto taskHandle = ffrtHandler_->SubmitTask([&input]() { HWTEST_F() local
165 auto taskHandle = ffrtHandler_->SubmitTask([]() {}); HWTEST_F() local
178 auto taskHandle = ffrtHandler_->SubmitTask([]() {}, 100); HWTEST_F() local
[all...]
/foundation/ability/ability_runtime/services/common/src/
H A Dffrt_task_handler_wrap.cpp33 bool FfrtTaskHandlerWrap::CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in CancelTaskInner() argument
35 if (!taskHandle) { in CancelTaskInner()
38 return ffrt::skip(taskHandle->GetFfrtHandle()) == 0; in CancelTaskInner()
41 void FfrtTaskHandlerWrap::WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in WaitTaskInner() argument
43 if (!taskHandle) { in WaitTaskInner()
46 ffrt::wait({taskHandle->GetFfrtHandle()}); in WaitTaskInner()
H A Dqueue_task_handler_wrap.cpp45 bool QueueTaskHandlerWrap::CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in CancelTaskInner() argument
47 if (!taskHandle) { in CancelTaskInner()
50 return taskQueue_.cancel(taskHandle->GetFfrtHandle()) == 0; in CancelTaskInner()
52 void QueueTaskHandlerWrap::WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in WaitTaskInner() argument
54 if (!taskHandle) { in WaitTaskInner()
57 taskQueue_.wait(taskHandle->GetFfrtHandle()); in WaitTaskInner()
H A Dffrt_task_handler_wrap.h31 bool CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override;
32 void WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override;
H A Dtask_handler_wrap.cpp125 auto clearTask = [whandler = weak_from_this(), name, taskHandle = result]() { in SubmitTask()
130 handler->RemoveTask(name, taskHandle); in SubmitTask()
159 auto taskHandle = it->second; in CancelTask() local
161 return taskHandle.Cancel(); in CancelTask()
164 bool TaskHandlerWrap::RemoveTask(const std::string &name, const TaskHandle &taskHandle) in RemoveTask() argument
168 if (it == tasks_.end() || !it->second.IsSame(taskHandle)) { in RemoveTask()
H A Dffrt_task_utils_wrap.h27 explicit InnerTaskHandle(ffrt::task_handle &&taskHandle) in InnerTaskHandle() argument
28 : taskHandle_(std::move(taskHandle)) {} in InnerTaskHandle()
H A Dqueue_task_handler_wrap.h33 bool CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override;
34 void WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override;
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/common/
H A Drs_thread_handler_generic.cpp67 void RSThreadHandlerGeneric::PostTask(const RSTaskHandle taskHandle, int param) in PostTask() argument
72 auto* msg = static_cast<GenericThreadMessage*>(taskHandle.get()); in PostTask()
78 void RSThreadHandlerGeneric::PostTaskDelay(const RSTaskHandle taskHandle, int64_t nsecs, int param) in PostTaskDelay() argument
83 auto* msg = static_cast<GenericThreadMessage*>(taskHandle.get()); in PostTaskDelay()
89 void RSThreadHandlerGeneric::CancelTask(RSTaskHandle taskHandle) in CancelTask() argument
94 auto* msg = static_cast<GenericThreadMessage*>(taskHandle.get()); in CancelTask()
H A Drs_thread_handler_generic.h31 void PostTask(const RSTaskHandle taskHandle, int param) override;
32 void PostTaskDelay(const RSTaskHandle taskHandle, int64_t nsecs, int param) override;
33 void CancelTask(RSTaskHandle taskHandle) override;
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/common/
H A Drs_thread_handler_generic_test.cpp77 RSTaskHandle taskHandle = generic->CreateTask(task); in HWTEST_F() local
78 generic->PostTask(taskHandle, 1); in HWTEST_F()
96 RSTaskHandle taskHandle = generic->CreateTask(task); in HWTEST_F() local
97 generic->PostTaskDelay(taskHandle, 1, 1); in HWTEST_F()
115 RSTaskHandle taskHandle = generic->CreateTask(task); in HWTEST_F() local
116 generic->CancelTask(taskHandle); in HWTEST_F()
/foundation/ability/ability_runtime/test/mock/task_handler_wrap_mock/include/
H A Dmock_task_handler_wrap.h43 bool CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override
47 void WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override {}
48 bool RemoveTask(const std::string &name, const TaskHandle &taskHandle) in RemoveTask() argument
/foundation/ability/form_fwk/test/unittest/frs_form_render_serial_queue_test/
H A Dfrs_form_render_serial_queue_test.cpp126 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F() local
127 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end()); in HWTEST_F()
143 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F() local
144 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end()); in HWTEST_F()
160 auto taskHandle = serialQueueTask.taskMap_.find(taskName); in HWTEST_F() local
161 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end()); in HWTEST_F()
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/fuzztest/rsthreadhandlergeneric_fuzzer/
H A Drsthreadhandlergeneric_fuzzer.cpp82 auto taskHandle = std::make_shared<RSTaskMessage>(); in DoPostTask() local
83 rsThreadHandlerGeneric->PostTask(taskHandle, param); in DoPostTask()
99 auto taskHandle = std::make_shared<RSTaskMessage>(); in DoPostTaskDelay() local
100 rsThreadHandlerGeneric->PostTaskDelay(taskHandle, nsecs, param); in DoPostTaskDelay()
114 auto taskHandle = std::make_shared<RSTaskMessage>(); in DoCancelTask() local
115 rsThreadHandlerGeneric->CancelTask(taskHandle); in DoCancelTask()
/foundation/resourceschedule/ffrt/src/sync/
H A Dpoller_api.cpp88 uint64_t ffrt_epoll_get_wait_time(void* taskHandle) in ffrt_epoll_get_wait_time() argument
90 if (taskHandle == nullptr) { in ffrt_epoll_get_wait_time()
95 auto task = reinterpret_cast<ffrt::CPUEUTask*>(taskHandle); in ffrt_epoll_get_wait_time()
/foundation/ability/ability_runtime/services/common/include/
H A Dtask_handler_wrap.h94 virtual bool CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) = 0;
95 virtual void WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) = 0;
96 bool RemoveTask(const std::string &name, const TaskHandle &taskHandle);
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/fuzztest/rsbasecommon_fuzzer/
H A Drsbasecommon_fuzzer.cpp195 std::shared_ptr<RSTaskMessage> taskHandle = std::make_shared<RSTaskMessage>(); in RSThreadHandlerGenericFuzzTest() local
202 rsthreadhandlergeneric.PostTask(taskHandle, param); in RSThreadHandlerGenericFuzzTest()
203 rsthreadhandlergeneric.PostTaskDelay(taskHandle, nsecs, param); in RSThreadHandlerGenericFuzzTest()
204 rsthreadhandlergeneric.CancelTask(taskHandle); in RSThreadHandlerGenericFuzzTest()
/foundation/resourceschedule/device_usage_statistics/services/packagegroup/src/
H A Dbundle_active_group_handler.cpp133 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([groupHandler, eventId, handlerobj]() { in SendEvent() local
143 taskHandlerMap_[eventId].push(std::move(taskHandle)); in SendEvent()
169 auto taskHandle = ffrtQueue_->submit_h(fuc); in PostSyncTask() local
170 ffrtQueue_->wait(taskHandle); in PostSyncTask()
/foundation/resourceschedule/device_usage_statistics/services/packageusage/src/
H A Dbundle_active_report_handler.cpp56 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([reportHandler, eventId, handlerobj]() { in SendEvent() local
66 taskHandlerMap_[eventId].push(std::move(taskHandle)); in SendEvent()
/foundation/resourceschedule/ffrt/interfaces/inner_api/c/
H A Dexecutor_task.h55 FFRT_C_API uint64_t ffrt_epoll_get_wait_time(void* taskHandle);
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_csync.cpp260 ffrt::task_handle taskHandle; in HWTEST_F() member
274 ffrt::task_handle* handleAddr = &m.taskHandle; in HWTEST_F()

Completed in 7 milliseconds