X-Git-Url: https://git.llucax.com/software/libev.git/blobdiff_plain/f123911c49df152e9b27ab4df77b12a03b6abfa2..d5b686568688adf526735190000d81a260db6c36:/ev_select.c?ds=sidebyside diff --git a/ev_select.c b/ev_select.c index a0db3b6..9f81e55 100644 --- a/ev_select.c +++ b/ev_select.c @@ -42,15 +42,15 @@ #include #include -static unsigned char *vec_ri, *vec_ro, *vec_wi, *vec_wo; -static int vec_max; - static void -select_modify (int fd, int oev, int nev) +select_modify (EV_P_ int fd, int oev, int nev) { int offs = fd >> 3; int mask = 1 << (fd & 7); + if (oev == nev) + return; + if (vec_max < (fd >> 5) + 1) { int new_max = (fd >> 5) + 1; @@ -75,7 +75,7 @@ select_modify (int fd, int oev, int nev) } static void -select_poll (ev_tstamp timeout) +select_poll (EV_P_ ev_tstamp timeout) { struct timeval tv; int res; @@ -110,7 +110,7 @@ select_poll (ev_tstamp timeout) events |= byte_w & (1 << bit) ? EV_WRITE : 0; if (events) - fd_event (idx * 8 + bit, events); + fd_event (EV_A_ idx * 8 + bit, events); } } } @@ -118,18 +118,35 @@ select_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 -select_init (int flags) +static int +select_init (EV_P_ int flags) { - ev_method = EVMETHOD_SELECT; method_fudge = 1e-2; /* needed to compensate for select returning early, very conservative */ method_modify = select_modify; method_poll = select_poll; + + vec_max = 0; + vec_ri = 0; + vec_ri = 0; + vec_wo = 0; + vec_wo = 0; + + return EVMETHOD_SELECT; } +static void +select_destroy (EV_P) +{ + free (vec_ri); + free (vec_ro); + free (vec_wi); + free (vec_wo); +} + +