| /base/startup/init/services/loopevent/loop/ |
| H A 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, hashNod in TaskNodeFree()
[all...] |
| H A D | le_loop.h | 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);
53 LE_STATUS AddTask(EventLoop *loop, BaseTask *task);
54 BaseTask *GetTaskByFd(EventLoop *loop, int fd);
55 void DelTask(EventLoop *loop, BaseTask *task);
|
| H A D | le_epoll.c | 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_()
|
| /base/startup/init/services/loopevent/task/ |
| H A 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()
175 if (((BaseTask *)taskHandl in LE_Send()
[all...] |
| H A D | le_task.h | 76 } BaseTask;
typedef
79 BaseTask base;
85 BaseTask base;
120 BaseTask base;
133 BaseTask *CreateTask(const LoopHandle loopHandle, int fd, const LE_BaseInfo *info, uint32_t size);
134 void CloseTask(const LoopHandle loopHandle, BaseTask *task);
136 int CheckTaskFlags(const BaseTask *task, uint32_t flags);
|
| H A D | le_watchtask.c | 21 DelTask((EventLoop *)loopHandle, (BaseTask *)taskHandle);
in HandleWatcherTaskClose_()
22 CloseTask(loopHandle, (BaseTask *)taskHandle);
in HandleWatcherTaskClose_()
48 loop->modEvent(loop, (const BaseTask *)taskHandle, watcher->events);
in HandleWatcherEvent_()
56 BaseTask *baseTask = (BaseTask *)task;
in DumpWatcherTaskInfo_()
80 loop->addEvent(loop, (const BaseTask *)task, info->events);
in LE_StartWatcher()
|
| H A D | le_asynctask.c | 79 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_WRITE);
in HandleAsyncEvent_()
85 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ);
in HandleAsyncEvent_()
93 BaseTask *task = (BaseTask *)taskHandle;
in HandleAsyncTaskClose_()
102 BaseTask *baseTask = (BaseTask *)task;
in DumpEventTaskInfo_()
127 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_CreateAsyncTask()
|
| H A D | le_streamtask.c | 47 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ);
in HandleSendMsg_()
139 BaseTask *task = (BaseTask *)taskHandle;
in HandleStreamTaskClose_()
150 BaseTask *baseTask = (BaseTask *)task;
in DumpStreamServerTaskInfo_()
164 BaseTask *baseTask = (BaseTask *)task;
in DumpStreamConnectTaskInfo_()
197 loop->modEvent(loop, (const BaseTask *)serverTask, EVENT_READ);
in HandleServerEvent_()
228 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_CreateStreamServer()
258 loop->addEvent(loop, (const BaseTask *)tas in LE_CreateStreamClient()
[all...] |
| /base/startup/init/services/loopevent/signal/ |
| H A D | le_signal.c | 45 BaseTask *task = (BaseTask *)signalHandle;
in HandleSignalTaskClose_()
68 BaseTask *baseTask = (BaseTask *)task;
in DumpSignalTaskInfo_()
112 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_AddSignal()
114 loop->modEvent(loop, (const BaseTask *)task, EVENT_READ);
in LE_AddSignal()
|
| H A D | le_signal.h | 24 BaseTask base;
|
| /base/startup/init/test/unittest/loopevent/ |
| H A D | loopsignal_unittest.cpp | 59 ((BaseTask *)g_sigHandler)->handleEvent(loopClient, (TaskHandle)&g_sigHandler, EVENT_WRITE); in HWTEST_F()
|
| H A D | loopevent_unittest.cpp | 182 BaseTask *task = CreateTask(LE_GetDefaultLoop(), testfd, &info, sizeof(StreamClientTask));
|
| /base/startup/init/services/init/standard/ |
| H A D | init_control_fd_service.c | 39 BaseTask *baseTask = HASHMAP_ENTRY(node, BaseTask, hashNode); in DumpLoopNodeInfo()
|