| /base/startup/init/services/loopevent/loop/ |
| H A D | le_loop.h | 32 LE_STATUS (*close)(const struct EventLoop_ *loop);
33 LE_STATUS (*runLoop)(const struct EventLoop_ *loop);
34 LE_STATUS (*addEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
35 LE_STATUS (*modEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
36 LE_STATUS (*delEvent)(const struct EventLoop_ *loop, int fd, int op);
52 LE_STATUS CloseLoop(EventLoop *loop);
53 LE_STATUS AddTask(EventLoop *loop, BaseTask *task);
56 LE_STATUS ProcessEvent(const EventLoop *loop, int fd, uint32_t oper);
|
| H A D | le_loop.c | 53 static LE_STATUS CreateLoop_(EventLoop **loop, uint32_t maxevents, uint32_t timeout)
in CreateLoop_()
56 LE_STATUS ret = CreateEpollLoop(loop, maxevents, timeout);
in CreateLoop_()
80 LE_STATUS CloseLoop(EventLoop *loop)
in CloseLoop()
92 LE_STATUS ProcessEvent(const EventLoop *loop, int fd, uint32_t oper)
in ProcessEvent()
103 LE_STATUS AddTask(EventLoop *loop, BaseTask *task)
in AddTask()
148 LE_STATUS LE_CreateLoop(LoopHandle *handle)
in LE_CreateLoop()
151 LE_STATUS ret = CreateLoop_(&loop, LOOP_MAX_SOCKET, DEFAULT_TIMEOUT);
in LE_CreateLoop()
|
| H A D | le_epoll.c | 38 static LE_STATUS Close_(const EventLoop *loop) in Close_()
48 static LE_STATUS AddEvent_(const EventLoop *loop, const BaseTask *task, int op) in AddEvent_()
64 static LE_STATUS ModEvent_(const EventLoop *loop, const BaseTask *task, int op) in ModEvent_()
80 static LE_STATUS DelEvent_(const EventLoop *loop, int fd, int op) in DelEvent_()
95 static LE_STATUS RunLoop_(const EventLoop *loop) in RunLoop_()
145 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout) in CreateEpollLoop()
|
| H A D | le_epoll.h | 28 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout);
|
| /base/startup/init/interfaces/innerkits/include/ |
| H A D | loop_event.h | 53 } LE_STATUS;
typedef
67 LE_STATUS LE_CreateLoop(LoopHandle *loopHandle);
125 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle,
127 LE_STATUS LE_CreateStreamClient(const LoopHandle loopHandle,
129 LE_STATUS LE_AcceptStreamClient(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,
158 LE_STATUS LE_CreateTimer(const LoopHandle loopHandle, TimerHandle *timer,
160 LE_STATUS LE_StartTime
[all...] |
| /base/startup/init/services/loopevent/task/ |
| H A D | le_streamtask.c | 25 static LE_STATUS HandleSendMsg_(const LoopHandle loopHandle,
in HandleSendMsg_()
53 static LE_STATUS HandleRecvMsg_(const LoopHandle loopHandle,
in HandleRecvMsg_()
56 LE_STATUS status = LE_SUCCESS;
in HandleRecvMsg_()
92 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t oper)
in HandleStreamEvent_()
97 LE_STATUS status = LE_SUCCESS;
in HandleStreamEvent_()
113 static LE_STATUS HandleClientEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t oper)
in HandleClientEvent_()
118 LE_STATUS status = LE_SUCCESS;
in HandleClientEvent_()
183 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint32_t oper)
in HandleServerEvent_()
201 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle,
in LE_CreateStreamServer()
235 LE_STATUS LE_CreateStreamClien
[all...] |
| H A D | le_watchtask.c | 25 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper)
in HandleWatcherEvent_()
63 LE_STATUS LE_StartWatcher(const LoopHandle loopHandle,
in LE_StartWatcher()
|
| H A D | le_asynctask.c | 67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper)
in HandleAsyncEvent_()
108 LE_STATUS LE_CreateAsyncTask(const LoopHandle loopHandle,
in LE_CreateAsyncTask()
132 LE_STATUS LE_StartAsyncEvent(const LoopHandle loopHandle,
in LE_StartAsyncEvent()
|
| H A D | le_task.h | 54 typedef LE_STATUS (*HandleTaskEvent)(const LoopHandle loop, const TaskHandle task, uint32_t oper);
|
| H A D | le_task.c | 47 LE_STATUS ret = AddTask((EventLoop *)loopHandle, task);
in CreateTask()
169 LE_STATUS LE_Send(const LoopHandle loopHandle,
in LE_Send()
|
| /base/startup/init/services/loopevent/signal/ |
| H A D | le_signal.c | 28 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper)
in HandleSignalEvent_()
77 LE_STATUS LE_CreateSignalTask(const LoopHandle loopHandle, SignalHandle *signalHandle, LE_ProcessSignal processSignal)
in LE_CreateSignalTask()
98 LE_STATUS LE_AddSignal(const LoopHandle loopHandle, const SignalHandle signalHandle, int signal)
in LE_AddSignal()
120 LE_STATUS LE_RemoveSignal(const LoopHandle loopHandle, const SignalHandle signalHandle, int signal)
in LE_RemoveSignal()
|
| /base/startup/init/test/unittest/loopevent/ |
| H A D | loopserver_unittest.cpp | 89 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper) in TestHandleTaskEvent()
152 LE_STATUS ret = LE_AcceptStreamClient(loop, server, &stream, &info); in TestTcpIncomingConnect()
169 LE_STATUS ret = LE_AcceptStreamClient(loop, server, &stream, &info); in TestPipIncomingConnect()
237 LE_STATUS ret = LE_CreateLoop(&g_loopServer_); in RunServer()
279 LE_STATUS ret = LE_CreateLoop(&g_loopClient_); in CreateConnect()
293 LE_STATUS status = LE_CreateStreamClient(g_loopClient_, &task, &info); in CreateConnect()
301 LE_STATUS ret = LE_CreateLoop(&g_loopClient_); in CreateWatcherTask()
310 LE_STATUS status = LE_StartWatcher(g_loopClient_, &handle, &info, nullptr); in CreateWatcherTask()
318 LE_STATUS ret = LE_CreateLoop(&g_loopClient_); in CreateTimerTask()
|
| H A D | loopsignal_unittest.cpp | 47 LE_STATUS status = LE_CreateLoop(&loopClient); in HWTEST_F()
|
| H A D | loopevent_unittest.cpp | 48 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper)
|
| /base/startup/init/services/param/linux/ |
| H A D | param_msgadp.c | 76 LE_STATUS status = LE_AcceptStreamClient(LE_GetDefaultLoop(), server, stream, &info);
in ParamStreamCreate()
127 LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), timer, (LE_ProcessTimer)process, context);
in ParamTimerCreate()
|
| /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()
|
| /base/startup/init/services/loopevent/timer/ |
| H A D | le_timer.c | 117 LE_STATUS LE_CreateTimer(const LoopHandle loopHandle,
in LE_CreateTimer()
133 LE_STATUS LE_StartTimer(const LoopHandle loopHandle,
in LE_StartTimer()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| H A D | control_fd_service.c | 112 LE_STATUS status = LE_Send(loop, task, handle, strlen(message) + 1); in SendMessage()
|
| H A D | control_fd_client.c | 121 LE_STATUS status = LE_CreateStreamClient(LE_GetDefaultLoop(), &task, &info); in CmdAgentCreate()
|
| /base/startup/init/services/loopevent/socket/ |
| H A D | le_socket.c | 110 static LE_STATUS GetSockaddrFromServer_(const char *server, struct sockaddr_in *addr)
in GetSockaddrFromServer_()
|
| /base/startup/appspawn/standard/ |
| H A D | appspawn_service.c | 380 LE_STATUS ret = LE_AcceptStreamClient(loopHandle, server, &stream, &info); in OnConnection()
612 LE_STATUS status = LE_StartWatcher(LE_GetDefaultLoop(), &property->forkCtx.pidFdWatcherHandle, &watchInfo, appPid); in WatchChildProcessFd()
639 LE_STATUS status = LE_StartWatcher(LE_GetDefaultLoop(), &property->forkCtx.watcherHandle, &watchInfo, property); in AddChildWatcher()
1239 LE_STATUS status = LE_CreateSignalTask(LE_GetDefaultLoop(), &appSpawnContent->sigHandler, ProcessSignal); in AppSpawnRun()
|
| /base/startup/init/test/systest/ |
| H A D | loopclient_systest.c | 86 LE_STATUS status = LE_CreateStreamClient(LE_GetDefaultLoop(), &task, &info); in CreateAgent()
|
| H A D | loopserver_systest.c | 209 LE_STATUS status = LE_Send(loop, task, handle, strlen(message) + 1); in SendMessage()
|
| /base/startup/init/services/init/ |
| H A D | init_common_service.c | 964 LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), &service->timer, ServiceTimerStartProcess,
in ServiceStartTimer()
|
| /base/startup/appspawn/test/unittest/ |
| H A D | app_spawn_test_helper.cpp | 300 LE_STATUS ret = LE_AcceptStreamClient(loopHandle, server, &stream, &info); in OnConnection()
|