… | |
… | |
2588 | timers [active] = timers [timercnt + HEAP0]; |
2588 | timers [active] = timers [timercnt + HEAP0]; |
2589 | adjustheap (timers, timercnt, active); |
2589 | adjustheap (timers, timercnt, active); |
2590 | } |
2590 | } |
2591 | } |
2591 | } |
2592 | |
2592 | |
2593 | EV_FREQUENT_CHECK; |
|
|
2594 | |
|
|
2595 | ev_at (w) -= mn_now; |
2593 | ev_at (w) -= mn_now; |
2596 | |
2594 | |
2597 | ev_stop (EV_A_ (W)w); |
2595 | ev_stop (EV_A_ (W)w); |
|
|
2596 | |
|
|
2597 | EV_FREQUENT_CHECK; |
2598 | } |
2598 | } |
2599 | |
2599 | |
2600 | void noinline |
2600 | void noinline |
2601 | ev_timer_again (EV_P_ ev_timer *w) |
2601 | ev_timer_again (EV_P_ ev_timer *w) |
2602 | { |
2602 | { |
… | |
… | |
2681 | periodics [active] = periodics [periodiccnt + HEAP0]; |
2681 | periodics [active] = periodics [periodiccnt + HEAP0]; |
2682 | adjustheap (periodics, periodiccnt, active); |
2682 | adjustheap (periodics, periodiccnt, active); |
2683 | } |
2683 | } |
2684 | } |
2684 | } |
2685 | |
2685 | |
2686 | EV_FREQUENT_CHECK; |
|
|
2687 | |
|
|
2688 | ev_stop (EV_A_ (W)w); |
2686 | ev_stop (EV_A_ (W)w); |
|
|
2687 | |
|
|
2688 | EV_FREQUENT_CHECK; |
2689 | } |
2689 | } |
2690 | |
2690 | |
2691 | void noinline |
2691 | void noinline |
2692 | ev_periodic_again (EV_P_ ev_periodic *w) |
2692 | ev_periodic_again (EV_P_ ev_periodic *w) |
2693 | { |
2693 | { |
… | |
… | |
3429 | |
3429 | |
3430 | ev_io_stop (EV_A_ &w->io); |
3430 | ev_io_stop (EV_A_ &w->io); |
3431 | ev_prepare_stop (EV_A_ &w->prepare); |
3431 | ev_prepare_stop (EV_A_ &w->prepare); |
3432 | ev_fork_stop (EV_A_ &w->fork); |
3432 | ev_fork_stop (EV_A_ &w->fork); |
3433 | |
3433 | |
|
|
3434 | ev_stop (EV_A_ (W)w); |
|
|
3435 | |
3434 | EV_FREQUENT_CHECK; |
3436 | EV_FREQUENT_CHECK; |
3435 | } |
3437 | } |
3436 | #endif |
3438 | #endif |
3437 | |
3439 | |
3438 | #if EV_FORK_ENABLE |
3440 | #if EV_FORK_ENABLE |