| /base/startup/init/services/loopevent/include/ |
| D | loop_event.h | 60 typedef LoopBase *TaskHandle; typedef
71 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle);
77 void LE_FreeBuffer(const LoopHandle loopHandle, const TaskHandle taskHandle, const BufferHandle han…
79 void *LE_GetUserData(const TaskHandle handle);
82 typedef void (*LE_Close)(const TaskHandle taskHandle);
98 typedef void (*LE_DisConnectComplete)(const TaskHandle client);
99 typedef void (*LE_ConnectComplete)(const TaskHandle client);
100 typedef void (*LE_SendMessageComplete)(const TaskHandle taskHandle, BufferHandle handle);
101 typedef void (*LE_RecvMessage)(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen…
102 typedef int (*LE_IncommingConnect)(const LoopHandle loopHandle, const TaskHandle serverTask);
[all …]
|
| /base/startup/init/test/unittest/init/ |
| D | loopevent_unittest.cpp | 51 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper) in TestHandleTaskEvent()
56 static void OnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in OnReceiveRequest()
63 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer,… in ProcessAsyncEvent()
71 static int IncomingConnect(LoopHandle loop, TaskHandle server) in IncomingConnect()
112 TaskHandle clientTaskHandle = nullptr; in StreamTaskTest()
113 …LE_AcceptStreamClient(LE_GetDefaultLoop(), (TaskHandle)serverTask_, &clientTaskHandle, &streamInfo… in StreamTaskTest()
118 (TaskHandle)clientTaskHandle, Event_Read); in StreamTaskTest()
120 (TaskHandle)clientTaskHandle, Event_Write); in StreamTaskTest()
123 (TaskHandle)clientTaskHandle, 0); in StreamTaskTest()
127 TaskHandle clientTaskHandleb = nullptr; in StreamTaskTest()
[all …]
|
| D | SignalInitUnitTest.cpp | 56 …((BaseTask *)g_sigHandler)->handleEvent(LE_GetDefaultLoop(), (TaskHandle)&g_sigHandler, Event_Writ…
|
| /base/startup/init/services/loopevent/task/ |
| D | le_streamtask.c | 25 const TaskHandle taskHandle, const LE_SendMessageComplete complete) in HandleSendMsg_()
49 const TaskHandle taskHandle, const LE_RecvMessage recvMessage) in HandleRecvMsg_()
82 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t … in HandleStreamEvent_()
105 static LE_STATUS HandleClientEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t … in HandleClientEvent_()
129 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleStreamTaskClose_()
138 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint3… in HandleServerEvent_()
157 TaskHandle *taskHandle, const LE_StreamServerInfo *info) in LE_CreateStreamServer()
181 *taskHandle = (TaskHandle)task; in LE_CreateStreamServer()
186 TaskHandle *taskHandle, const LE_StreamInfo *info) in LE_CreateStreamClient()
208 *taskHandle = (TaskHandle)task; in LE_CreateStreamClient()
[all …]
|
| D | le_asynctask.c | 39 asyncTask->processAsyncEvent((TaskHandle)asyncTask, eventId, in DoAsyncEvent_()
58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent()
66 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32… in HandleAsyncEvent_()
89 static void HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleAsyncTaskClose_()
97 TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent) in LE_CreateAsyncTask()
116 *taskHandle = (TaskHandle)task; in LE_CreateAsyncTask()
121 const TaskHandle taskHandle, uint64_t eventId, const uint8_t *data, uint32_t buffLen) in LE_StartAsyncEvent()
136 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) in LE_StopAsyncTask()
|
| D | le_task.h | 52 typedef LE_STATUS (*HandleTaskEvent)(const LoopHandle loop, const TaskHandle task, uint32_t oper);
53 typedef void (*HandleTaskClose)(const LoopHandle loop, const TaskHandle task);
129 int GetSocketFd(const TaskHandle task);
|
| D | le_task.c | 30 int GetSocketFd(const TaskHandle task) in GetSocketFd()
70 task->close((TaskHandle)task); in CloseTask()
152 void LE_FreeBuffer(const LoopHandle loop, const TaskHandle taskHandle, const BufferHandle handle) in LE_FreeBuffer()
171 const TaskHandle taskHandle, const BufferHandle buffHandle, uint32_t buffLen) in LE_Send()
189 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseTask()
200 void *LE_GetUserData(TaskHandle handle) in LE_GetUserData()
|
| D | le_watchtask.c | 18 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint… in HandleWatcherEvent_()
46 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleWatcherTaskClose_()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd.h | 45 TaskHandle serverTask;
50 TaskHandle task;
57 TaskHandle task;
|
| D | control_fd_service.c | 30 static void OnClose(const TaskHandle task) in OnClose()
38 CONTROL_FD_STATIC int CheckSocketPermission(const TaskHandle task) in CheckSocketPermission()
55 CONTROL_FD_STATIC void CmdOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_t buff… in CmdOnRecvMessage()
100 CONTROL_FD_STATIC int SendMessage(LoopHandle loop, TaskHandle task, const char *message) in SendMessage()
119 CONTROL_FD_STATIC int CmdOnIncommingConnect(const LoopHandle loop, const TaskHandle server) in CmdOnIncommingConnect()
121 TaskHandle client = NULL; in CmdOnIncommingConnect()
|
| D | control_fd_client.c | 66 CONTROL_FD_STATIC void CmdClientOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_… in CmdClientOnRecvMessage()
71 CONTROL_FD_STATIC void CmdOnConnectComplete(const TaskHandle client) in CmdOnConnectComplete()
76 CONTROL_FD_STATIC void CmdOnClose(const TaskHandle task) in CmdOnClose()
86 CONTROL_FD_STATIC void CmdDisConnectComplete(const TaskHandle client) in CmdDisConnectComplete()
91 CONTROL_FD_STATIC void CmdOnSendMessageComplete(const TaskHandle task, const BufferHandle handle) in CmdOnSendMessageComplete()
102 TaskHandle task = NULL; in CmdAgentCreate()
|
| /base/startup/appspawn/standard/ |
| D | appspawn_service.h | 48 TaskHandle stream;
63 TaskHandle server;
|
| D | appspawn_service.c | 132 static void OnClose(const TaskHandle taskHandle) in OnClose()
138 APPSPAWN_STATIC void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete()
343 APPSPAWN_STATIC void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t … in OnReceiveRequest()
418 TaskHandle g_testClientHandle = NULL;
419 TaskHandle GetTestClientHandle() in GetTestClientHandle()
424 APPSPAWN_STATIC int OnConnection(const LoopHandle loopHandle, const TaskHandle server) in OnConnection()
429 TaskHandle stream; in OnConnection()
|
| /base/startup/init/test/unittest/innerkits/ |
| D | innerkits_unittest.cpp | 36 void CmdDisConnectComplete(const TaskHandle client);
37 void CmdOnSendMessageComplete(const TaskHandle task, const BufferHandle handle);
38 void CmdOnClose(const TaskHandle task);
39 void CmdOnConnectComplete(const TaskHandle client);
40 void CmdOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_t buffLen);
44 int CmdOnIncommingConnect(const LoopHandle loop, const TaskHandle server);
46 void CmdClientOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_t buffLen);
48 int SendMessage(LoopHandle loop, TaskHandle task, const char *message);
305 static int TestIncommingConnect(const LoopHandle loop, const TaskHandle server) in TestIncommingConnect()
362 TaskHandle testServer;
|
| /base/startup/init/services/loopevent/timer/ |
| D | le_timer.c | 41 static LE_STATUS HandleTimerEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleTimerEvent_()
66 static void HandleTimerClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleTimerClose_()
|
| /base/startup/init/services/loopevent/signal/ |
| D | le_signal.c | 27 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_()
42 static void HandleSignalTaskClose_(const LoopHandle loopHandle, const TaskHandle signalHandle) in HandleSignalTaskClose_()
|
| /base/startup/init/services/loopevent/loop/ |
| D | le_epoll.c | 51 int fd = GetSocketFd((const TaskHandle)task); in AddEvent_()
67 int fd = GetSocketFd((const TaskHandle)task); in ModEvent_()
|
| D | le_loop.c | 93 task->handleEvent((LoopHandle)loop, (TaskHandle)task, oper); in ProcessEvent()
|
| /base/startup/init/services/param/linux/ |
| D | param_message.h | 105 int OnIncomingConnect(LoopHandle loop, TaskHandle server);
|
| D | param_msgadp.c | 29 static void OnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in OnReceiveRequest()
|
| D | param_service.c | 337 PARAM_STATIC int OnIncomingConnect(LoopHandle loop, TaskHandle server) in OnIncomingConnect()
|
| /base/startup/appspawn/test/unittest/app_spawn_standard_test/ |
| D | app_spawn_standard_test.cpp | 45 int OnConnection(const LoopHandle loopHandle, const TaskHandle server);
47 void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen);
50 void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle);
51 TaskHandle GetTestClientHandle();
|