Home
last modified time | relevance | path

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

/base/startup/init/services/loopevent/task/
H A Dle_asynctask.c58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() argument
60 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in LE_DoAsyncEvent()
62 DoAsyncEvent_(loopHandle, (AsyncEventTask *)taskHandle); in LE_DoAsyncEvent()
67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper) in HandleAsyncEvent_() argument
69 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters"); in HandleAsyncEvent_()
70 LE_LOGV("HandleAsyncEvent_ fd: %d oper 0x%x", GetSocketFd(taskHandle), oper); in HandleAsyncEvent_()
72 AsyncEventTask *asyncTask = (AsyncEventTask *)taskHandle; in HandleAsyncEvent_()
75 int ret = read(GetSocketFd(taskHandle), &eventId, sizeof(eventId)); in HandleAsyncEvent_()
76 LE_LOGV("HandleAsyncEvent_ read fd:%d ret: %d eventId %llu", GetSocketFd(taskHandle), ret, eventId); in HandleAsyncEvent_()
79 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_WRIT in HandleAsyncEvent_()
91 HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) HandleAsyncTaskClose_() argument
108 LE_CreateAsyncTask(const LoopHandle loopHandle, TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent) LE_CreateAsyncTask() argument
132 LE_StartAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle, uint64_t eventId, const uint8_t *data, uint32_t buffLen) LE_StartAsyncEvent() argument
149 LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) LE_StopAsyncTask() argument
[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, uint32_t oper) 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, f in HandleWatcherEvent_()
[all...]
H A Dle_streamtask.c26 const TaskHandle taskHandle, const LE_SendMessageComplete complete) in HandleSendMsg_()
29 StreamTask *stream = (StreamTask *)taskHandle; in HandleSendMsg_()
32 int ret = write(GetSocketFd(taskHandle), buffer->data, buffer->dataSize); in HandleSendMsg_()
34 LE_LOGE("HandleSendMsg_ fd:%d send data size %d %d, err:%d", GetSocketFd(taskHandle), in HandleSendMsg_()
37 LE_LOGV("HandleSendMsg_ fd:%d send data size %d %d", GetSocketFd(taskHandle), buffer->dataSize, ret); in HandleSendMsg_()
40 complete(taskHandle, buffer); in HandleSendMsg_()
46 LE_LOGV("HandleSendMsg_ fd:%d empty wait read", GetSocketFd(taskHandle)); in HandleSendMsg_()
47 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ); in HandleSendMsg_()
54 const TaskHandle taskHandle, const LE_RecvMessage recvMessage, const LE_HandleRecvMsg handleRecvMsg) in HandleRecvMsg_()
62 readLen = handleRecvMsg(taskHandle, buffe in HandleRecvMsg_()
25 HandleSendMsg_(const LoopHandle loopHandle, const TaskHandle taskHandle, const LE_SendMessageComplete complete) HandleSendMsg_() argument
53 HandleRecvMsg_(const LoopHandle loopHandle, const TaskHandle taskHandle, const LE_RecvMessage recvMessage, const LE_HandleRecvMsg handleRecvMsg) HandleRecvMsg_() argument
137 HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) HandleStreamTaskClose_() argument
166 TaskHandle taskHandle = (TaskHandle)connectTask; DumpStreamConnectTaskInfo_() local
201 LE_CreateStreamServer(const LoopHandle loopHandle, TaskHandle *taskHandle, const LE_StreamServerInfo *info) LE_CreateStreamServer() argument
235 LE_CreateStreamClient(const LoopHandle loopHandle, TaskHandle *taskHandle, const LE_StreamInfo *info) LE_CreateStreamClient() argument
263 LE_AcceptStreamClient(const LoopHandle loopHandle, const TaskHandle server, TaskHandle *taskHandle, const LE_StreamInfo *info) LE_AcceptStreamClient() argument
296 LE_CloseStreamTask(const LoopHandle loopHandle, const TaskHandle taskHandle) LE_CloseStreamTask() argument
302 LE_GetSocketFd(const TaskHandle taskHandle) LE_GetSocketFd() argument
[all...]
H A Dle_task.c151 void LE_FreeBuffer(const LoopHandle loop, const TaskHandle taskHandle, const BufferHandle handle) in LE_FreeBuffer() argument
153 FreeBuffer(loop, (StreamTask *)taskHandle, (LE_Buffer *)handle); in LE_FreeBuffer()
170 const TaskHandle taskHandle, const BufferHandle buffHandle, uint32_t buffLen) in LE_Send()
173 LE_CHECK(taskHandle != NULL, return LE_INVALID_TASK, "Invalid task"); in LE_Send()
175 if (((BaseTask *)taskHandle)->flags & TASK_FLAGS_INVALID) { in LE_Send()
176 LE_FreeBuffer(loopHandle, taskHandle, buffHandle); in LE_Send()
181 if (CheckTaskFlags((BaseTask *)taskHandle, TASK_STREAM | TASK_CONNECT)) { in LE_Send()
182 AddBuffer((StreamTask *)taskHandle, buffer); in LE_Send()
183 } else if (CheckTaskFlags((BaseTask *)taskHandle, TASK_EVENT | TASK_ASYNC_EVENT)) { in LE_Send()
184 AddBuffer((StreamTask *)taskHandle, buffe in LE_Send()
169 LE_Send(const LoopHandle loopHandle, const TaskHandle taskHandle, const BufferHandle buffHandle, uint32_t buffLen) LE_Send() argument
190 LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) LE_CloseTask() argument
[all...]
/base/startup/init/interfaces/innerkits/include/
H A Dloop_event.h71 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle);
77 void LE_FreeBuffer(const LoopHandle loopHandle, const TaskHandle taskHandle, const BufferHandle handle);
82 typedef void (*LE_Close)(const TaskHandle taskHandle);
101 typedef void (*LE_SendMessageComplete)(const TaskHandle taskHandle, BufferHandle handle);
102 typedef void (*LE_RecvMessage)(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen);
104 typedef int (*LE_HandleRecvMsg)(const TaskHandle taskHandle, uint8_t* buffer, int bufferSize, int flags);
126 TaskHandle *taskHandle, const LE_StreamServerInfo *info);
128 TaskHandle *taskHandle, const LE_StreamInfo *info);
130 const TaskHandle serverTask, TaskHandle *taskHandle, const LE_StreamInfo *info);
132 const TaskHandle taskHandle, cons
[all...]
/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()
369 TaskNode *task = GetTask(mgr, &mgr->taskList, taskHandle); in ThreadMgrAddExecutor()
370 APPSPAWN_CHECK(task != NULL, return -1, "Invalid thread task %{public}u", taskHandle); in ThreadMgrAddExecutor()
373 APPSPAWN_CHECK(node != NULL, return -1, "Failed to create thread executor for task %{public}u", 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()
364 ThreadMgrAddExecutor(ThreadMgr instance, ThreadTaskHandle taskHandle, TaskExecutor executor, const ThreadContext *context) ThreadMgrAddExecutor() argument
409 TaskSyncExecute(ThreadMgr instance, ThreadTaskHandle taskHandle) TaskSyncExecute() argument
437 TaskExecute(ThreadMgr instance, ThreadTaskHandle taskHandle, TaskFinishProcessor process, const ThreadContext *context) TaskExecute() argument
[all...]
/base/startup/init/test/unittest/loopevent/
H A Dloopserver_unittest.cpp66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *message, ...) 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
120 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer, uint32_t buffLen) in ProcessAsyncEvent() 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 ProcessWatchEventTest(WatcherHandle taskHandle, int fd, uint32_t *events, const void *context) ProcessWatchEventTest() argument
[all...]
H A Dlooptimer_unittest.cpp39 static void Test_ProcessTimer(const TimerHandle taskHandle, void *context) in Test_ProcessTimer() argument
48 static void TimeoutCancel(const TimerHandle taskHandle, void *context) in TimeoutCancel() argument
51 LE_StopTimer(LE_GetDefaultLoop(), taskHandle); in TimeoutCancel() local
H A Dloopevent_unittest.cpp60 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer, uint32_t buffLen)
62 UNUSED(taskHandle);
75 static void ProcessWatchEventTest(WatcherHandle taskHandle, int fd, uint32_t *events, const void *context)
77 UNUSED(taskHandle);
271 static void Test_ProcessTimer(const TimerHandle taskHandle, void *context)
/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()
249 static int HandleRecvMessage(const TaskHandle taskHandle, uint8_t * buffer, int bufferSize, int flags) in HandleRecvMessage() argument
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()
339 OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) OnReceiveRequest() argument
[all...]
/base/startup/init/test/systest/
H A Dloopserver_systest.c251 static void OnClose(const TaskHandle taskHandle) in OnClose() argument
253 MyTask *task = (MyTask *)LE_GetUserData(taskHandle); in OnClose()
260 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect() argument
262 MyTask *task = (MyTask *)LE_GetUserData(taskHandle); in OnDisConnect()
268 OnClose(taskHandle); in OnDisConnect()
271 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete() argument
273 MyTask *task = (MyTask *)LE_GetUserData(taskHandle); in SendMessageComplete()
664 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) in OnReceiveRequest() argument
666 MyTask *task = (MyTask *)LE_GetUserData(taskHandle); in OnReceiveRequest()
669 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); in OnReceiveRequest() local
675 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); OnReceiveRequest() local
717 LE_CloseStreamTask(LE_GetDefaultLoop(), taskHandle); OnReceiveRequest() local
[all...]
/base/startup/appspawn/standard/
H A Dappspawn_service.c62 static void WaitChildTimeout(const TimerHandle taskHandle, void *context);
63 static void ProcessChildResponse(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context);
65 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen);
224 static void OnClose(const TaskHandle taskHandle) in OnClose() argument
229 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); in OnClose()
236 connection->connectionId, LE_GetSocketFd(taskHandle)); in OnClose()
243 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect() argument
245 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); in OnDisConnect()
248 connection->connectionId, LE_GetSocketFd(taskHandle)); in OnDisConnect()
249 OnClose(taskHandle); in OnDisConnect()
252 SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) SendMessageComplete() argument
287 WaitMsgCompleteTimeOut(const TimerHandle taskHandle, void *context) WaitMsgCompleteTimeOut() argument
308 HandleRecvMessage(const TaskHandle taskHandle, uint8_t * buffer, int bufferSize, int flags) HandleRecvMessage() argument
428 OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) OnReceiveRequest() argument
461 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); return); OnReceiveRequest() local
475 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); OnReceiveRequest() local
549 ClosePidfdWatcher(const TaskHandle taskHandle) ClosePidfdWatcher() argument
561 ProcessChildProcessFd(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context) ProcessChildProcessFd() argument
572 LE_CloseTask(LE_GetDefaultLoop(), taskHandle); ProcessChildProcessFd() local
958 WaitChildTimeout(const TimerHandle taskHandle, void *context) WaitChildTimeout() argument
993 ProcessChildResponse(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context) ProcessChildResponse() argument
[all...]
H A Dappspawn_kickdog.c75 static void ProcessTimerHandle(const TimerHandle taskHandle, void *context) in ProcessTimerHandle() argument
/base/startup/init/services/param/include/
H A Dparam_osadp.h107 typedef void (*ProcessTimer)(const struct ParamTimer_ *taskHandle, void *context);
118 typedef void (*ProcessTimer)(const ParamTaskPtr taskHandle, void *context);
/base/startup/init/test/unittest/init/
H A Dinit_unittest.cpp88 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer() argument
113 LE_StopTimer(LE_GetDefaultLoop(), taskHandle); in TestProcessTimer() local
/base/startup/init/interfaces/innerkits/init_module_engine/
H A Dinit_modulemgr.c44 static void DelayedUninstall(const IdleHandle taskHandle, void *context) in DelayedUninstall() argument
/base/startup/appspawn/test/moduletest/
H A Dappspawn_test_cmder.cpp445 ThreadTaskHandle taskHandle = 0; in StartSendMsg() local
446 ret = ThreadMgrAddTask(threadMgr_, &taskHandle); in StartSendMsg()
449 ThreadMgrAddExecutor(threadMgr_, taskHandle, TaskExecutorProc, reinterpret_cast<ThreadContext *>(this)); in StartSendMsg()
451 TaskSyncExecute(threadMgr_, taskHandle); in StartSendMsg()
/base/startup/init/interfaces/innerkits/control_fd/
H A Dcontrol_fd_client.c29 CONTROL_FD_STATIC void ProcessPtyWrite(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context) in ProcessPtyWrite() argument
49 CONTROL_FD_STATIC void ProcessPtyRead(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context) in ProcessPtyRead() argument
/base/startup/init/services/init/standard/
H A Dfd_holder_service.c166 void ProcessFdHoldEvent(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context) in ProcessFdHoldEvent() argument
/base/startup/init/test/unittest/innerkits/
H A Dinnerkits_unittest.cpp41 void ProcessPtyRead(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context);
42 void ProcessPtyWrite(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context);
/base/startup/init/test/unittest/param/
H A Dparam_stub.cpp626 void __attribute__((weak))LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() argument
H A Dparam_unittest.cpp33 static void OnClose(const TaskHandle taskHandle) in OnClose() argument

Completed in 16 milliseconds