if (oev == nev)
return;
- array_needsize (pollidxs, pollidxmax, fd + 1, pollidx_init);
+ array_needsize (int, pollidxs, pollidxmax, fd + 1, pollidx_init);
idx = pollidxs [fd];
if (idx < 0) /* need to allocate a new pollfd */
{
- idx = pollcnt++;
- array_needsize (polls, pollmax, pollcnt, );
+ pollidxs [fd] = idx = pollcnt++;
+ array_needsize (struct pollfd, polls, pollmax, pollcnt, );
polls [idx].fd = fd;
}
+ assert (polls [idx].fd == fd);
+
if (nev)
polls [idx].events =
(nev & EV_READ ? POLLIN : 0)
| (nev & EV_WRITE ? POLLOUT : 0);
else /* remove pollfd */
{
- if (idx < pollcnt--)
+ pollidxs [fd] = -1;
+
+ if (idx < --pollcnt)
{
- pollidxs [fd] = -1;
polls [idx] = polls [pollcnt];
pollidxs [polls [idx].fd] = idx;
}
poll_poll (EV_P_ ev_tstamp timeout)
{
int i;
- int res = poll (polls, pollcnt, ceil (timeout * 1000.));
+ int res = poll (polls, pollcnt, (int)ceil (timeout * 1000.));
if (res < 0)
{
else if (errno == ENOMEM && !syserr_cb)
fd_enomem (EV_A);
else if (errno != EINTR)
- syserr ();
+ syserr ("(libev) poll");
return;
}
ev_free (pollidxs);
ev_free (polls);
}
+