| /base/startup/init/services/loopevent/loop/ |
| D | le_loop.c | 22 BaseTask *task1 = HASHMAP_ENTRY(node1, BaseTask, hashNode); in TaskNodeCompare()
23 BaseTask *task2 = HASHMAP_ENTRY(node2, BaseTask, hashNode); in TaskNodeCompare()
29 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskKeyCompare()
36 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskGetNodeHasCode()
48 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskNodeFree()
89 BaseTask *task = GetTaskByFd((EventLoop *)loop, fd); in ProcessEvent()
101 LE_STATUS AddTask(EventLoop *loop, BaseTask *task) in AddTask()
114 BaseTask *GetTaskByFd(EventLoop *loop, int fd) in GetTaskByFd()
116 BaseTask *task = NULL; in GetTaskByFd()
121 task = HASHMAP_ENTRY(node, BaseTask, hashNode); in GetTaskByFd()
[all …]
|
| D | le_loop.h | 33 LE_STATUS (*addEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
34 LE_STATUS (*modEvent)(const struct EventLoop_ *loop, const BaseTask *task, int op);
49 LE_STATUS AddTask(EventLoop *loop, BaseTask *task);
50 BaseTask *GetTaskByFd(EventLoop *loop, int fd);
51 void DelTask(EventLoop *loop, BaseTask *task);
|
| D | le_epoll.c | 46 static LE_STATUS AddEvent_(const EventLoop *loop, const BaseTask *task, int op) in AddEvent_()
62 static LE_STATUS ModEvent_(const EventLoop *loop, const BaseTask *task, int op) in ModEvent_()
|
| /base/startup/init/services/loopevent/task/ |
| D | le_task.c | 22 int CheckTaskFlags(const BaseTask *task, uint32_t flags) in CheckTaskFlags()
32 BaseTask *stream = (BaseTask *)task; in GetSocketFd()
36 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size) in CreateTask()
41 BaseTask *task = (BaseTask *)calloc(1, size + info->userDataSize); in CreateTask()
56 void CloseTask(const LoopHandle loopHandle, BaseTask *task) in CloseTask()
137 if (CheckTaskFlags((BaseTask *)task, TASK_STREAM | TASK_CONNECT) || in FreeBuffer()
138 CheckTaskFlags((BaseTask *)task, TASK_EVENT | TASK_ASYNC_EVENT)) { in FreeBuffer()
173 if (((BaseTask *)taskHandle)->flags & TASK_FLAGS_INVALID) { in LE_Send()
179 if (CheckTaskFlags((BaseTask *)taskHandle, TASK_STREAM | TASK_CONNECT)) { in LE_Send()
181 } else if (CheckTaskFlags((BaseTask *)taskHandle, TASK_EVENT | TASK_ASYNC_EVENT)) { in LE_Send()
[all …]
|
| D | le_task.h | 72 } BaseTask; typedef
75 BaseTask base;
81 BaseTask base;
114 BaseTask base;
127 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size);
128 void CloseTask(const LoopHandle loopHandle, BaseTask *task);
130 int CheckTaskFlags(const BaseTask *task, uint32_t flags);
|
| D | le_watchtask.c | 41 loop->modEvent(loop, (const BaseTask *)taskHandle, watcher->events); in HandleWatcherEvent_()
48 CloseTask(loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
49 DelTask((EventLoop *)loopHandle, (BaseTask *)taskHandle); in HandleWatcherTaskClose_()
68 loop->addEvent(loop, (const BaseTask *)task, info->events); in LE_StartWatcher()
|
| D | le_asynctask.c | 77 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Write); in HandleAsyncEvent_()
83 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Read); in HandleAsyncEvent_()
91 BaseTask *task = (BaseTask *)taskHandle; in HandleAsyncTaskClose_()
116 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateAsyncTask()
|
| D | le_streamtask.c | 42 loop->modEvent(loop, (const BaseTask *)taskHandle, Event_Read); in HandleSendMsg_()
131 BaseTask *task = (BaseTask *)taskHandle; in HandleStreamTaskClose_()
153 loop->modEvent(loop, (const BaseTask *)serverTask, Event_Read); in HandleServerEvent_()
179 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateStreamServer()
208 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_CreateStreamClient()
238 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_AcceptStreamClient()
|
| /base/startup/init/services/loopevent/signal/ |
| D | le_signal.c | 44 BaseTask *task = (BaseTask *)signalHandle; in HandleSignalTaskClose_()
84 loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_AddSignal()
86 loop->modEvent(loop, (const BaseTask *)task, Event_Read); in LE_AddSignal()
|
| D | le_signal.h | 24 BaseTask base;
|
| /base/startup/init/services/loopevent/timer/ |
| D | le_timer.h | 24 BaseTask base;
|
| D | le_timer.c | 68 BaseTask *task = (BaseTask *)taskHandle; in HandleTimerClose_()
107 ret = loop->addEvent(loop, (const BaseTask *)task, Event_Read); in LE_StartTimer()
|
| /base/startup/init/test/unittest/loopevent/ |
| D | loopsignal_unittest.cpp | 59 ((BaseTask *)g_sigHandler)->handleEvent(loopClient, (TaskHandle)&g_sigHandler, Event_Write);
|
| D | loopevent_unittest.cpp | 182 BaseTask *task = CreateTask(LE_GetDefaultLoop(), testfd, &info, sizeof(StreamClientTask)); in ProcessEventTest()
|