Lines Matching refs:loop

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