| /ohos5.0/base/startup/init/interfaces/innerkits/include/ |
| H A 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);
125 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle,
131 LE_STATUS LE_Send(const LoopHandle loopHandle,
143 LE_STATUS LE_CreateAsyncTask(const LoopHandle loopHandle,
145 LE_STATUS LE_StartAsyncEvent(const LoopHandle loopHandle,
160 LE_STATUS LE_StartTimer(const LoopHandle loopHandle,
166 LE_STATUS LE_CreateSignalTask(const LoopHandle loopHandle,
[all …]
|
| /ohos5.0/base/startup/init/services/loopevent/task/ |
| H A D | le_streamtask.c | 28 EventLoop *loop = (EventLoop *)loopHandle; in HandleSendMsg_()
42 FreeBuffer(loopHandle, stream, buffer); in HandleSendMsg_()
81 FreeBuffer(loopHandle, NULL, buffer); in HandleRecvMsg_()
87 FreeBuffer(loopHandle, NULL, buffer); in HandleRecvMsg_()
107 LE_CloseStreamTask(loopHandle, handle); in HandleStreamEvent_()
131 LE_CloseStreamTask(loopHandle, handle); in HandleClientEvent_()
139 DelTask((EventLoop *)loopHandle, task); in HandleStreamTaskClose_()
140 CloseTask(loopHandle, task); in HandleStreamTaskClose_()
195 EventLoop *loop = (EventLoop *)loopHandle; in HandleServerEvent_()
218 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateStreamServer()
[all …]
|
| H A D | le_asynctask.c | 62 DoAsyncEvent_(loopHandle, (AsyncEventTask *)taskHandle); in LE_DoAsyncEvent()
71 EventLoop *loop = (EventLoop *)loopHandle; in HandleAsyncEvent_()
77 DoAsyncEvent_(loopHandle, asyncTask); in HandleAsyncEvent_()
94 DelTask((EventLoop *)loopHandle, task); in HandleAsyncTaskClose_()
95 CloseTask(loopHandle, task); in HandleAsyncTaskClose_()
108 LE_STATUS LE_CreateAsyncTask(const LoopHandle loopHandle, in LE_CreateAsyncTask() argument
126 EventLoop *loop = (EventLoop *)loopHandle; in LE_CreateAsyncTask()
132 LE_STATUS LE_StartAsyncEvent(const LoopHandle loopHandle, in LE_StartAsyncEvent() argument
146 return LE_Send(loopHandle, taskHandle, handle, buffLen); in LE_StartAsyncEvent()
149 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) in LE_StopAsyncTask() argument
[all …]
|
| H A D | le_watchtask.c | 18 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleWatcherTaskClose_() argument
21 DelTask((EventLoop *)loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
22 CloseTask(loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
28 EventLoop *loop = (EventLoop *)loopHandle; in HandleWatcherEvent_()
36 watcher = (WatcherTask *)GetTaskByFd((EventLoop *)loopHandle, fd); in HandleWatcherEvent_()
63 LE_STATUS LE_StartWatcher(const LoopHandle loopHandle, in LE_StartWatcher() argument
70 …WatcherTask *task = (WatcherTask *)CreateTask(loopHandle, info->fd, &baseInfo, sizeof(WatcherTask)… in LE_StartWatcher()
79 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartWatcher()
85 void LE_RemoveWatcher(const LoopHandle loopHandle, const WatcherHandle watcherHandle) in LE_RemoveWatcher() argument
87 LE_CHECK(loopHandle != NULL && watcherHandle != NULL, return, "Invalid parameters"); in LE_RemoveWatcher()
[all …]
|
| H A D | le_task.c | 47 LE_STATUS ret = AddTask((EventLoop *)loopHandle, task); in CreateTask()
56 void CloseTask(const LoopHandle loopHandle, BaseTask *task) in CloseTask() argument
58 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
174 EventLoop *loop = (EventLoop *)loopHandle; in LE_Send()
176 LE_FreeBuffer(loopHandle, taskHandle, buffHandle); in LE_Send()
190 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseTask() argument
192 LE_CHECK(loopHandle != NULL && taskHandle != NULL, return, "Invalid parameters"); in LE_CloseTask()
194 LE_StopTimer(loopHandle, taskHandle); in LE_CloseTask()
[all …]
|
| H A D | le_task.h | 133 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size);
134 void CloseTask(const LoopHandle loopHandle, BaseTask *task);
|
| /ohos5.0/base/startup/init/services/loopevent/signal/ |
| H A D | le_signal.c | 43 static void HandleSignalTaskClose_(const LoopHandle loopHandle, const TaskHandle signalHandle) in HandleSignalTaskClose_() argument
46 DelTask((EventLoop *)loopHandle, task); in HandleSignalTaskClose_()
47 CloseTask(loopHandle, task); in HandleSignalTaskClose_()
86 SignalTask *task = (SignalTask *)CreateTask(loopHandle, sfd, &info, sizeof(SignalTask)); in LE_CreateSignalTask()
98 LE_STATUS LE_AddSignal(const LoopHandle loopHandle, const SignalHandle signalHandle, int signal) in LE_AddSignal() argument
101 EventLoop *loop = (EventLoop *)loopHandle; in LE_AddSignal()
120 LE_STATUS LE_RemoveSignal(const LoopHandle loopHandle, const SignalHandle signalHandle, int signal) in LE_RemoveSignal() argument
123 EventLoop *loop = (EventLoop *)loopHandle; in LE_RemoveSignal()
139 void LE_CloseSignalTask(const LoopHandle loopHandle, const SignalHandle signalHandle) in LE_CloseSignalTask() argument
141 LE_CHECK(loopHandle != NULL && signalHandle != NULL, return, "Invalid parameters"); in LE_CloseSignalTask()
[all …]
|
| /ohos5.0/base/startup/init/services/loopevent/idle/ |
| H A D | le_idle.c | 36 LE_STATUS LE_AddIdle(const LoopHandle loopHandle, IdleHandle *idle, in LE_AddIdle() argument
39 …LE_CHECK(loopHandle != NULL && processIdle != NULL, return LE_INVALID_PARAM, "Invalid parameters"); in LE_AddIdle()
44 task->loop = (EventLoop *)loopHandle; in LE_AddIdle()
79 int LE_DelayProc(const LoopHandle loopHandle, LE_ProcessIdle idle, void *context) in LE_DelayProc() argument
81 return LE_AddIdle(loopHandle, NULL, idle, context, 0); in LE_DelayProc()
106 void LE_RunIdle(const LoopHandle loopHandle) in LE_RunIdle() argument
108 if (loopHandle == NULL) { in LE_RunIdle()
111 EventLoop *loop = (EventLoop *)loopHandle; in LE_RunIdle()
|
| H A D | le_idle.h | 48 void LE_RunIdle(const LoopHandle loopHandle);
|
| /ohos5.0/base/startup/init/services/loopevent/timer/ |
| H A D | le_timer.c | 117 LE_STATUS LE_CreateTimer(const LoopHandle loopHandle, in LE_CreateTimer() argument
120 LE_CHECK(loopHandle != NULL, return LE_INVALID_PARAM, "loopHandle iS NULL"); in LE_CreateTimer()
133 LE_STATUS LE_StartTimer(const LoopHandle loopHandle, in LE_StartTimer() argument
136 LE_CHECK(loopHandle != NULL && timer != NULL, return LE_INVALID_PARAM, "Invalid parameters"); in LE_StartTimer()
137 EventLoop *loop = (EventLoop *)loopHandle; in LE_StartTimer()
187 void LE_StopTimer(const LoopHandle loopHandle, const TimerHandle timer) in LE_StopTimer() argument
|
| /ohos5.0/base/startup/init/services/loopevent/loop/ |
| H A D | le_loop.c | 163 void LE_CloseLoop(const LoopHandle loopHandle) in LE_CloseLoop() argument
165 LE_CHECK(loopHandle != NULL, return, "Invalid handle"); in LE_CloseLoop()
166 CloseLoop((EventLoop *)loopHandle); in LE_CloseLoop()
167 if ((LoopHandle)g_defaultLoop == loopHandle) { in LE_CloseLoop()
|
| /ohos5.0/base/startup/init/test/unittest/loopevent/ |
| H A 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()
|
| /ohos5.0/base/startup/appspawn/test/unittest/ |
| H A D | app_spawn_test_helper.h | 245 static int OnConnection(const LoopHandle loopHandle, const TaskHandle server);
|
| H A D | app_spawn_test_helper.cpp | 284 int LocalTestServer::OnConnection(const LoopHandle loopHandle, const TaskHandle server) in OnConnection() argument
300 LE_STATUS ret = LE_AcceptStreamClient(loopHandle, server, &stream, &info); in OnConnection()
|
| /ohos5.0/base/startup/init/test/unittest/param/ |
| H A D | param_stub.cpp | 626 void __attribute__((weak))LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent() argument
|
| /ohos5.0/base/startup/appspawn/standard/ |
| H A D | appspawn_service.c | 358 static int OnConnection(const LoopHandle loopHandle, const TaskHandle server) in OnConnection() argument
360 APPSPAWN_CHECK(server != NULL && loopHandle != NULL, return -1, "Error server"); in OnConnection()
371 LE_STATUS ret = LE_AcceptStreamClient(loopHandle, server, &stream, &info); in OnConnection()
|