X-Git-Url: https://git.llucax.com/software/libev.git/blobdiff_plain/0c513fd963e79da73c7d77018523ac956a5066bd..6f16328ecec5b9add341be4e60ed9eeaa3adea67:/ev_poll.c diff --git a/ev_poll.c b/ev_poll.c index 0af63f3..b858b45 100644 --- a/ev_poll.c +++ b/ev_poll.c @@ -31,11 +31,6 @@ #include -static struct pollfd *polls; -static int pollmax, pollcnt; -static int *pollidxs; /* maps fds into structure indices */ -static int pollidxmax; - static void pollidx_init (int *base, int count) { @@ -44,7 +39,7 @@ pollidx_init (int *base, int count) } static void -poll_modify (int fd, int oev, int nev) +poll_modify (EV_P_ int fd, int oev, int nev) { int idx; array_needsize (pollidxs, pollidxmax, fd + 1, pollidx_init); @@ -74,7 +69,7 @@ poll_modify (int fd, int oev, int nev) } static void -poll_poll (ev_tstamp timeout) +poll_poll (EV_P_ ev_tstamp timeout) { int res = poll (polls, pollcnt, ceil (timeout * 1000.)); @@ -84,6 +79,7 @@ poll_poll (ev_tstamp timeout) for (i = 0; i < pollcnt; ++i) fd_event ( + EV_A_ polls [i].fd, (polls [i].revents & (POLLOUT | POLLERR | POLLHUP) ? EV_WRITE : 0) | (polls [i].revents & (POLLIN | POLLERR | POLLHUP) ? EV_READ : 0) @@ -92,17 +88,28 @@ poll_poll (ev_tstamp timeout) else if (res < 0) { if (errno == EBADF) - fd_ebadf (); + fd_ebadf (EV_A); else if (errno == ENOMEM) - fd_enomem (); + fd_enomem (EV_A); } } -static void -poll_init (int flags) +static int +poll_init (EV_P_ int flags) { - ev_method = EVMETHOD_POLL; method_fudge = 1e-3; /* needed to compensate for select returning early, very conservative */ method_modify = poll_modify; method_poll = poll_poll; + + pollidxs = 0; pollidxmax = 0; + polls = 0; pollmax = 0; pollcnt = 0; + + return EVMETHOD_POLL; +} + +static void +poll_destroy (EV_P) +{ + free (pollidxs); + free (polls); }