| /ohos5.0/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,
160 LE_STATUS LE_StartTimer(const LoopHandle loopHandle,
166 LE_STATUS LE_CreateSignalTask(const LoopHandle loopHandle,
[all …]
|
| /ohos5.0/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_()
142 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);
|
| /ohos5.0/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_()
91 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t … in HandleStreamEvent_()
96 LE_STATUS status = LE_SUCCESS; in HandleStreamEvent_()
112 static LE_STATUS HandleClientEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t … in HandleClientEvent_()
117 LE_STATUS status = LE_SUCCESS; in HandleClientEvent_()
182 static LE_STATUS HandleServerEvent_(const LoopHandle loopHandle, const TaskHandle serverTask, uint3… in HandleServerEvent_()
200 LE_STATUS LE_CreateStreamServer(const LoopHandle loopHandle, in LE_CreateStreamServer()
234 LE_STATUS LE_CreateStreamClient(const LoopHandle loopHandle, in LE_CreateStreamClient()
[all …]
|
| H A D | le_asynctask.c | 67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32… 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_watchtask.c | 25 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint… in HandleWatcherEvent_()
63 LE_STATUS LE_StartWatcher(const LoopHandle loopHandle, in LE_StartWatcher()
|
| 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()
|
| H A D | le_task.h | 54 typedef LE_STATUS (*HandleTaskEvent)(const LoopHandle loop, const TaskHandle task, uint32_t oper);
|
| /ohos5.0/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);
|
| H A D | loopevent_unittest.cpp | 48 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper) in TestHandleTaskEvent()
|
| /ohos5.0/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_ProcessSi… 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()
|
| /ohos5.0/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()
|
| /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()
133 LE_STATUS LE_StartTimer(const LoopHandle loopHandle, in LE_StartTimer()
|
| /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()
|
| /ohos5.0/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()
|
| /ohos5.0/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_()
|
| /ohos5.0/base/startup/appspawn/standard/ |
| H A D | appspawn_service.c | 371 LE_STATUS ret = LE_AcceptStreamClient(loopHandle, server, &stream, &info); in OnConnection()
604 …LE_STATUS status = LE_StartWatcher(LE_GetDefaultLoop(), &property->forkCtx.pidFdWatcherHandle, &wa… in WatchChildProcessFd()
632 …LE_STATUS status = LE_StartWatcher(LE_GetDefaultLoop(), &property->forkCtx.watcherHandle, &watchIn… in AddChildWatcher()
1225 …LE_STATUS status = LE_CreateSignalTask(LE_GetDefaultLoop(), &appSpawnContent->sigHandler, ProcessS… in AppSpawnRun()
|
| /ohos5.0/base/startup/init/services/init/ |
| H A D | init_common_service.c | 989 … LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), &service->timer, ServiceTimerStartProcess, in ServiceStartTimer()
1014 …LE_STATUS status = LE_CreateTimer(LE_GetDefaultLoop(), &service->timer, ServiceTimerReStartProcess, in ServiceReStartTimer()
|
| /ohos5.0/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()
|