Lines Matching refs:epoll

41     EventEpoll *epoll = (EventEpoll *)loop;  in Close_()  local
42 LE_LOGV("Close_ epollFd %d", epoll->epollFd); in Close_()
43 close(epoll->epollFd); in Close_()
44 free(epoll); in Close_()
51 EventEpoll *epoll = (EventEpoll *)loop; in AddEvent_() local
57 if (IsValid_(epoll) && fd >= 0) { in AddEvent_()
58 ret = epoll_ctl(epoll->epollFd, EPOLL_CTL_ADD, fd, &event); in AddEvent_()
67 EventEpoll *epoll = (EventEpoll *)loop; in ModEvent_() local
73 if (IsValid_(epoll) && fd >= 0) { in ModEvent_()
74 ret = epoll_ctl(epoll->epollFd, EPOLL_CTL_MOD, fd, &event); in ModEvent_()
83 EventEpoll *epoll = (EventEpoll *)loop; in DelEvent_() local
88 if (IsValid_(epoll) && fd >= 0) { in DelEvent_()
89 ret = epoll_ctl(epoll->epollFd, EPOLL_CTL_DEL, fd, &event); in DelEvent_()
99 EventEpoll *epoll = (EventEpoll *)loop; in RunLoop_() local
100 if (!IsValid_(epoll)) { in RunLoop_()
105 LE_RunIdle((LoopHandle)&(epoll->loop)); in RunLoop_()
117 int number = epoll_wait(epoll->epollFd, epoll->waitEvents, loop->maxevents, timeout); in RunLoop_()
119 if ((epoll->waitEvents[index].events & EPOLLIN) == EPOLLIN) { in RunLoop_()
120 ProcessEvent(loop, epoll->waitEvents[index].data.fd, EVENT_READ); in RunLoop_()
122 if ((epoll->waitEvents[index].events & EPOLLOUT) == EPOLLOUT) { in RunLoop_()
123 ProcessEvent(loop, epoll->waitEvents[index].data.fd, EVENT_WRITE); in RunLoop_()
125 if (epoll->waitEvents[index].events & (EPOLLERR | EPOLLHUP)) { in RunLoop_()
126 LE_LOGV("RunLoop_ fd:%d, error:%d", epoll->waitEvents[index].data.fd, errno); in RunLoop_()
127 ProcessEvent(loop, epoll->waitEvents[index].data.fd, EVENT_ERROR); in RunLoop_()
145 …EventEpoll *epoll = (EventEpoll *)malloc(sizeof(EventEpoll) + sizeof(struct epoll_event) * (maxeve… in CreateEpollLoop() local
146 LE_CHECK(epoll != NULL, return LE_FAILURE, "Failed to alloc memory for epoll"); in CreateEpollLoop()
147 epoll->epollFd = epoll_create(maxevents); in CreateEpollLoop()
148 LE_CHECK(epoll->epollFd >= 0, free(epoll); 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()