| … | |
… | |
| 1166 | |
1166 | |
| 1167 | while (pipe (sigpipe)) |
1167 | while (pipe (sigpipe)) |
| 1168 | syserr ("(libev) error creating pipe"); |
1168 | syserr ("(libev) error creating pipe"); |
| 1169 | |
1169 | |
| 1170 | siginit (EV_A); |
1170 | siginit (EV_A); |
|
|
1171 | sigcb (EV_A_ &sigev, EV_READ); |
| 1171 | } |
1172 | } |
| 1172 | |
1173 | |
| 1173 | postfork = 0; |
1174 | postfork = 0; |
| 1174 | } |
1175 | } |
| 1175 | |
1176 | |
| … | |
… | |
| 1309 | { |
1310 | { |
| 1310 | while (timercnt && ((WT)timers [0])->at <= mn_now) |
1311 | while (timercnt && ((WT)timers [0])->at <= mn_now) |
| 1311 | { |
1312 | { |
| 1312 | ev_timer *w = (ev_timer *)timers [0]; |
1313 | ev_timer *w = (ev_timer *)timers [0]; |
| 1313 | |
1314 | |
| 1314 | assert (("inactive timer on timer heap detected", ev_is_active (w))); |
1315 | /*assert (("inactive timer on timer heap detected", ev_is_active (w)));*/ |
| 1315 | |
1316 | |
| 1316 | /* first reschedule or stop timer */ |
1317 | /* first reschedule or stop timer */ |
| 1317 | if (w->repeat) |
1318 | if (w->repeat) |
| 1318 | { |
1319 | { |
| 1319 | assert (("negative ev_timer repeat value found while processing timers", w->repeat > 0.)); |
1320 | assert (("negative ev_timer repeat value found while processing timers", w->repeat > 0.)); |
