… | |
… | |
1840 | ev_invoke (EV_P_ void *w, int revents) |
1840 | ev_invoke (EV_P_ void *w, int revents) |
1841 | { |
1841 | { |
1842 | EV_CB_INVOKE ((W)w, revents); |
1842 | EV_CB_INVOKE ((W)w, revents); |
1843 | } |
1843 | } |
1844 | |
1844 | |
|
|
1845 | unsigned int |
|
|
1846 | ev_pending_count (EV_P) |
|
|
1847 | { |
|
|
1848 | int pri; |
|
|
1849 | unsigned int count = 0; |
|
|
1850 | |
|
|
1851 | for (pri = NUMPRI; pri--; ) |
|
|
1852 | count += pendingcnt [pri]; |
|
|
1853 | |
|
|
1854 | return count; |
|
|
1855 | } |
|
|
1856 | |
1845 | void noinline |
1857 | void noinline |
1846 | ev_invoke_pending (EV_P) |
1858 | ev_invoke_pending (EV_P) |
1847 | { |
1859 | { |
1848 | int pri; |
1860 | int pri; |
1849 | |
1861 | |
… | |
… | |
2585 | if (!((WL)w)->next) |
2597 | if (!((WL)w)->next) |
2586 | { |
2598 | { |
2587 | #if _WIN32 |
2599 | #if _WIN32 |
2588 | signal (w->signum, ev_sighandler); |
2600 | signal (w->signum, ev_sighandler); |
2589 | #else |
2601 | #else |
2590 | struct sigaction sa; |
2602 | struct sigaction sa = { }; |
2591 | sa.sa_handler = ev_sighandler; |
2603 | sa.sa_handler = ev_sighandler; |
2592 | sigfillset (&sa.sa_mask); |
2604 | sigfillset (&sa.sa_mask); |
2593 | sa.sa_flags = SA_RESTART; /* if restarting works we save one iteration */ |
2605 | sa.sa_flags = SA_RESTART; /* if restarting works we save one iteration */ |
2594 | sigaction (w->signum, &sa, 0); |
2606 | sigaction (w->signum, &sa, 0); |
2595 | #endif |
2607 | #endif |