… | |
… | |
83 | static EV_ATOMIC_T aio_pending; |
83 | static EV_ATOMIC_T aio_pending; |
84 | |
84 | |
85 | static void |
85 | static void |
86 | aio2_cb (EV_P_ ev_idle *w, int revents) |
86 | aio2_cb (EV_P_ ev_idle *w, int revents) |
87 | { |
87 | { |
|
|
88 | IV reqs; |
|
|
89 | |
88 | CALL_BEGIN (0); |
90 | CALL_BEGIN (0); |
89 | CALL_CALL ("IO::AIO::poll_cb", G_SCALAR); |
91 | CALL_CALL ("IO::AIO::poll_cb", G_SCALAR); |
90 | |
92 | |
|
|
93 | reqs = POPi; |
91 | if (count > 0 && TOPi < 0) |
94 | if (count > 0 && reqs < 0) |
92 | ev_idle_start (EV_A, w); |
95 | ev_idle_start (EV_A, w); |
93 | else |
96 | else |
94 | ev_idle_stop (EV_A, w); |
97 | ev_idle_stop (EV_A, w); |
95 | |
98 | |
96 | CALL_END; |
99 | CALL_END; |