Home
last modified time | relevance | path

Searched refs:LoopHandle (Results 1 - 25 of 27) sorted by relevance

12

/base/startup/init/interfaces/innerkits/include/
H A Dloop_event.h59 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 handle);
103 typedef int (*LE_IncommingConnect)(const LoopHandle loopHandl
[all...]
/base/startup/init/services/loopevent/loop/
H A Dle_loop.c49 CloseTask((const LoopHandle)context, task); in TaskNodeFree()
96 task->handleEvent((LoopHandle)loop, (TaskHandle)task, oper); in ProcessEvent()
140 LoopHandle LE_GetDefaultLoop(void) in LE_GetDefaultLoop()
143 LE_CreateLoop((LoopHandle *)&g_defaultLoop); in LE_GetDefaultLoop()
145 return (LoopHandle)g_defaultLoop; in LE_GetDefaultLoop()
148 LE_STATUS LE_CreateLoop(LoopHandle *handle) in LE_CreateLoop()
152 *handle = (LoopHandle)loop; in LE_CreateLoop()
156 void LE_RunLoop(const LoopHandle handle) in LE_RunLoop()
163 void LE_CloseLoop(const LoopHandle loopHandle) in LE_CloseLoop()
167 if ((LoopHandle)g_defaultLoo in LE_CloseLoop()
[all...]
H A Dle_epoll.c105 LE_RunIdle((LoopHandle)&(epoll->loop)); in RunLoop_()
/base/startup/init/services/loopevent/task/
H A Dle_watchtask.c18 static void HandleWatcherTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleWatcherTaskClose_()
25 static LE_STATUS HandleWatcherEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper) in HandleWatcherEvent_()
39 HandleWatcherTaskClose_((LoopHandle)loop, (TaskHandle)watcher); in HandleWatcherEvent_()
43 HandleWatcherTaskClose_((LoopHandle)loop, (TaskHandle)watcher); in HandleWatcherEvent_()
63 LE_STATUS LE_StartWatcher(const LoopHandle loopHandle, in LE_StartWatcher()
85 void LE_RemoveWatcher(const LoopHandle loopHandle, const WatcherHandle watcherHandle) in LE_RemoveWatcher()
H A Dle_task.h54 typedef LE_STATUS (*HandleTaskEvent)(const LoopHandle loop, const TaskHandle task, uint32_t oper);
55 typedef void (*HandleTaskClose)(const LoopHandle loop, const TaskHandle task);
130 void FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer);
133 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size);
134 void CloseTask(const LoopHandle loopHandle, BaseTask *task);
H A Dle_asynctask.c24 static void DoAsyncEvent_(const LoopHandle loopHandle, AsyncEventTask *asyncTask) in DoAsyncEvent_()
58 void LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent()
67 static LE_STATUS HandleAsyncEvent_(const LoopHandle loopHandle, const TaskHandle taskHandle, uint32_t oper) in HandleAsyncEvent_()
91 static void HandleAsyncTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleAsyncTaskClose_()
108 LE_STATUS LE_CreateAsyncTask(const LoopHandle loopHandle, in LE_CreateAsyncTask()
132 LE_STATUS LE_StartAsyncEvent(const LoopHandle loopHandle, in LE_StartAsyncEvent()
149 void LE_StopAsyncTask(LoopHandle loopHandle, TaskHandle taskHandle) in LE_StopAsyncTask()
H A Dle_task.c36 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()
190 void LE_CloseTask(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_CloseTask()
H A Dle_streamtask.c25 static LE_STATUS HandleSendMsg_(const LoopHandle loopHandle, in HandleSendMsg_()
53 static LE_STATUS HandleRecvMsg_(const LoopHandle loopHandle, in HandleRecvMsg_()
92 static LE_STATUS HandleStreamEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t oper) in HandleStreamEvent_()
113 static LE_STATUS HandleClientEvent_(const LoopHandle loopHandle, const TaskHandle handle, uint32_t oper) in HandleClientEvent_()
137 static void HandleStreamTaskClose_(const LoopHandle loopHandle, const TaskHandle taskHandle) in HandleStreamTaskClose_()
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_CreateStreamClient(const LoopHandle loopHandle, in LE_CreateStreamClient()
263 LE_STATUS LE_AcceptStreamClient(const LoopHandle loopHandle, const TaskHandle server, in LE_AcceptStreamClient()
296 void LE_CloseStreamTask(const LoopHandle loopHandl
[all...]
/base/startup/init/services/loopevent/signal/
H A Dle_signal.c28 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_()
43 static void HandleSignalTaskClose_(const LoopHandle loopHandle, const TaskHandle signalHandle) in HandleSignalTaskClose_()
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()
139 void LE_CloseSignalTask(const LoopHandle loopHandle, const SignalHandle signalHandle) in LE_CloseSignalTask()
/base/startup/init/services/loopevent/idle/
H A Dle_idle.c36 LE_STATUS LE_AddIdle(const LoopHandle loopHandle, IdleHandle *idle, in LE_AddIdle()
79 int LE_DelayProc(const LoopHandle loopHandle, LE_ProcessIdle idle, void *context) in LE_DelayProc()
106 void LE_RunIdle(const LoopHandle loopHandle) in LE_RunIdle()
H A Dle_idle.h48 void LE_RunIdle(const LoopHandle loopHandle);
/base/startup/init/interfaces/innerkits/control_fd/
H A Dcontrol_fd_service.c27 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()
H A Dcontrol_fd.h82 void CmdServiceInit(const char *socketPath, CallbackControlFdProcess func, LoopHandle loop);
/base/startup/init/services/loopevent/timer/
H A Dle_timer.c117 LE_STATUS LE_CreateTimer(const LoopHandle loopHandle, in LE_CreateTimer()
133 LE_STATUS LE_StartTimer(const LoopHandle loopHandle, in LE_StartTimer()
187 void LE_StopTimer(const LoopHandle loopHandle, const TimerHandle timer) in LE_StopTimer()
/base/startup/init/test/unittest/loopevent/
H A Dloopserver_unittest.cpp46 static LoopHandle g_loopClient_ = nullptr;
47 static LoopHandle g_loopServer_ = nullptr;
66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *message, ...) 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()
H A Dloopsignal_unittest.cpp46 static LoopHandle loopClient = nullptr; in HWTEST_F()
H A Dloopevent_unittest.cpp48 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper)
68 static int IncomingConnect(LoopHandle loop, TaskHandle server)
269 static LoopHandle g_loop = nullptr;
H A Dlooptimer_unittest.cpp37 static LoopHandle g_loop = NULL;
/base/startup/init/services/param/linux/
H A Dparam_message.h106 int OnIncomingConnect(LoopHandle loop, TaskHandle server);
H A Dparam_service.c361 PARAM_STATIC int OnIncomingConnect(LoopHandle loop, TaskHandle server) in OnIncomingConnect()
/base/startup/appspawn/standard/
H A Dappspawn_kickdog.c91 LoopHandle loop = LE_GetDefaultLoop(); in CreateTimerLoopTask()
/base/startup/init/test/unittest/innerkits/
H A Dinnerkits_unittest.cpp43 int CmdOnIncommingConnect(const LoopHandle loop, const TaskHandle server);
47 int SendMessage(LoopHandle loop, TaskHandle task, const char *message);
317 static int TestIncommingConnect(const LoopHandle loop, const TaskHandle server) in TestIncommingConnect()
/base/startup/init/test/systest/
H A Dloopserver_systest.c187 static int SendMessage(LoopHandle loop, TaskHandle task, const char *message) in SendMessage()
217 static int OnConnection(const LoopHandle loop, const TaskHandle server) in OnConnection()
287 void ServerInit(const char *server, LoopHandle loop, int flags) in ServerInit()
/base/startup/appspawn/test/unittest/
H A Dapp_spawn_test_helper.h245 static int OnConnection(const LoopHandle loopHandle, const TaskHandle server);
/base/startup/init/test/unittest/param/
H A Dparam_stub.cpp626 void __attribute__((weak))LE_DoAsyncEvent(const LoopHandle loopHandle, const TaskHandle taskHandle) in LE_DoAsyncEvent()

Completed in 13 milliseconds

12