… | |
… | |
120 | *stash_idle, |
120 | *stash_idle, |
121 | *stash_prepare, |
121 | *stash_prepare, |
122 | *stash_check, |
122 | *stash_check, |
123 | *stash_embed, |
123 | *stash_embed, |
124 | *stash_fork, |
124 | *stash_fork, |
|
|
125 | *stash_cleanup, |
125 | *stash_async; |
126 | *stash_async; |
126 | |
127 | |
127 | ///////////////////////////////////////////////////////////////////////////// |
128 | ///////////////////////////////////////////////////////////////////////////// |
128 | // Event |
129 | // Event |
129 | |
130 | |
… | |
… | |
374 | const_iv (EV_, IDLE) |
375 | const_iv (EV_, IDLE) |
375 | const_iv (EV_, PREPARE) |
376 | const_iv (EV_, PREPARE) |
376 | const_iv (EV_, CHECK) |
377 | const_iv (EV_, CHECK) |
377 | const_iv (EV_, EMBED) |
378 | const_iv (EV_, EMBED) |
378 | const_iv (EV_, FORK) |
379 | const_iv (EV_, FORK) |
|
|
380 | const_iv (EV_, CLEANUP) |
379 | const_iv (EV_, ASYNC) |
381 | const_iv (EV_, ASYNC) |
380 | const_iv (EV_, CUSTOM) |
382 | const_iv (EV_, CUSTOM) |
381 | const_iv (EV_, ERROR) |
383 | const_iv (EV_, ERROR) |
382 | |
384 | |
383 | const_iv (EV, RUN_NOWAIT) |
385 | const_iv (EV, RUN_NOWAIT) |
… | |
… | |
428 | stash_check = gv_stashpv ("EV::Check" , 1); |
430 | stash_check = gv_stashpv ("EV::Check" , 1); |
429 | stash_child = gv_stashpv ("EV::Child" , 1); |
431 | stash_child = gv_stashpv ("EV::Child" , 1); |
430 | stash_embed = gv_stashpv ("EV::Embed" , 1); |
432 | stash_embed = gv_stashpv ("EV::Embed" , 1); |
431 | stash_stat = gv_stashpv ("EV::Stat" , 1); |
433 | stash_stat = gv_stashpv ("EV::Stat" , 1); |
432 | stash_fork = gv_stashpv ("EV::Fork" , 1); |
434 | stash_fork = gv_stashpv ("EV::Fork" , 1); |
|
|
435 | stash_cleanup = gv_stashpv ("EV::Cleanup" , 1); |
433 | stash_async = gv_stashpv ("EV::Async" , 1); |
436 | stash_async = gv_stashpv ("EV::Async" , 1); |
434 | |
437 | |
435 | { |
438 | { |
436 | SV *sv = perl_get_sv ("EV::API", TRUE); |
439 | SV *sv = perl_get_sv ("EV::API", TRUE); |
437 | perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */ |
440 | perl_get_sv ("EV::API", TRUE); /* silence 5.10 warning */ |
… | |
… | |
494 | evapi.embed_start = ev_embed_start; |
497 | evapi.embed_start = ev_embed_start; |
495 | evapi.embed_stop = ev_embed_stop; |
498 | evapi.embed_stop = ev_embed_stop; |
496 | evapi.embed_sweep = ev_embed_sweep; |
499 | evapi.embed_sweep = ev_embed_sweep; |
497 | evapi.fork_start = ev_fork_start; |
500 | evapi.fork_start = ev_fork_start; |
498 | evapi.fork_stop = ev_fork_stop; |
501 | evapi.fork_stop = ev_fork_stop; |
|
|
502 | evapi.cleanup_start = ev_cleanup_start; |
|
|
503 | evapi.cleanup_stop = ev_cleanup_stop; |
499 | evapi.async_start = ev_async_start; |
504 | evapi.async_start = ev_async_start; |
500 | evapi.async_stop = ev_async_stop; |
505 | evapi.async_stop = ev_async_stop; |
501 | evapi.async_send = ev_async_send; |
506 | evapi.async_send = ev_async_send; |
502 | evapi.clear_pending = ev_clear_pending; |
507 | evapi.clear_pending = ev_clear_pending; |
503 | evapi.invoke = ev_invoke; |
508 | evapi.invoke = ev_invoke; |
… | |
… | |
713 | ev_fork_set (RETVAL); |
718 | ev_fork_set (RETVAL); |
714 | if (!ix) START (fork, RETVAL); |
719 | if (!ix) START (fork, RETVAL); |
715 | OUTPUT: |
720 | OUTPUT: |
716 | RETVAL |
721 | RETVAL |
717 | |
722 | |
|
|
723 | ev_cleanup *cleanup (SV *cb) |
|
|
724 | ALIAS: |
|
|
725 | cleanup_ns = 1 |
|
|
726 | CODE: |
|
|
727 | RETVAL = e_new (sizeof (ev_cleanup), cb, default_loop_sv); |
|
|
728 | ev_cleanup_set (RETVAL); |
|
|
729 | if (!ix) START (cleanup, RETVAL); |
|
|
730 | OUTPUT: |
|
|
731 | RETVAL |
718 | |
732 | |
719 | ev_child *child (int pid, int trace, SV *cb) |
733 | ev_child *child (int pid, int trace, SV *cb) |
720 | ALIAS: |
734 | ALIAS: |
721 | child_ns = 1 |
735 | child_ns = 1 |
722 | CODE: |
736 | CODE: |
… | |
… | |
1101 | STOP (fork, w); |
1115 | STOP (fork, w); |
1102 | |
1116 | |
1103 | void DESTROY (ev_fork *w) |
1117 | void DESTROY (ev_fork *w) |
1104 | CODE: |
1118 | CODE: |
1105 | STOP (fork, w); |
1119 | STOP (fork, w); |
|
|
1120 | e_destroy (w); |
|
|
1121 | |
|
|
1122 | MODULE = EV PACKAGE = EV::Cleanup PREFIX = ev_cleanup_ |
|
|
1123 | |
|
|
1124 | void ev_cleanup_start (ev_cleanup *w) |
|
|
1125 | CODE: |
|
|
1126 | START (cleanup, w); |
|
|
1127 | |
|
|
1128 | void ev_cleanup_stop (ev_cleanup *w) |
|
|
1129 | CODE: |
|
|
1130 | STOP (cleanup, w); |
|
|
1131 | |
|
|
1132 | void DESTROY (ev_cleanup *w) |
|
|
1133 | CODE: |
|
|
1134 | STOP (cleanup, w); |
1106 | e_destroy (w); |
1135 | e_destroy (w); |
1107 | |
1136 | |
1108 | MODULE = EV PACKAGE = EV::Child PREFIX = ev_child_ |
1137 | MODULE = EV PACKAGE = EV::Child PREFIX = ev_child_ |
1109 | |
1138 | |
1110 | #if EV_CHILD_ENABLE |
1139 | #if EV_CHILD_ENABLE |
… | |
… | |
1463 | ev_fork_set (RETVAL); |
1492 | ev_fork_set (RETVAL); |
1464 | if (!ix) START (fork, RETVAL); |
1493 | if (!ix) START (fork, RETVAL); |
1465 | OUTPUT: |
1494 | OUTPUT: |
1466 | RETVAL |
1495 | RETVAL |
1467 | |
1496 | |
|
|
1497 | ev_cleanup *cleanup (struct ev_loop *loop, SV *cb) |
|
|
1498 | ALIAS: |
|
|
1499 | cleanup_ns = 1 |
|
|
1500 | CODE: |
|
|
1501 | RETVAL = e_new (sizeof (ev_cleanup), cb, ST (0)); |
|
|
1502 | ev_cleanup_set (RETVAL); |
|
|
1503 | if (!ix) START (cleanup, RETVAL); |
|
|
1504 | OUTPUT: |
|
|
1505 | RETVAL |
1468 | |
1506 | |
1469 | ev_child *child (struct ev_loop *loop, int pid, int trace, SV *cb) |
1507 | ev_child *child (struct ev_loop *loop, int pid, int trace, SV *cb) |
1470 | ALIAS: |
1508 | ALIAS: |
1471 | child_ns = 1 |
1509 | child_ns = 1 |
1472 | CODE: |
1510 | CODE: |