| … | |
… | |
| 600 | |
600 | |
| 601 | #if EV_SELECT_IS_WINSOCKET |
601 | #if EV_SELECT_IS_WINSOCKET |
| 602 | if (events) |
602 | if (events) |
| 603 | { |
603 | { |
| 604 | unsigned long argp; |
604 | unsigned long argp; |
|
|
605 | #ifdef EV_FD_TO_WIN32_HANDLE |
|
|
606 | anfd->handle = EV_FD_TO_WIN32_HANDLE (fd); |
|
|
607 | #else |
| 605 | anfd->handle = _get_osfhandle (fd); |
608 | anfd->handle = _get_osfhandle (fd); |
|
|
609 | #endif |
| 606 | assert (("libev only supports socket fds in this configuration", ioctlsocket (anfd->handle, FIONREAD, &argp) == 0)); |
610 | assert (("libev only supports socket fds in this configuration", ioctlsocket (anfd->handle, FIONREAD, &argp) == 0)); |
| 607 | } |
611 | } |
| 608 | #endif |
612 | #endif |
| 609 | |
613 | |
| 610 | { |
614 | { |
| … | |
… | |
| 1305 | { |
1309 | { |
| 1306 | while (timercnt && ((WT)timers [0])->at <= mn_now) |
1310 | while (timercnt && ((WT)timers [0])->at <= mn_now) |
| 1307 | { |
1311 | { |
| 1308 | ev_timer *w = (ev_timer *)timers [0]; |
1312 | ev_timer *w = (ev_timer *)timers [0]; |
| 1309 | |
1313 | |
| 1310 | /*assert (("inactive timer on timer heap detected", ev_is_active (w)));*/ |
1314 | assert (("inactive timer on timer heap detected", ev_is_active (w))); |
| 1311 | |
1315 | |
| 1312 | /* first reschedule or stop timer */ |
1316 | /* first reschedule or stop timer */ |
| 1313 | if (w->repeat) |
1317 | if (w->repeat) |
| 1314 | { |
1318 | { |
| 1315 | assert (("negative ev_timer repeat value found while processing timers", w->repeat > 0.)); |
1319 | assert (("negative ev_timer repeat value found while processing timers", w->repeat > 0.)); |
