ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Coro/Coro/State.xs
(Generate patch)

Comparing Coro/Coro/State.xs (file contents):
Revision 1.38 by root, Wed Nov 7 00:21:06 2001 UTC vs.
Revision 1.39 by root, Sun Nov 25 20:04:05 2001 UTC

… …
102static AV *main_mainstack; /* used to differentiate between $main and others */ 102static AV *main_mainstack; /* used to differentiate between $main and others */
103static HV *coro_state_stash; 103static HV *coro_state_stash;
104static SV *ucoro_state_sv; 104static SV *ucoro_state_sv;
105static U32 ucoro_state_hash; 105static U32 ucoro_state_hash;
106static HV *padlist_cache; 106static HV *padlist_cache;
107static SV *coro_mortal; /* will be freed after next transfer */
107 108
108/* mostly copied from op.c:cv_clone2 */ 109/* mostly copied from op.c:cv_clone2 */
109STATIC AV * 110STATIC AV *
110clone_padlist (AV *protopadlist) 111clone_padlist (AV *protopadlist)
111{ 112{
… …
753 * we switched the c stack or not. that's why i use a global 754 * we switched the c stack or not. that's why i use a global
754 * variable, that should become thread-specific at one point. 755 * variable, that should become thread-specific at one point.
755 */ 756 */
756 xnext->cursp = stacklevel; 757 xnext->cursp = stacklevel;
757 } 758 }
758}
759 759
760static struct coro * 760 if (coro_mortal)
761sv_to_coro (SV *arg, const char *funcname, const char *varname) 761 {
762{ 762 SvREFCNT_dec (coro_mortal);
763 if (SvROK(arg) && SvTYPE(SvRV(arg)) == SVt_PVHV) 763 coro_mortal = 0;
764 { 764 }
765}
766
767#define SV_CORO(sv,func) \
768 do { \
769 if (SvROK (sv)) \
770 sv = SvRV (sv); \
771 \
772 if (SvTYPE(sv) == SVt_PVHV) \
773 { \
765 HE *he = hv_fetch_ent((HV *)SvRV(arg), ucoro_state_sv, 0, ucoro_state_hash); 774 HE *he = hv_fetch_ent((HV *)sv, ucoro_state_sv, 0, ucoro_state_hash); \
766 775 \
767 if (!he) 776 if (!he) \
768 croak ("%s() -- %s is a hashref but lacks the " UCORO_STATE " key", funcname, varname); 777 croak ("%s() -- %s is a hashref but lacks the " UCORO_STATE " key", func, # sv); \
769 778 \
770 arg = HeVAL(he); 779 (sv) = SvRV (HeVAL(he)); \
771 } 780 } \
772 781 \
773 /* must also be changed inside Coro::Cont::yield */ 782 /* must also be changed inside Coro::Cont::yield */ \
774 if (SvROK(arg) && SvOBJECT(SvRV(arg)) 783 if (!SvOBJECT(sv) || SvSTASH(sv) != coro_state_stash) \
775 && SvSTASH(SvRV(arg)) == coro_state_stash)
776 return (struct coro *) SvIV((SV*)SvRV(arg));
777
778 croak ("%s() -- %s is not (and contains not) a Coro::State object", funcname, varname); 784 croak ("%s() -- %s is not (and contains not) a Coro::State object", func, # sv); \
779 /*NORETURN*/ 785 \
780} 786 } while(0)
787
788#define SvSTATE(sv) (struct coro *)SvIV (sv)
781 789
782static void 790static void
783api_transfer(pTHX_ SV *prev, SV *next, int flags) 791api_transfer(pTHX_ SV *prev, SV *next, int flags)
784{ 792{
785 transfer(aTHX_ 793 SV_CORO (prev, "Coro::transfer");
786 sv_to_coro (prev, "Coro::transfer", "prev"), 794 SV_CORO (next, "Coro::transfer");
787 sv_to_coro (next, "Coro::transfer", "next"), 795
788 flags); 796 transfer(aTHX_ SvSTATE(prev), SvSTATE(next), flags);
789} 797}
790 798
791/** Coro ********************************************************************/ 799/** Coro ********************************************************************/
792 800
793#define PRIO_MAX 3 801#define PRIO_MAX 3
… …
803static int coro_nready; 811static int coro_nready;
804 812
805static void 813static void
806coro_enq (SV *sv) 814coro_enq (SV *sv)
807{ 815{
808 if (SvROK (sv))
809 {
810 SV *hv = SvRV (sv);
811 if (SvTYPE (hv) == SVt_PVHV) 816 if (SvTYPE (sv) == SVt_PVHV)
812 { 817 {
813 SV **xprio = hv_fetch ((HV *)hv, "prio", 4, 0); 818 SV **xprio = hv_fetch ((HV *)sv, "prio", 4, 0);
814 int prio = xprio ? SvIV (*xprio) : PRIO_NORMAL; 819 int prio = xprio ? SvIV (*xprio) : PRIO_NORMAL;
815 820
816 prio = prio > PRIO_MAX ? PRIO_MAX 821 prio = prio > PRIO_MAX ? PRIO_MAX
817 : prio < PRIO_MIN ? PRIO_MIN 822 : prio < PRIO_MIN ? PRIO_MIN
818 : prio; 823 : prio;
819 824
820 av_push (coro_ready [prio - PRIO_MIN], sv); 825 av_push (coro_ready [prio - PRIO_MIN], sv);
821 coro_nready++; 826 coro_nready++;
822 827
823 return; 828 return;
824 }
825 } 829 }
826 830
827 croak ("Coro::ready tried to enqueue something that is not a coroutine"); 831 croak ("Coro::ready tried to enqueue something that is not a coroutine");
828} 832}
829 833
… …
847} 851}
848 852
849static void 853static void
850api_ready (SV *coro) 854api_ready (SV *coro)
851{ 855{
856 if (SvROK (coro))
857 coro = SvRV (coro);
858
852 coro_enq (SvREFCNT_inc (coro)); 859 coro_enq (SvREFCNT_inc (coro));
853} 860}
854 861
855static void 862static void
856api_schedule (int cede) 863api_schedule (void)
857{ 864{
858 SV *prev, *next; 865 SV *prev, *next;
859 866
860 prev = GvSV (coro_current); 867 prev = SvRV (GvSV (coro_current));
861
862 if (cede)
863 coro_enq (SvREFCNT_inc (prev));
864
865 next = coro_deq (PRIO_MIN); 868 next = coro_deq (PRIO_MIN);
866 869
867 if (!next) 870 if (!next)
868 next = SvREFCNT_inc (GvSV (coro_idle)); 871 next = SvREFCNT_inc (SvRV (GvSV (coro_idle)));
869 872
870 GvSV (coro_current) = SvREFCNT_inc (next); 873 coro_mortal = prev;
871 transfer (aTHX_ 874 SV_CORO (prev, "Coro::schedule");
872 sv_to_coro (prev, "Coro::schedule", "current coroutine"), 875
873 sv_to_coro (next, "Coro::schedule", "next coroutine"), 876 SvRV (GvSV (coro_current)) = next;
877
878 SV_CORO (next, "Coro::schedule");
879
880 transfer (aTHX_ SvSTATE (prev), SvSTATE (next),
874 TRANSFER_SAVE_ALL | TRANSFER_LAZY_STACK); 881 TRANSFER_SAVE_ALL | TRANSFER_LAZY_STACK);
875 SvREFCNT_dec (next); 882}
876 SvREFCNT_dec (prev); 883
884static void
885api_cede (void)
886{
887 coro_enq (SvREFCNT_inc (SvRV (GvSV (coro_current))));
888
889 api_schedule ();
877} 890}
878 891
879MODULE = Coro::State PACKAGE = Coro::State 892MODULE = Coro::State PACKAGE = Coro::State
880 893
881PROTOTYPES: ENABLE 894PROTOTYPES: ENABLE
… …
920 OUTPUT: 933 OUTPUT:
921 RETVAL 934 RETVAL
922 935
923void 936void
924transfer(prev, next, flags) 937transfer(prev, next, flags)
925 Coro::State_or_hashref prev 938 SV *prev
926 Coro::State_or_hashref next 939 SV *next
927 int flags 940 int flags
928 PROTOTYPE: @ 941 PROTOTYPE: @
929 CODE: 942 CODE:
930 PUTBACK; 943 PUTBACK;
944 SV_CORO (next, "Coro::transfer");
945 SV_CORO (prev, "Coro::transfer");
931 transfer (aTHX_ prev, next, flags); 946 transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags);
932 SPAGAIN; 947 SPAGAIN;
933 948
934void 949void
935DESTROY(coro) 950DESTROY(coro)
936 Coro::State coro 951 Coro::State coro
… …
1031 1046
1032 { 1047 {
1033 SV *sv = perl_get_sv("Coro::API", 1); 1048 SV *sv = perl_get_sv("Coro::API", 1);
1034 1049
1035 coroapi.schedule = api_schedule; 1050 coroapi.schedule = api_schedule;
1051 coroapi.cede = api_cede;
1036 coroapi.ready = api_ready; 1052 coroapi.ready = api_ready;
1037 coroapi.nready = &coro_nready; 1053 coroapi.nready = &coro_nready;
1038 coroapi.current = coro_current; 1054 coroapi.current = coro_current;
1039 1055
1040 GCoroAPI = &coroapi; 1056 GCoroAPI = &coroapi;
… …
1059 RETVAL 1075 RETVAL
1060 1076
1061void 1077void
1062schedule(...) 1078schedule(...)
1063 PROTOTYPE: 1079 PROTOTYPE:
1064 ALIAS:
1065 cede = 1
1066 CODE: 1080 CODE:
1067 api_schedule (ix); 1081 api_schedule ();
1068 1082
1083void
1084cede(...)
1085 PROTOTYPE:
1086 CODE:
1087 api_cede ();
1088

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines