| … | |
… | |
| 987 | |
987 | |
| 988 | /* first reschedule or stop timer */ |
988 | /* first reschedule or stop timer */ |
| 989 | if (w->repeat) |
989 | if (w->repeat) |
| 990 | { |
990 | { |
| 991 | assert (("negative ev_timer repeat value found while processing timers", w->repeat > 0.)); |
991 | assert (("negative ev_timer repeat value found while processing timers", w->repeat > 0.)); |
|
|
992 | |
| 992 | ((WT)w)->at = mn_now + w->repeat; |
993 | ((WT)w)->at += w->repeat; |
|
|
994 | if (((WT)w)->at < mn_now) |
|
|
995 | ((WT)w)->at = mn_now; |
|
|
996 | |
| 993 | downheap ((WT *)timers, timercnt, 0); |
997 | downheap ((WT *)timers, timercnt, 0); |
| 994 | } |
998 | } |
| 995 | else |
999 | else |
| 996 | ev_timer_stop (EV_A_ w); /* nonrepeating: stop timer */ |
1000 | ev_timer_stop (EV_A_ w); /* nonrepeating: stop timer */ |
| 997 | |
1001 | |
