Home
last modified time | relevance | path

Searched refs:taskHandle (Results 1 – 25 of 45) sorted by relevance

12

/ohos5.0/foundation/ability/ability_runtime/test/unittest/task_handler_wrap_test/
H A Dtask_handler_wrap_test.cpp62 EXPECT_TRUE(taskHandle);
63 taskHandle.Sync();
78 EXPECT_TRUE(taskHandle);
79 taskHandle.Sync();
91 EXPECT_TRUE(taskHandle);
104 EXPECT_TRUE(taskHandle);
121 EXPECT_TRUE(taskHandle);
122 taskHandle.Sync();
137 EXPECT_TRUE(taskHandle);
138 taskHandle.Sync();
[all …]
/ohos5.0/base/startup/init/services/loopevent/task/
H A Dle_asynctask.c60 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in LE_DoAsyncEvent()
62 DoAsyncEvent_(loopHandle, (AsyncEventTask *)taskHandle); in LE_DoAsyncEvent()
72 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in HandleAsyncEvent_()
84 (void)write(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_()
85 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ); in HandleAsyncEvent_()
93 BaseTask *task = (BaseTask *)taskHandle; in HandleAsyncTaskClose_()
109 TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent) in LE_CreateAsyncTask() argument
128 *taskHandle = (TaskHandle)task; in LE_CreateAsyncTask()
146 return LE_Send(loopHandle, taskHandle, handle, buffLen); in LE_StartAsyncEvent()
149 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) in LE_StopAsyncTask() argument
[all …]
H A Dle_streamtask.c29 StreamTask *stream = (StreamTask *)taskHandle; in HandleSendMsg_()
40 complete(taskHandle, buffer); in HandleSendMsg_()
85 recvMessage(taskHandle, buffer->data, readLen); in HandleRecvMsg_()
138 BaseTask *task = (BaseTask *)taskHandle; in HandleStreamTaskClose_()
165 TaskHandle taskHandle = (TaskHandle)connectTask; in DumpStreamConnectTaskInfo_() local
230 *taskHandle = (TaskHandle)task; in LE_CreateStreamServer()
258 *taskHandle = (TaskHandle)task; in LE_CreateStreamClient()
291 *taskHandle = (TaskHandle)task; in LE_AcceptStreamClient()
298 LE_CloseTask(loopHandle, taskHandle); in LE_CloseStreamTask()
301 int LE_GetSocketFd(const TaskHandle taskHandle) in LE_GetSocketFd() argument
[all …]
H A Dle_task.c153 FreeBuffer(loop, (StreamTask *)taskHandle, (LE_Buffer *)handle); in LE_FreeBuffer()
175 if (((BaseTask *)taskHandle)->flags & TASK_FLAGS_INVALID) { in LE_Send()
176 LE_FreeBuffer(loopHandle, taskHandle, buffHandle); in LE_Send()
182 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
184 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
186 loop->modEvent(loop, (BaseTask *)taskHandle, EVENT_WRITE); in LE_Send()
193 if (((LoopBase*)taskHandle)->flags & TASK_TIME) { in LE_CloseTask()
194 LE_StopTimer(loopHandle, taskHandle); in LE_CloseTask()
197 LE_LOGV("LE_CloseTask %d", GetSocketFd(taskHandle)); in LE_CloseTask()
198 BaseTask *task = (BaseTask *)taskHandle; in LE_CloseTask()
[all …]
H A Dle_watchtask.c18 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleWatcherTaskClose_() argument
20 LE_LOGV("HandleWatcherTaskClose_ fd: %d ", GetSocketFd(taskHandle)); in HandleWatcherTaskClose_()
21 DelTask((EventLoop *)loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
22 CloseTask(loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
25 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint… in HandleWatcherEvent_() argument
27 LE_LOGV("HandleWatcherEvent_ fd: %d oper 0x%x", GetSocketFd(taskHandle), oper); in HandleWatcherEvent_()
29 WatcherTask *watcher = (WatcherTask *)taskHandle; in HandleWatcherEvent_()
30 int fd = GetSocketFd(taskHandle); in HandleWatcherEvent_()
32 uint64_t userData = *(uint64_t *)LE_GetUserData(taskHandle); in HandleWatcherEvent_()
34 watcher->processEvent(taskHandle, fd, &events, (void *)userData); in HandleWatcherEvent_()
[all …]
/ohos5.0/base/startup/init/interfaces/innerkits/include/
H A Dloop_event.h71 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle);
82 typedef void (*LE_Close)(const TaskHandle taskHandle);
126 TaskHandle *taskHandle, const LE_StreamServerInfo *info);
128 TaskHandle *taskHandle, const LE_StreamInfo *info);
132 const TaskHandle taskHandle, const BufferHandle handle, uint32_t buffLen);
134 int LE_GetSocketFd(const TaskHandle taskHandle);
139 typedef void (*LE_ProcessAsyncEvent)(const TaskHandle taskHandle,
144 TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent);
149 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle);
156 typedef void (*LE_ProcessTimer)(const TimerHandle taskHandle, void *context);
[all …]
/ohos5.0/foundation/ability/ability_runtime/services/common/src/
H A Dffrt_task_handler_wrap.cpp29 bool FfrtTaskHandlerWrap::CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in CancelTaskInner() argument
31 if (!taskHandle) { in CancelTaskInner()
34 return ffrt::skip(taskHandle->GetFfrtHandle()) == 0; in CancelTaskInner()
37 void FfrtTaskHandlerWrap::WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in WaitTaskInner() argument
39 if (!taskHandle) { in WaitTaskInner()
42 ffrt::wait({taskHandle->GetFfrtHandle()}); in WaitTaskInner()
H A Dqueue_task_handler_wrap.cpp39 bool QueueTaskHandlerWrap::CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in CancelTaskInner() argument
41 if (!taskHandle) { in CancelTaskInner()
44 return taskQueue_.cancel(taskHandle->GetFfrtHandle()) == 0; in CancelTaskInner()
46 void QueueTaskHandlerWrap::WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) in WaitTaskInner() argument
48 if (!taskHandle) { in WaitTaskInner()
51 taskQueue_.wait(taskHandle->GetFfrtHandle()); in WaitTaskInner()
H A Dtask_handler_wrap.cpp122 auto clearTask = [whandler = weak_from_this(), name, taskHandle = result]() { in SubmitTask()
127 handler->RemoveTask(name, taskHandle); in SubmitTask()
170 auto taskHandle = it->second; in CancelTask() local
174 name.c_str(), taskHandle.taskId_, queueName_.c_str()); in CancelTask()
176 return taskHandle.Cancel(); in CancelTask()
179 bool TaskHandlerWrap::RemoveTask(const std::string &name, const TaskHandle &taskHandle) in RemoveTask() argument
183 if (it == tasks_.end() || !it->second.IsSame(taskHandle)) { in RemoveTask()
H A Dffrt_task_handler_wrap.h32 bool CancelTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override;
33 void WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override;
/ohos5.0/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;
/ohos5.0/base/startup/appspawn/test/moduletest/threadpool/
H A Dthread_manager.h37 int ThreadMgrAddTask(ThreadMgr instance, ThreadTaskHandle *taskHandle);
39 ThreadTaskHandle taskHandle, TaskExecutor executor, const ThreadContext *context);
40 int ThreadMgrCancelTask(ThreadMgr instance, ThreadTaskHandle taskHandle);
41 int TaskSyncExecute(ThreadMgr instance, ThreadTaskHandle taskHandle); // 同步执行
43 ThreadTaskHandle taskHandle, TaskFinishProcessor process, const ThreadContext *context);
H A Dthread_manager.c338 int ThreadMgrAddTask(ThreadMgr instance, ThreadTaskHandle *taskHandle) in ThreadMgrAddTask() argument
359 *taskHandle = task->taskId; in ThreadMgrAddTask()
365 ThreadTaskHandle taskHandle, TaskExecutor executor, const ThreadContext *context) in ThreadMgrAddExecutor() argument
369 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); in ThreadMgrAddExecutor()
384 int ThreadMgrCancelTask(ThreadMgr instance, ThreadTaskHandle taskHandle) in ThreadMgrCancelTask() argument
388 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); in ThreadMgrCancelTask()
394 task = GetTask(mgr, &mgr->waitingTaskQueue, taskHandle); in ThreadMgrCancelTask()
400 task = GetTask(mgr, &mgr->executingTaskQueue, taskHandle); in ThreadMgrCancelTask()
409 int TaskSyncExecute(ThreadMgr instance, ThreadTaskHandle taskHandle) in TaskSyncExecute() argument
413 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); in TaskSyncExecute()
[all …]
/ohos5.0/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); variable
78 generic->PostTask(taskHandle, 1);
96 RSTaskHandle taskHandle = generic->CreateTask(task); variable
97 generic->PostTaskDelay(taskHandle, 1, 1);
115 RSTaskHandle taskHandle = generic->CreateTask(task); variable
116 generic->CancelTask(taskHandle);
/ohos5.0/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()
/ohos5.0/base/startup/init/test/unittest/loopevent/
H A Dloopserver_unittest.cpp66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *messa… in SendMessage() argument
75 LE_FreeBuffer(loopHandle, taskHandle, handle); in SendMessage()
81 int ret = LE_Send(loopHandle, taskHandle, handle, bufferSize); in SendMessage()
85 static void TestOnClose(const TaskHandle taskHandle) in TestOnClose() argument
122 UNUSED(taskHandle); in ProcessAsyncEvent()
128 static void TestSendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in TestSendMessageComplete() argument
185 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer() argument
196 LE_StopTimer(g_loopClient_, taskHandle); in TestProcessTimer()
207 LE_StopTimer(g_loopClient_, taskHandle); in TestProcessTimer()
212 static void ProcessWatchEventTest(WatcherHandle taskHandle, int fd, uint32_t *events, const void *c… in ProcessWatchEventTest() argument
[all …]
/ohos5.0/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); variable
127 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end());
143 auto taskHandle = serialQueueTask.taskMap_.find(taskName); variable
144 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end());
160 auto taskHandle = serialQueueTask.taskMap_.find(taskName); variable
161 EXPECT_TRUE(taskHandle != serialQueueTask.taskMap_.end());
/ohos5.0/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 in CancelTaskInner() argument
47 void WaitTaskInner(const std::shared_ptr<InnerTaskHandle> &taskHandle) override {} in WaitTaskInner() argument
48 bool RemoveTask(const std::string &name, const TaskHandle &taskHandle) in RemoveTask() argument
/ohos5.0/docs/zh-cn/release-notes/changelogs/OpenHarmony_5.0.0.36/
H A Dchangelogs-arkcompiler.md89 async function taskHandle(sendable: SendableClass) {
93 taskpool.execute(new taskpool.Task(taskHandle, new SendableClass()));
112 async function taskHandle(sendable: SendableClass) {
116 taskpool.execute(new taskpool.Task(taskHandle, new SendableClass()));
/ohos5.0/base/startup/appspawn/standard/
H A Dappspawn_service.c215 static void OnClose(const TaskHandle taskHandle) in OnClose() argument
227 connection->connectionId, LE_GetSocketFd(taskHandle)); in OnClose()
234 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect() argument
239 connection->connectionId, LE_GetSocketFd(taskHandle)); in OnDisConnect()
240 OnClose(taskHandle); in OnDisConnect()
301 int socketFd = LE_GetSocketFd(taskHandle); in HandleRecvMessage()
468 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest()
541 static void ClosePidfdWatcher(const TaskHandle taskHandle) in ClosePidfdWatcher() argument
543 int fd = LE_GetSocketFd(taskHandle); in ClosePidfdWatcher()
547 void *p = LE_GetUserData(taskHandle); in ClosePidfdWatcher()
[all …]
/ohos5.0/base/startup/appspawn/test/unittest/
H A Dapp_spawn_test_helper.h192 static void ProcessIdle(const TimerHandle taskHandle, void *context);
194 static void ProcessIdle(const IdleHandle taskHandle, void *context);
246 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle);
247 static void OnClose(const TaskHandle taskHandle);
248 …static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen);
H A Dapp_spawn_test_helper.cpp227 void AppSpawnTestServer::ProcessIdle(const TimerHandle taskHandle, void *context) in ProcessIdle() argument
229 void AppSpawnTestServer::ProcessIdle(const IdleHandle taskHandle, void *context) in ProcessIdle()
251 int socketFd = LE_GetSocketFd(taskHandle); in HandleRecvMessage()
264 AppSpawnConnection *connection = (AppSpawnConnection *) LE_GetUserData(taskHandle); in HandleRecvMessage()
315 void LocalTestServer::SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete() argument
320 void LocalTestServer::OnClose(const TaskHandle taskHandle) in OnClose() argument
322 TestConnection *connection = (TestConnection *)LE_GetUserData(taskHandle); in OnClose()
325 connection->connectionId, LE_GetSocketFd(taskHandle)); in OnClose()
327 AppSpawnConnection *spawnConnection = (AppSpawnConnection *) LE_GetUserData(taskHandle); in OnClose()
341 TestConnection *connection = (TestConnection *)LE_GetUserData(taskHandle); in OnReceiveRequest()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/sync/
H A Dpoller_api.cpp88 uint64_t ffrt_epoll_get_wait_time(void* taskHandle)
90 if (taskHandle == nullptr) {
95 auto task = reinterpret_cast<ffrt::CPUEUTask*>(taskHandle);
/ohos5.0/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()

12