Lines Matching defs:loop
22 static int IsValid_(const EventEpoll *loop)
24 return loop->epollFd >= 0;
38 static LE_STATUS Close_(const EventLoop *loop)
40 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop");
41 EventEpoll *epoll = (EventEpoll *)loop;
48 static LE_STATUS AddEvent_(const EventLoop *loop, const BaseTask *task, int op)
50 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop");
51 EventEpoll *epoll = (EventEpoll *)loop;
64 static LE_STATUS ModEvent_(const EventLoop *loop, const BaseTask *task, int op)
66 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop");
67 EventEpoll *epoll = (EventEpoll *)loop;
80 static LE_STATUS DelEvent_(const EventLoop *loop, int fd, int op)
82 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop");
83 EventEpoll *epoll = (EventEpoll *)loop;
95 static LE_STATUS RunLoop_(const EventLoop *loop)
97 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop");
99 EventEpoll *epoll = (EventEpoll *)loop;
105 LE_RunIdle((LoopHandle)&(epoll->loop));
107 uint64_t minTimePeriod = GetMinTimeoutPeriod(loop);
120 int number = epoll_wait(epoll->epollFd, epoll->waitEvents, loop->maxevents, timeout);
123 ProcessEvent(loop, epoll->waitEvents[index].data.fd, EVENT_READ);
126 ProcessEvent(loop, epoll->waitEvents[index].data.fd, EVENT_WRITE);
130 ProcessEvent(loop, epoll->waitEvents[index].data.fd, EVENT_ERROR);
135 CheckTimeoutOfTimer((EventLoop *)loop, GetCurrentTimespec(0));
138 if (loop->stop) {
145 LE_STATUS CreateEpollLoop(EventLoop **loop, uint32_t maxevents, uint32_t timeout)
147 LE_CHECK(loop != NULL, return LE_FAILURE, "Invalid loop");
154 *loop = (EventLoop *)epoll;
155 epoll->loop.maxevents = maxevents;
156 epoll->loop.timeout = timeout;
157 epoll->loop.close = Close_;
158 epoll->loop.runLoop = RunLoop_;
159 epoll->loop.delEvent = DelEvent_;
160 epoll->loop.addEvent = AddEvent_;
161 epoll->loop.modEvent = ModEvent_;