| … | |
… | |
| 667 | CALLRUNOPS(aTHX); |
667 | CALLRUNOPS(aTHX); |
| 668 | |
668 | |
| 669 | abort (); |
669 | abort (); |
| 670 | } |
670 | } |
| 671 | |
671 | |
|
|
672 | /* never call directly, always through the coro_state_transfer global variable */ |
| 672 | static void |
673 | static void |
| 673 | transfer (pTHX_ struct coro *prev, struct coro *next, int flags) |
674 | transfer_impl (pTHX_ struct coro *prev, struct coro *next, int flags) |
| 674 | { |
675 | { |
| 675 | dSTACKLEVEL; |
676 | dSTACKLEVEL; |
| 676 | |
677 | |
| 677 | if (prev != next) |
678 | if (prev != next) |
| 678 | { |
679 | { |
| … | |
… | |
| 771 | coro_mortal = 0; |
772 | coro_mortal = 0; |
| 772 | } |
773 | } |
| 773 | UNLOCK; |
774 | UNLOCK; |
| 774 | } |
775 | } |
| 775 | |
776 | |
|
|
777 | /* use this function pointer to call the above function */ |
|
|
778 | /* this is done to increase chances of the compiler not inlining the call */ |
|
|
779 | void (*coro_state_transfer)(pTHX_ struct coro *prev, struct coro *next, int flags) = transfer_impl; |
|
|
780 | |
| 776 | #define SV_CORO(sv,func) \ |
781 | #define SV_CORO(sv,func) \ |
| 777 | do { \ |
782 | do { \ |
| 778 | if (SvROK (sv)) \ |
783 | if (SvROK (sv)) \ |
| 779 | sv = SvRV (sv); \ |
784 | sv = SvRV (sv); \ |
| 780 | \ |
785 | \ |
| … | |
… | |
| 795 | } while(0) |
800 | } while(0) |
| 796 | |
801 | |
| 797 | #define SvSTATE(sv) INT2PTR (struct coro *, SvIVX (sv)) |
802 | #define SvSTATE(sv) INT2PTR (struct coro *, SvIVX (sv)) |
| 798 | |
803 | |
| 799 | static void |
804 | static void |
| 800 | api_transfer(pTHX_ SV *prev, SV *next, int flags) |
805 | api_transfer (pTHX_ SV *prev, SV *next, int flags) |
| 801 | { |
806 | { |
| 802 | SV_CORO (prev, "Coro::transfer"); |
807 | SV_CORO (prev, "Coro::transfer"); |
| 803 | SV_CORO (next, "Coro::transfer"); |
808 | SV_CORO (next, "Coro::transfer"); |
| 804 | |
809 | |
| 805 | transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags); |
810 | coro_state_transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags); |
| 806 | } |
811 | } |
| 807 | |
812 | |
| 808 | /** Coro ********************************************************************/ |
813 | /** Coro ********************************************************************/ |
| 809 | |
814 | |
| 810 | #define PRIO_MAX 3 |
815 | #define PRIO_MAX 3 |
| … | |
… | |
| 894 | |
899 | |
| 895 | SV_CORO (next, "Coro::schedule"); |
900 | SV_CORO (next, "Coro::schedule"); |
| 896 | |
901 | |
| 897 | UNLOCK; |
902 | UNLOCK; |
| 898 | |
903 | |
| 899 | transfer (aTHX_ SvSTATE (prev), SvSTATE (next), |
904 | coro_state_transfer (aTHX_ SvSTATE (prev), SvSTATE (next), |
| 900 | TRANSFER_SAVE_ALL | TRANSFER_LAZY_STACK); |
905 | TRANSFER_SAVE_ALL | TRANSFER_LAZY_STACK); |
| 901 | } |
906 | } |
| 902 | |
907 | |
| 903 | static void |
908 | static void |
| 904 | api_cede (void) |
909 | api_cede (void) |
| 905 | { |
910 | { |
| … | |
… | |
| 937 | coroapi.ver = CORO_API_VERSION; |
942 | coroapi.ver = CORO_API_VERSION; |
| 938 | coroapi.transfer = api_transfer; |
943 | coroapi.transfer = api_transfer; |
| 939 | } |
944 | } |
| 940 | |
945 | |
| 941 | Coro::State |
946 | Coro::State |
| 942 | _newprocess(args) |
947 | new (char *klass, ...) |
| 943 | SV * args |
|
|
| 944 | PROTOTYPE: $ |
948 | PROTOTYPE: $@ |
| 945 | CODE: |
949 | CODE: |
|
|
950 | { |
| 946 | Coro__State coro; |
951 | Coro__State coro; |
|
|
952 | int i; |
| 947 | |
953 | |
| 948 | if (!SvROK (args) || SvTYPE (SvRV (args)) != SVt_PVAV) |
954 | if (!SvOK (ST (1))) |
| 949 | croak ("Coro::State::_newprocess expects an arrayref"); |
955 | croak ("Coro::State::new needs something callable as first argument"); |
| 950 | |
956 | |
| 951 | Newz (0, coro, 1, struct coro); |
957 | Newz (0, coro, 1, struct coro); |
|
|
958 | coro->args = newAV (); |
| 952 | |
959 | |
| 953 | coro->args = (AV *)SvREFCNT_inc (SvRV (args)); |
960 | for (i = 1; i < items; i++) |
|
|
961 | av_push (coro->args, newSVsv (ST (i))); |
|
|
962 | |
|
|
963 | RETVAL = coro; |
|
|
964 | |
| 954 | /*coro->mainstack = 0; *//*actual work is done inside transfer */ |
965 | /*coro->mainstack = 0; *//*actual work is done inside transfer */ |
| 955 | /*coro->stack = 0;*/ |
966 | /*coro->stack = 0;*/ |
| 956 | |
967 | } |
| 957 | RETVAL = coro; |
|
|
| 958 | OUTPUT: |
968 | OUTPUT: |
| 959 | RETVAL |
969 | RETVAL |
| 960 | |
970 | |
| 961 | void |
971 | void |
| 962 | transfer(prev, next, flags) |
972 | transfer(prev, next, flags) |
| … | |
… | |
| 966 | PROTOTYPE: @ |
976 | PROTOTYPE: @ |
| 967 | CODE: |
977 | CODE: |
| 968 | PUTBACK; |
978 | PUTBACK; |
| 969 | SV_CORO (next, "Coro::transfer"); |
979 | SV_CORO (next, "Coro::transfer"); |
| 970 | SV_CORO (prev, "Coro::transfer"); |
980 | SV_CORO (prev, "Coro::transfer"); |
| 971 | transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags); |
981 | coro_state_transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags); |
| 972 | SPAGAIN; |
982 | SPAGAIN; |
| 973 | |
983 | |
| 974 | void |
984 | void |
| 975 | DESTROY(coro) |
985 | DESTROY(coro) |
| 976 | Coro::State coro |
986 | Coro::State coro |
| … | |
… | |
| 1030 | sv = av_pop ((AV *)SvRV (yieldstack)); |
1040 | sv = av_pop ((AV *)SvRV (yieldstack)); |
| 1031 | prev = SvSTATE ((SV*)SvRV (*av_fetch ((AV *)SvRV (sv), 0, 0))); |
1041 | prev = SvSTATE ((SV*)SvRV (*av_fetch ((AV *)SvRV (sv), 0, 0))); |
| 1032 | next = SvSTATE ((SV*)SvRV (*av_fetch ((AV *)SvRV (sv), 1, 0))); |
1042 | next = SvSTATE ((SV*)SvRV (*av_fetch ((AV *)SvRV (sv), 1, 0))); |
| 1033 | SvREFCNT_dec (sv); |
1043 | SvREFCNT_dec (sv); |
| 1034 | |
1044 | |
| 1035 | transfer (aTHX_ prev, next, 0); |
1045 | coro_state_transfer (aTHX_ prev, next, 0); |
| 1036 | |
1046 | |
| 1037 | MODULE = Coro::State PACKAGE = Coro |
1047 | MODULE = Coro::State PACKAGE = Coro |
| 1038 | |
1048 | |
| 1039 | BOOT: |
1049 | BOOT: |
| 1040 | { |
1050 | { |
