| /base/startup/init/services/loopevent/include/ |
| D | loop_event.h | 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);
122 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle,
124 LE_STATUS LE_CreateStreamClient(const LoopHandle loopHandle,
[all …]
|
| /base/startup/init/services/loopevent/task/ |
| D | le_asynctask.c | 24 static void DoAsyncEvent_(const LoopHandle loopHandle, AsyncEventTask *asyncTask) in DoAsyncEvent_() argument
26 LE_CHECK(loopHandle != NULL && asyncTask != NULL, return, "Invalid parameters"); in DoAsyncEvent_()
58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() argument
62 DoAsyncEvent_(loopHandle, (AsyncEventTask *)taskHandle); in LE_DoAsyncEvent()
66 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32… in HandleAsyncEvent_() argument
69 EventLoop *loop = (EventLoop *)loopHandle; in HandleAsyncEvent_()
75 DoAsyncEvent_(loopHandle, asyncTask); in HandleAsyncEvent_()
89 static void HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleAsyncTaskClose_() argument
92 CloseTask(loopHandle, task); in HandleAsyncTaskClose_()
93 DelTask((EventLoop *)loopHandle, task); in HandleAsyncTaskClose_()
[all …]
|
| D | le_streamtask.c | 24 static LE_STATUS HandleSendMsg_(const LoopHandle loopHandle, in HandleSendMsg_() argument
27 EventLoop *loop = (EventLoop *)loopHandle; in HandleSendMsg_()
37 FreeBuffer(loopHandle, stream, buffer); in HandleSendMsg_()
48 static LE_STATUS HandleRecvMsg_(const LoopHandle loopHandle, in HandleRecvMsg_() argument
72 FreeBuffer(loopHandle, NULL, buffer); in HandleRecvMsg_()
78 FreeBuffer(loopHandle, NULL, buffer); in HandleRecvMsg_()
82 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t … in HandleStreamEvent_() argument
84 EventLoop *loop = (EventLoop *)loopHandle; in HandleStreamEvent_()
90 status = HandleSendMsg_(loopHandle, handle, stream->sendMessageComplete); in HandleStreamEvent_()
93 status = HandleRecvMsg_(loopHandle, handle, stream->recvMessage); in HandleStreamEvent_()
[all …]
|
| D | le_watchtask.c | 18 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint… in HandleWatcherEvent_() argument
21 EventLoop *loop = (EventLoop *)loopHandle; in HandleWatcherEvent_()
29 watcher = (WatcherTask *)GetTaskByFd((EventLoop *)loopHandle, fd); in HandleWatcherEvent_()
46 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleWatcherTaskClose_() argument
48 CloseTask(loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
49 DelTask((EventLoop *)loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
52 LE_STATUS LE_StartWatcher(const LoopHandle loopHandle, in LE_StartWatcher() argument
55 …LE_CHECK(loopHandle != NULL && watcherHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters… in LE_StartWatcher()
59 …WatcherTask *task = (WatcherTask *)CreateTask(loopHandle, info->fd, &baseInfo, sizeof(WatcherTask)… in LE_StartWatcher()
67 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartWatcher()
[all …]
|
| D | le_task.c | 36 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size) in CreateTask() argument
47 LE_STATUS ret = AddTask((EventLoop *)loopHandle, task); in CreateTask()
56 void CloseTask(const LoopHandle loopHandle, BaseTask *task) in CloseTask() argument
59 LE_CHECK(loopHandle != NULL && task != NULL, return, "Invalid parameters"); in CloseTask()
65 FreeBuffer(loopHandle, stream, (BufferHandle)buffer); in CloseTask()
169 LE_STATUS LE_Send(const LoopHandle loopHandle, in LE_Send() argument
172 EventLoop *loop = (EventLoop *)loopHandle; in LE_Send()
174 LE_FreeBuffer(loopHandle, taskHandle, buffHandle); in LE_Send()
188 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseTask() argument
190 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters"); in LE_CloseTask()
[all …]
|
| D | le_task.h | 127 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size);
128 void CloseTask(const LoopHandle loopHandle, BaseTask *task);
|
| /base/startup/init/services/loopevent/signal/ |
| D | le_signal.c | 42 static void HandleSignalTaskClose_(const LoopHandle loopHandle, const TaskHandle signalHandle) in HandleSignalTaskClose_() argument
45 CloseTask(loopHandle, task); in HandleSignalTaskClose_()
46 DelTask((EventLoop *)loopHandle, task); in HandleSignalTaskClose_()
50 LE_STATUS LE_CreateSignalTask(const LoopHandle loopHandle, SignalHandle *signalHandle, LE_ProcessSi… in LE_CreateSignalTask() argument
52 …LE_CHECK(loopHandle != NULL && signalHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters"… in LE_CreateSignalTask()
59 SignalTask *task = (SignalTask *)CreateTask(loopHandle, sfd, &info, sizeof(SignalTask)); in LE_CreateSignalTask()
70 LE_STATUS LE_AddSignal(const LoopHandle loopHandle, const SignalHandle signalHandle, int signal) in LE_AddSignal() argument
72 …LE_CHECK(loopHandle != NULL && signalHandle != NULL, return LE_INVALID_PARAM, "Invalid parameters"… in LE_AddSignal()
73 EventLoop *loop = (EventLoop *)loopHandle; in LE_AddSignal()
92 LE_STATUS LE_RemoveSignal(const LoopHandle loopHandle, const SignalHandle signalHandle, int signal) in LE_RemoveSignal() argument
[all …]
|
| /base/startup/init/services/loopevent/timer/ |
| D | le_timer.c | 66 static void HandleTimerClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleTimerClose_() argument
69 CloseTask(loopHandle, task); in HandleTimerClose_()
70 DelTask((EventLoop *)loopHandle, task); in HandleTimerClose_()
74 LE_STATUS LE_CreateTimer(const LoopHandle loopHandle, in LE_CreateTimer() argument
77 LE_CHECK(loopHandle != NULL && timer != NULL, return LE_INVALID_PARAM, "Invalid parameters"); in LE_CreateTimer()
86 TimerTask *task = (TimerTask *)CreateTask(loopHandle, fd, &baseInfo, sizeof(TimerTask)); in LE_CreateTimer()
97 LE_STATUS LE_StartTimer(const LoopHandle loopHandle, in LE_StartTimer() argument
100 LE_CHECK(loopHandle != NULL && timer != NULL, return LE_INVALID_PARAM, "Invalid parameters"); in LE_StartTimer()
101 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartTimer()
112 void LE_StopTimer(const LoopHandle loopHandle, const TimerHandle timer) in LE_StopTimer() argument
[all …]
|
| /base/startup/init/services/loopevent/loop/ |
| D | le_loop.c | 161 void LE_CloseLoop(const LoopHandle loopHandle) in LE_CloseLoop() argument
163 LE_CHECK(loopHandle != NULL, return, "Invalid handle"); in LE_CloseLoop()
164 CloseLoop((EventLoop *)loopHandle); in LE_CloseLoop()
165 if ((LoopHandle)g_defaultLoop == loopHandle) { in LE_CloseLoop()
|
| /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() argument
69 BufferHandle handle = LE_CreateBuffer(loopHandle, bufferSize); in SendMessage()
75 LE_FreeBuffer(loopHandle, taskHandle, handle); in SendMessage()
81 int ret = LE_Send(loopHandle, taskHandle, handle, bufferSize); in SendMessage()
|
| /base/startup/appspawn/standard/ |
| D | appspawn_service.c | 514 APPSPAWN_STATIC TaskHandle AcceptClient(const LoopHandle loopHandle, const TaskHandle server, uint3… in AcceptClient() argument
527 LE_STATUS ret = LE_AcceptStreamClient(loopHandle, server, &stream, &info); in AcceptClient()
556 static int OnConnection(const LoopHandle loopHandle, const TaskHandle server) in OnConnection() argument
558 APPSPAWN_CHECK(server != NULL && loopHandle != NULL, return -1, "Error server"); in OnConnection()
559 (void)AcceptClient(loopHandle, server, 0); 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() argument
|
| /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);
|