/base/startup/appspawn/standard/ |
H A D | appspawn_kickdog.c | 75 static void ProcessTimerHandle(const TimerHandle taskHandle, void *context) in ProcessTimerHandle() argument
|
H A D | appspawn_service.c | 224 static void OnClose(const TaskHandle taskHandle) in OnClose() argument 243 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect() argument 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...] |
/base/startup/init/services/loopevent/task/ |
H A D | le_watchtask.c | 18 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle)
in HandleWatcherTaskClose_() argument 25 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper)
in HandleWatcherEvent_() argument [all...] |
H A D | le_streamtask.c | 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 D | le_task.c | 151 void LE_FreeBuffer(const LoopHandle loop, const TaskHandle taskHandle, const BufferHandle handle)
in LE_FreeBuffer() argument 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...] |
H A D | le_asynctask.c | 58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle)
in LE_DoAsyncEvent() argument 67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper)
in HandleAsyncEvent_() argument 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...] |
/base/startup/init/test/unittest/init/ |
H A D | init_unittest.cpp | 88 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer() argument 113 LE_StopTimer(LE_GetDefaultLoop(), taskHandle); in TestProcessTimer() local
|
/base/startup/init/test/unittest/loopevent/ |
H A D | looptimer_unittest.cpp | 39 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 D | loopserver_unittest.cpp | 66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *message, ...) in SendMessage() argument 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 128 static void TestSendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in TestSendMessageComplete() argument 185 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer() argument 212 ProcessWatchEventTest(WatcherHandle taskHandle, int fd, uint32_t *events, const void *context) ProcessWatchEventTest() argument [all...] |
/base/startup/init/interfaces/innerkits/init_module_engine/ |
H A D | init_modulemgr.c | 44 static void DelayedUninstall(const IdleHandle taskHandle, void *context) in DelayedUninstall() argument
|
/base/startup/init/services/init/standard/ |
H A D | fd_holder_service.c | 166 void ProcessFdHoldEvent(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *context) in ProcessFdHoldEvent() argument
|
/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, 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/test/unittest/param/ |
H A D | param_unittest.cpp | 33 static void OnClose(const TaskHandle taskHandle) in OnClose() argument
|
H A D | param_stub.cpp | 626 void __attribute__((weak))LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() argument
|
/base/startup/appspawn/test/moduletest/ |
H A D | appspawn_test_cmder.cpp | 445 ThreadTaskHandle taskHandle = 0; in StartSendMsg() local
|
/base/startup/appspawn/test/moduletest/threadpool/ |
H A D | thread_manager.c | 338 int ThreadMgrAddTask(ThreadMgr instance, ThreadTaskHandle *taskHandle) in ThreadMgrAddTask() argument 384 int ThreadMgrCancelTask(ThreadMgr instance, ThreadTaskHandle taskHandle) in ThreadMgrCancelTask() argument 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/systest/ |
H A D | loopserver_systest.c | 251 static void OnClose(const TaskHandle taskHandle) in OnClose() argument 260 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect() argument 271 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete() argument 664 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) in OnReceiveRequest() argument 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/test/unittest/ |
H A D | app_spawn_test_helper.cpp | 227 void AppSpawnTestServer::ProcessIdle(const TimerHandle taskHandle, void *context) in ProcessIdle() argument 249 static int HandleRecvMessage(const TaskHandle taskHandle, uint8_t * buffer, int bufferSize, int flags) in HandleRecvMessage() argument 315 void LocalTestServer::SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete() argument 320 void LocalTestServer::OnClose(const TaskHandle taskHandle) in OnClose() argument 339 OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) OnReceiveRequest() argument [all...] |