| /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/loopevent/ |
| D | loopevent_unittest.cpp | 48 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper) in TestHandleTaskEvent()
53 static void OnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in OnReceiveRequest()
60 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer,… in ProcessAsyncEvent()
68 static int IncomingConnect(LoopHandle loop, TaskHandle server) in IncomingConnect()
110 TaskHandle clientTaskHandle = nullptr; in StreamTaskTest()
111 …LE_AcceptStreamClient(LE_GetDefaultLoop(), (TaskHandle)serverTask_, &clientTaskHandle, &streamInfo… in StreamTaskTest()
116 (TaskHandle)clientTaskHandle, 0); in StreamTaskTest()
118 (TaskHandle)clientTaskHandle, Event_Read); in StreamTaskTest()
120 TaskHandle clientTaskHandlec = nullptr; in StreamTaskTest()
127 TaskHandle clientTaskHandled = nullptr; in StreamTaskTest()
[all …]
|
| 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()
89 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper) in TestHandleTaskEvent()
94 static void TestOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in TestOnReceiveRequest()
106 static void TestClientOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in TestClientOnReceiveRequest()
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()
140 static int TestTcpIncomingConnect(LoopHandle loop, TaskHandle server) in TestTcpIncomingConnect()
144 TaskHandle stream; in TestTcpIncomingConnect()
157 static int TestPipIncomingConnect(LoopHandle loop, TaskHandle server) in TestPipIncomingConnect()
[all …]
|
| D | loopsignal_unittest.cpp | 59 ((BaseTask *)g_sigHandler)->handleEvent(loopClient, (TaskHandle)&g_sigHandler, Event_Write);
|
| /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_()
139 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint3… in HandleServerEvent_()
158 TaskHandle *taskHandle, const LE_StreamServerInfo *info) in LE_CreateStreamServer()
182 *taskHandle = (TaskHandle)task; in LE_CreateStreamServer()
187 TaskHandle *taskHandle, const LE_StreamInfo *info) in LE_CreateStreamClient()
209 *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_()
98 TaskHandle *taskHandle, LE_ProcessAsyncEvent processAsyncEvent) in LE_CreateAsyncTask()
117 *taskHandle = (TaskHandle)task; in LE_CreateAsyncTask()
122 const TaskHandle taskHandle, uint64_t eventId, const uint8_t *data, uint32_t buffLen) in LE_StartAsyncEvent()
137 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) in LE_StopAsyncTask()
|
| D | le_task.c | 30 int GetSocketFd(const TaskHandle task) in GetSocketFd()
70 task->close((TaskHandle)task); in CloseTask()
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()
188 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseTask()
199 void *LE_GetUserData(TaskHandle handle) in LE_GetUserData()
|
| 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_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 | 31 static void OnClose(const TaskHandle task) in OnClose()
39 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()
98 CONTROL_FD_STATIC int SendMessage(LoopHandle loop, TaskHandle task, const char *message) in SendMessage()
117 CONTROL_FD_STATIC int CmdOnIncommingConnect(const LoopHandle loop, const TaskHandle server) in CmdOnIncommingConnect()
119 TaskHandle client = NULL; in CmdOnIncommingConnect()
|
| D | control_fd_client.c | 67 CONTROL_FD_STATIC void CmdClientOnRecvMessage(const TaskHandle task, const uint8_t *buffer, uint32_… in CmdClientOnRecvMessage()
72 CONTROL_FD_STATIC void CmdOnConnectComplete(const TaskHandle client) in CmdOnConnectComplete()
77 CONTROL_FD_STATIC void CmdOnClose(const TaskHandle task) in CmdOnClose()
87 CONTROL_FD_STATIC void CmdDisConnectComplete(const TaskHandle client) in CmdDisConnectComplete()
92 CONTROL_FD_STATIC void CmdOnSendMessageComplete(const TaskHandle task, const BufferHandle handle) in CmdOnSendMessageComplete()
103 TaskHandle task = NULL; in CmdAgentCreate()
|
| /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);
51 int CheckSocketPermission(const TaskHandle task);
308 static int TestIncommingConnect(const LoopHandle loop, const TaskHandle server) in TestIncommingConnect()
[all …]
|
| /base/startup/appspawn/standard/ |
| D | appspawn_service.h | 55 TaskHandle stream;
70 TaskHandle server;
|
| D | appspawn_service.c | 126 static void OnClose(const TaskHandle taskHandle) in OnClose()
150 static void SendMessageComplete(const TaskHandle taskHandle, BufferHandle handle) in SendMessageComplete()
320 static bool ReceiveRequestDataToDataGroup(const TaskHandle taskHandle, AppSpawnClientExt *client, in ReceiveRequestDataToDataGroup()
342 static bool ReceiveRequestDataToOverlay(const TaskHandle taskHandle, AppSpawnClientExt *client, in ReceiveRequestDataToOverlay()
367 static bool ReceiveRequestDataToHspList(const TaskHandle taskHandle, AppSpawnClientExt *client, in ReceiveRequestDataToHspList()
408 APPSPAWN_STATIC bool ReceiveRequestData(const TaskHandle taskHandle, AppSpawnClientExt *client, in ReceiveRequestData()
477 static void OnReceiveRequest(const TaskHandle taskHandle, const uint8_t *buffer, uint32_t buffLen) in OnReceiveRequest()
514 APPSPAWN_STATIC TaskHandle AcceptClient(const LoopHandle loopHandle, const TaskHandle server, uint3… in AcceptClient()
517 TaskHandle stream; in AcceptClient()
554 static int OnConnection(const LoopHandle loopHandle, const TaskHandle server) in OnConnection()
|
| /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 | 53 int fd = GetSocketFd((const TaskHandle)task); in AddEvent_()
69 int fd = GetSocketFd((const TaskHandle)task); in ModEvent_()
|
| D | le_loop.c | 94 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 | 334 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 | 51 TaskHandle AcceptClient(const LoopHandle loopHandle, const TaskHandle server, uint32_t flags);
52 bool ReceiveRequestData(const TaskHandle taskHandle, AppSpawnClientExt *appProperty,
528 TaskHandle stream = AcceptClient(LE_GetDefaultLoop(), content->server, TASK_TEST); in RunClient()
|
| /base/startup/init/test/unittest/param/ |
| D | param_stub.cpp | 628 void __attribute__((weak))LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent()
|
| D | param_unittest.cpp | 32 static void OnClose(const TaskHandle taskHandle) in OnClose()
|