| /base/startup/init/services/loopevent/task/ |
| 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()
|
| 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()
|
| 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_()
|
| 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()
|
| /base/startup/init/test/unittest/loopevent/ |
| 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()
|
| 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()
|
| 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()
|
| /base/startup/appspawn/standard/ |
| D | appspawn_service.c | 201 static void OnClose(const TaskHandle taskHandle) in OnClose()
220 static void OnDisConnect(const TaskHandle taskHandle) in OnDisConnect()
229 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete()
264 static void WaitMsgCompleteTimeOut(const TimerHandle taskHandle, void *context) in WaitMsgCompleteTimeOut()
285 static int HandleRecvMessage(const TaskHandle taskHandle, uint8_t * buffer, int bufferSize, int fla… in HandleRecvMessage()
363 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) in OnReceiveRequest()
482 static void ClosePidfdWatcher(const TaskHandle taskHandle) in ClosePidfdWatcher()
494 static void ProcessChildProcessFd(const WatcherHandle taskHandle, int fd, uint32_t *events, const v… in ProcessChildProcessFd()
893 static void WaitChildTimeout(const TimerHandle taskHandle, void *context) in WaitChildTimeout()
910 static void ProcessChildResponse(const WatcherHandle taskHandle, int fd, uint32_t *events, const vo… in ProcessChildResponse()
|
| D | appspawn_kickdog.c | 75 static void ProcessTimerHandle(const TimerHandle taskHandle, void *context) in ProcessTimerHandle()
|
| /base/startup/init/test/unittest/init/ |
| D | init_unittest.cpp | 90 static void TestProcessTimer(const TimerHandle taskHandle, void *context) in TestProcessTimer()
|
| /base/startup/appspawn/test/moduletest/threadpool/ |
| 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()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| 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()
|
| /base/startup/appspawn/test/unittest/ |
| 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()
|
| /base/startup/init/interfaces/innerkits/init_module_engine/ |
| D | init_modulemgr.c | 44 static void DelayedUninstall(const IdleHandle taskHandle, void *context) in DelayedUninstall()
|
| /base/startup/init/services/init/standard/ |
| D | fd_holder_service.c | 166 void ProcessFdHoldEvent(const WatcherHandle taskHandle, int fd, uint32_t *events, const void *conte… in ProcessFdHoldEvent()
|
| /base/startup/init/test/unittest/param/ |
| D | param_unittest.cpp | 33 static void OnClose(const TaskHandle taskHandle) in OnClose()
|
| D | param_stub.cpp | 626 void __attribute__((weak))LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent()
|
| /base/startup/appspawn/test/moduletest/ |
| D | appspawn_test_cmder.cpp | 445 ThreadTaskHandle taskHandle = 0; in StartSendMsg() local
|