| /base/startup/init/services/loopevent/include/ |
| D | loop_event.h | 59 typedef LoopBase *LoopHandle; typedef
66 LoopHandle LE_GetDefaultLoop(void);
67 LE_STATUS LE_CreateLoop(LoopHandle *loopHandle);
68 void LE_RunLoop(const LoopHandle loopHandle);
69 void LE_CloseLoop(const LoopHandle loopHandle);
70 void LE_StopLoop(const LoopHandle loopHandle);
71 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle);
76 BufferHandle LE_CreateBuffer(const LoopHandle loopHandle, uint32_t bufferSize);
77 void LE_FreeBuffer(const LoopHandle loopHandle, const TaskHandle taskHandle, const BufferHandle han…
102 typedef int (*LE_IncommingConnect)(const LoopHandle loopHandle, const TaskHandle serverTask);
[all …]
|
| /base/startup/init/services/loopevent/loop/ |
| D | le_loop.c | 49 CloseTask((const LoopHandle)context, task); in TaskNodeFree()
94 task->handleEvent((LoopHandle)loop, (TaskHandle)task, oper); in ProcessEvent()
138 LoopHandle LE_GetDefaultLoop(void) in LE_GetDefaultLoop()
141 LE_CreateLoop((LoopHandle *)&g_defaultLoop); in LE_GetDefaultLoop()
143 return (LoopHandle)g_defaultLoop; in LE_GetDefaultLoop()
146 LE_STATUS LE_CreateLoop(LoopHandle *handle) in LE_CreateLoop()
150 *handle = (LoopHandle)loop; in LE_CreateLoop()
154 void LE_RunLoop(const LoopHandle handle) in LE_RunLoop()
161 void LE_CloseLoop(const LoopHandle loopHandle) in LE_CloseLoop()
165 if ((LoopHandle)g_defaultLoop == loopHandle) { in LE_CloseLoop()
[all …]
|
| /base/startup/init/services/loopevent/task/ |
| 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);
124 void FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer);
127 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size);
128 void CloseTask(const LoopHandle loopHandle, BaseTask *task);
|
| D | le_asynctask.c | 24 static void DoAsyncEvent_(const LoopHandle loopHandle, AsyncEventTask *asyncTask) 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 LE_STATUS LE_CreateAsyncTask(const LoopHandle loopHandle, in LE_CreateAsyncTask()
121 LE_STATUS LE_StartAsyncEvent(const LoopHandle loopHandle, in LE_StartAsyncEvent()
137 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) in LE_StopAsyncTask()
|
| 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_()
52 LE_STATUS LE_StartWatcher(const LoopHandle loopHandle, in LE_StartWatcher()
73 void LE_RemoveWatcher(const LoopHandle loopHandle, const WatcherHandle watcherHandle) in LE_RemoveWatcher()
|
| D | le_streamtask.c | 24 static LE_STATUS HandleSendMsg_(const LoopHandle loopHandle, in HandleSendMsg_()
48 static LE_STATUS HandleRecvMsg_(const LoopHandle loopHandle, 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_()
157 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle, in LE_CreateStreamServer()
186 LE_STATUS LE_CreateStreamClient(const LoopHandle loopHandle, in LE_CreateStreamClient()
213 LE_STATUS LE_AcceptStreamClient(const LoopHandle loopHandle, const TaskHandle server, in LE_AcceptStreamClient()
244 void LE_CloseStreamTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseStreamTask()
|
| D | le_task.c | 36 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size) in CreateTask()
56 void CloseTask(const LoopHandle loopHandle, BaseTask *task) in CloseTask()
130 void FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer) in FreeBuffer()
146 BufferHandle LE_CreateBuffer(const LoopHandle loop, uint32_t bufferSize) in LE_CreateBuffer()
151 void LE_FreeBuffer(const LoopHandle loop, const TaskHandle taskHandle, const BufferHandle handle) in LE_FreeBuffer()
169 LE_STATUS LE_Send(const LoopHandle loopHandle, in LE_Send()
188 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseTask()
|
| /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_()
50 LE_STATUS LE_CreateSignalTask(const LoopHandle loopHandle, SignalHandle *signalHandle, LE_ProcessSi… in LE_CreateSignalTask()
70 LE_STATUS LE_AddSignal(const LoopHandle loopHandle, const SignalHandle signalHandle, int signal) in LE_AddSignal()
92 LE_STATUS LE_RemoveSignal(const LoopHandle loopHandle, const SignalHandle signalHandle, int signal) in LE_RemoveSignal()
111 void LE_CloseSignalTask(const LoopHandle loopHandle, const SignalHandle signalHandle) in LE_CloseSignalTask()
|
| /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_()
74 LE_STATUS LE_CreateTimer(const LoopHandle loopHandle, in LE_CreateTimer()
97 LE_STATUS LE_StartTimer(const LoopHandle loopHandle, in LE_StartTimer()
112 void LE_StopTimer(const LoopHandle loopHandle, const TimerHandle timer) in LE_StopTimer()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd_service.c | 27 static LoopHandle g_controlFdLoop = NULL;
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()
143 void CmdServiceInit(const char *socketPath, CallbackControlFdProcess func, LoopHandle loop) in CmdServiceInit()
|
| D | control_fd.h | 79 void CmdServiceInit(const char *socketPath, CallbackControlFdProcess func, LoopHandle loop);
|
| /base/startup/init/test/unittest/loopevent/ |
| D | loopserver_unittest.cpp | 46 static LoopHandle g_loopClient_ = nullptr;
47 static LoopHandle g_loopServer_ = nullptr;
66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *messa… in SendMessage()
89 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper) in TestHandleTaskEvent()
140 static int TestTcpIncomingConnect(LoopHandle loop, TaskHandle server) in TestTcpIncomingConnect()
157 static int TestPipIncomingConnect(LoopHandle loop, TaskHandle server) in TestPipIncomingConnect()
|
| D | loopsignal_unittest.cpp | 46 static LoopHandle loopClient = nullptr;
|
| D | loopevent_unittest.cpp | 48 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper) in TestHandleTaskEvent()
68 static int IncomingConnect(LoopHandle loop, TaskHandle server) in IncomingConnect()
269 static LoopHandle g_loop = nullptr;
|
| /base/startup/init/services/param/linux/ |
| D | param_message.h | 105 int OnIncomingConnect(LoopHandle loop, TaskHandle server);
|
| D | param_service.c | 334 PARAM_STATIC int OnIncomingConnect(LoopHandle loop, TaskHandle server) in OnIncomingConnect()
|
| /base/startup/init/test/unittest/innerkits/ |
| D | innerkits_unittest.cpp | 44 int CmdOnIncommingConnect(const LoopHandle loop, const TaskHandle server);
48 int SendMessage(LoopHandle loop, TaskHandle task, const char *message);
308 static int TestIncommingConnect(const LoopHandle loop, const TaskHandle server) in TestIncommingConnect()
|
| /base/startup/appspawn/standard/ |
| D | appspawn_service.c | 514 APPSPAWN_STATIC TaskHandle AcceptClient(const LoopHandle loopHandle, const TaskHandle server, uint3… in AcceptClient()
556 static int OnConnection(const LoopHandle loopHandle, const TaskHandle server) in OnConnection()
|
| /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()
|
| /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);
|