/ohos5.0/foundation/ability/ability_runtime/test/unittest/task_handler_wrap_test/ |
H A D | task_handler_wrap_test.cpp | 59 auto taskHandle = queueHandler_->SubmitTask([&input]() { in __anonb5f688920102() variable 75 auto taskHandle = queueHandler_->SubmitTask([&input]() { in __anonb5f688920202() variable 90 auto taskHandle = queueHandler_->SubmitTask([]() {}); in __anonb5f688920302() variable 103 auto taskHandle = queueHandler_->SubmitTask([]() {}, 100); in __anonb5f688920402() variable 117 auto taskHandle = queueHandler_->SubmitTask([&input]() { in __anonb5f688920502() variable 134 auto taskHandle = ffrtHandler_->SubmitTask([&input]() { in __anonb5f688920602() variable 150 auto taskHandle = ffrtHandler_->SubmitTask([&input]() { in __anonb5f688920702() variable 165 auto taskHandle = ffrtHandler_->SubmitTask([]() {}); in __anonb5f688920802() variable 178 auto taskHandle = ffrtHandler_->SubmitTask([]() {}, 100); in __anonb5f688920902() variable
|
/ohos5.0/foundation/ability/ability_runtime/test/mock/task_handler_wrap_mock/include/ |
H A D | mock_task_handler_wrap.h | 43 bool CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override in CancelTaskInner() 47 void WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override {} in WaitTaskInner() 48 bool RemoveTask(const std::string &name, const TaskHandle &taskHandle) in RemoveTask()
|
/ohos5.0/base/startup/init/services/loopevent/task/ |
H A D | le_streamtask.c | 26 const TaskHandle taskHandle, const LE_SendMessageComplete complete) in HandleSendMsg_() 54 …const TaskHandle taskHandle, const LE_RecvMessage recvMessage, const LE_HandleRecvMsg handleRecvMs… in HandleRecvMsg_() 136 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleStreamTaskClose_() 165 TaskHandle taskHandle = (TaskHandle)connectTask; in DumpStreamConnectTaskInfo_() local 201 TaskHandle *taskHandle, const LE_StreamServerInfo *info) in LE_CreateStreamServer() 235 TaskHandle *taskHandle, const LE_StreamInfo *info) in LE_CreateStreamClient() 263 TaskHandle *taskHandle, const LE_StreamInfo *info) in LE_AcceptStreamClient() 295 void LE_CloseStreamTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseStreamTask() 301 int LE_GetSocketFd(const TaskHandle taskHandle) in LE_GetSocketFd()
|
H A D | le_asynctask.c | 58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() 67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32… in HandleAsyncEvent_() 91 static void HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleAsyncTaskClose_() 109 TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent) in LE_CreateAsyncTask() 133 const TaskHandle taskHandle, uint64_t eventId, const uint8_t *data, uint32_t buffLen) in LE_StartAsyncEvent() 149 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) in LE_StopAsyncTask()
|
H A D | le_watchtask.c | 18 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleWatcherTaskClose_() 25 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint… in HandleWatcherEvent_()
|
H A D | le_task.c | 151 void LE_FreeBuffer(const LoopHandle loop, const TaskHandle taskHandle, const BufferHandle handle) in LE_FreeBuffer() 170 const TaskHandle taskHandle, const BufferHandle buffHandle, uint32_t buffLen) in LE_Send() 190 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseTask()
|
/ohos5.0/foundation/ability/ability_runtime/services/common/src/ |
H A D | ffrt_task_handler_wrap.cpp | 29 bool FfrtTaskHandlerWrap::CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in CancelTaskInner() 37 void FfrtTaskHandlerWrap::WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in WaitTaskInner()
|
H A D | queue_task_handler_wrap.cpp | 39 bool QueueTaskHandlerWrap::CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in CancelTaskInner() 46 void QueueTaskHandlerWrap::WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in WaitTaskInner()
|
H A D | ffrt_task_utils_wrap.h | 27 explicit InnerTaskHandle(ffrt::task_handle &&taskHandle) in InnerTaskHandle()
|
H A D | task_handler_wrap.cpp | 170 auto taskHandle = it->second; in CancelTask() local 179 bool TaskHandlerWrap::RemoveTask(const std::string &name, const TaskHandle &taskHandle) in RemoveTask()
|
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/common/ |
H A D | rs_thread_handler_generic.cpp | 67 void RSThreadHandlerGeneric::PostTask(const RSTaskHandle taskHandle, int param) in PostTask() 78 void RSThreadHandlerGeneric::PostTaskDelay(const RSTaskHandle taskHandle, int64_t nsecs, int param) in PostTaskDelay() 89 void RSThreadHandlerGeneric::CancelTask(RSTaskHandle taskHandle) in CancelTask()
|
/ohos5.0/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/common/ |
H A D | rs_thread_handler_generic_test.cpp | 77 RSTaskHandle taskHandle = generic->CreateTask(task); variable 96 RSTaskHandle taskHandle = generic->CreateTask(task); variable 115 RSTaskHandle taskHandle = generic->CreateTask(task); variable
|
/ohos5.0/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/fuzztest/rsthreadhandlergeneric_fuzzer/ |
H A D | rsthreadhandlergeneric_fuzzer.cpp | 82 auto taskHandle = std::make_shared<RSTaskMessage>(); in DoPostTask() local 99 auto taskHandle = std::make_shared<RSTaskMessage>(); in DoPostTaskDelay() local 114 auto taskHandle = std::make_shared<RSTaskMessage>(); in DoCancelTask() local
|
/ohos5.0/base/startup/init/test/unittest/loopevent/ |
H A D | loopserver_unittest.cpp | 66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *messa… in SendMessage() 85 static void TestOnClose(const TaskHandle taskHandle) in TestOnClose() 120 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer,… in ProcessAsyncEvent() 128 static void TestSendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in TestSendMessageComplete() 185 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer() 212 static void ProcessWatchEventTest(WatcherHandle taskHandle, int fd, uint32_t *events, const void *c… in ProcessWatchEventTest()
|
H A D | looptimer_unittest.cpp | 39 static void Test_ProcessTimer(const TimerHandle taskHandle, void *context) in Test_ProcessTimer() 48 static void TimeoutCancel(const TimerHandle taskHandle, void *context) in TimeoutCancel()
|
H A D | loopevent_unittest.cpp | 60 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer,… in ProcessAsyncEvent() 75 static void ProcessWatchEventTest(WatcherHandle taskHandle, int fd, uint32_t *events, const void *c… in ProcessWatchEventTest() 271 static void Test_ProcessTimer(const TimerHandle taskHandle, void *context) in Test_ProcessTimer()
|
/ohos5.0/foundation/ability/form_fwk/test/unittest/frs_form_render_serial_queue_test/ |
H A D | frs_form_render_serial_queue_test.cpp | 126 auto taskHandle = serialQueueTask.taskMap_.find(taskName); variable 143 auto taskHandle = serialQueueTask.taskMap_.find(taskName); variable 160 auto taskHandle = serialQueueTask.taskMap_.find(taskName); variable
|
/ohos5.0/base/startup/init/test/unittest/init/ |
H A D | init_unittest.cpp | 90 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer()
|
/ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packagegroup/src/ |
H A D | bundle_active_group_handler.cpp | 133 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([groupHandler, eventId, handlerobj]() { in SendEvent() local 169 auto taskHandle = ffrtQueue_->submit_h(fuc); in PostSyncTask() local
|
/ohos5.0/base/startup/appspawn/standard/ |
H A D | appspawn_kickdog.c | 75 static void ProcessTimerHandle(const TimerHandle taskHandle, void *context) in ProcessTimerHandle()
|
H A D | appspawn_service.c | 215 static void OnClose(const TaskHandle taskHandle) in OnClose() 234 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect() 243 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete() 278 static void WaitMsgCompleteTimeOut(const TimerHandle taskHandle, void *context) in WaitMsgCompleteTimeOut() 299 static int HandleRecvMessage(const TaskHandle taskHandle, uint8_t * buffer, int bufferSize, int fla… in HandleRecvMessage() 419 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) in OnReceiveRequest() 541 static void ClosePidfdWatcher(const TaskHandle taskHandle) in ClosePidfdWatcher() 553 static void ProcessChildProcessFd(const WatcherHandle taskHandle, int fd, uint32_t *events, const v… in ProcessChildProcessFd() 950 static void WaitChildTimeout(const TimerHandle taskHandle, void *context) in WaitChildTimeout() 984 static void ProcessChildResponse(const WatcherHandle taskHandle, int fd, uint32_t *events, const vo… in ProcessChildResponse()
|
/ohos5.0/base/startup/init/interfaces/innerkits/control_fd/ |
H A D | control_fd_client.c | 29 CONTROL_FD_STATIC void ProcessPtyWrite(const WatcherHandle taskHandle, int fd, uint32_t *events, co… in ProcessPtyWrite() 49 CONTROL_FD_STATIC void ProcessPtyRead(const WatcherHandle taskHandle, int fd, uint32_t *events, con… in ProcessPtyRead()
|
/ohos5.0/base/startup/appspawn/test/moduletest/threadpool/ |
H A D | thread_manager.c | 338 int ThreadMgrAddTask(ThreadMgr instance, ThreadTaskHandle *taskHandle) in ThreadMgrAddTask() 365 ThreadTaskHandle taskHandle, TaskExecutor executor, const ThreadContext *context) in ThreadMgrAddExecutor() 384 int ThreadMgrCancelTask(ThreadMgr instance, ThreadTaskHandle taskHandle) in ThreadMgrCancelTask() 409 int TaskSyncExecute(ThreadMgr instance, ThreadTaskHandle taskHandle) in TaskSyncExecute() 438 ThreadTaskHandle taskHandle, TaskFinishProcessor process, const ThreadContext *context) in TaskExecute()
|
/ohos5.0/base/startup/appspawn/test/unittest/ |
H A D | app_spawn_test_helper.cpp | 227 void AppSpawnTestServer::ProcessIdle(const TimerHandle taskHandle, void *context) in ProcessIdle() 249 static int HandleRecvMessage(const TaskHandle taskHandle, uint8_t * buffer, int bufferSize, int fla… in HandleRecvMessage() 315 void LocalTestServer::SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete() 320 void LocalTestServer::OnClose(const TaskHandle taskHandle) in OnClose() 339 void LocalTestServer::OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t… in OnReceiveRequest()
|
/ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packageusage/src/ |
H A D | bundle_active_report_handler.cpp | 55 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([reportHandler, eventId, handlerobj]() { in SendEvent() local
|