… | |
… | |
204 | static CV *cv_pool_handler; |
204 | static CV *cv_pool_handler; |
205 | static CV *cv_coro_state_new; |
205 | static CV *cv_coro_state_new; |
206 | |
206 | |
207 | /* Coro::AnyEvent */ |
207 | /* Coro::AnyEvent */ |
208 | static SV *sv_activity; |
208 | static SV *sv_activity; |
|
|
209 | |
|
|
210 | /* enable processtime/realtime profiling */ |
|
|
211 | static char profile_times; |
|
|
212 | typedef U32 coro_ts[2]; |
209 | |
213 | |
210 | static struct coro_cctx *cctx_first; |
214 | static struct coro_cctx *cctx_first; |
211 | static int cctx_count, cctx_idle; |
215 | static int cctx_count, cctx_idle; |
212 | |
216 | |
213 | enum { |
217 | enum { |
… | |
… | |
3367 | if (items > 1) |
3371 | if (items > 1) |
3368 | { |
3372 | { |
3369 | if (ix) |
3373 | if (ix) |
3370 | newprio = coro->prio - newprio; |
3374 | newprio = coro->prio - newprio; |
3371 | |
3375 | |
3372 | if (newprio < PRIO_MIN) newprio = PRIO_MIN; |
3376 | if (newprio < CORO_PRIO_MIN) newprio = CORO_PRIO_MIN; |
3373 | if (newprio > PRIO_MAX) newprio = PRIO_MAX; |
3377 | if (newprio > CORO_PRIO_MAX) newprio = CORO_PRIO_MAX; |
3374 | |
3378 | |
3375 | coro->prio = newprio; |
3379 | coro->prio = newprio; |
3376 | } |
3380 | } |
3377 | } |
3381 | } |
3378 | OUTPUT: |
3382 | OUTPUT: |