| /ohos5.0/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, hashNode); in TaskNodeFree()
94 BaseTask *task = GetTaskByFd((EventLoop *)loop, fd); in ProcessEvent()
103 LE_STATUS AddTask(EventLoop *loop, BaseTask *task) in AddTask()
116 BaseTask *GetTaskByFd(EventLoop *loop, int fd) in GetTaskByFd()
118 BaseTask *task = NULL; in GetTaskByFd()
123 task = HASHMAP_ENTRY(node, BaseTask, hashNode); in GetTaskByFd()
[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_()
|
| /ohos5.0/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()
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 *)taskHandle)->flags & TASK_FLAGS_INVALID) { in LE_Send()
181 if (CheckTaskFlags((BaseTask *)taskHandle, TASK_STREAM | TASK_CONNECT)) { in LE_Send()
186 loop->modEvent(loop, (BaseTask *)taskHandle, EVENT_WRITE); in LE_Send()
198 BaseTask *task = (BaseTask *)taskHandle; in LE_CloseTask()
[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_streamtask.c | 47 loop->modEvent(loop, (const BaseTask *)taskHandle, EVENT_READ); in HandleSendMsg_()
138 BaseTask *task = (BaseTask *)taskHandle; in HandleStreamTaskClose_()
149 BaseTask *baseTask = (BaseTask *)task; in DumpStreamServerTaskInfo_()
163 BaseTask *baseTask = (BaseTask *)task; in DumpStreamConnectTaskInfo_()
196 loop->modEvent(loop, (const BaseTask *)serverTask, EVENT_READ); in HandleServerEvent_()
227 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_CreateStreamServer()
257 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_CreateStreamClient()
289 loop->addEvent(loop, (const BaseTask *)task, EVENT_READ); in LE_AcceptStreamClient()
|
| 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()
|
| /ohos5.0/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;
|
| /ohos5.0/base/startup/init/test/unittest/loopevent/ |
| H A D | loopsignal_unittest.cpp | 59 ((BaseTask *)g_sigHandler)->handleEvent(loopClient, (TaskHandle)&g_sigHandler, EVENT_WRITE);
|
| H A D | loopevent_unittest.cpp | 182 BaseTask *task = CreateTask(LE_GetDefaultLoop(), testfd, &info, sizeof(StreamClientTask)); in ProcessEventTest()
|
| /ohos5.0/base/startup/init/services/init/standard/ |
| H A D | init_control_fd_service.c | 39 BaseTask *baseTask = HASHMAP_ENTRY(node, BaseTask, hashNode); in DumpLoopNodeInfo()
|