static void
epoll_poll (EV_P_ ev_tstamp timeout)
{
- int eventcnt = epoll_wait (epoll_fd, events, eventmax, ceil (timeout * 1000.));
+ int eventcnt = epoll_wait (epoll_fd, epoll_events, epoll_eventmax, ceil (timeout * 1000.));
int i;
if (eventcnt < 0)
for (i = 0; i < eventcnt; ++i)
fd_event (
EV_A_
- events [i].data.u64,
- (events [i].events & (EPOLLOUT | EPOLLERR | EPOLLHUP) ? EV_WRITE : 0)
- | (events [i].events & (EPOLLIN | EPOLLERR | EPOLLHUP) ? EV_READ : 0)
+ epoll_events [i].data.u64,
+ (epoll_events [i].events & (EPOLLOUT | EPOLLERR | EPOLLHUP) ? EV_WRITE : 0)
+ | (epoll_events [i].events & (EPOLLIN | EPOLLERR | EPOLLHUP) ? EV_READ : 0)
);
/* if the receive array was full, increase its size */
- if (expect_false (eventcnt == eventmax))
+ if (expect_false (eventcnt == epoll_eventmax))
{
- free (events);
- eventmax = array_roundsize (events, eventmax << 1);
- events = malloc (sizeof (struct epoll_event) * eventmax);
+ free (epoll_events);
+ epoll_eventmax = array_roundsize (epoll_events, epoll_eventmax << 1);
+ epoll_events = malloc (sizeof (struct epoll_event) * epoll_eventmax);
}
}
method_modify = epoll_modify;
method_poll = epoll_poll;
- eventmax = 64; /* intiial number of events receivable per poll */
- events = malloc (sizeof (struct epoll_event) * eventmax);
+ epoll_eventmax = 64; /* intiial number of events receivable per poll */
+ epoll_events = malloc (sizeof (struct epoll_event) * epoll_eventmax);
return EVMETHOD_EPOLL;
}