[ViewVC] Diff of: cvs/Coro/Coro/State.xs

Comparing Coro/Coro/State.xs (file contents):
Revision 1.85 by root, Fri Nov 24 00:32:04 2006 UTC vs.
Revision 1.87 by root, Fri Nov 24 13:40:36 2006 UTC

…		…
145	I32 retstack_max;	145	I32 retstack_max;
146	PMOP *curpm;	146	PMOP *curpm;
147	COP *curcop;	147	COP *curcop;
148	JMPENV *top_env;	148	JMPENV *top_env;
149		149
		150	/* coro process data */
		151	int prio;
		152
150	/* data associated with this coroutine (initial args) */	153	/* data associated with this coroutine (initial args) */
151	AV *args;	154	AV *args;
		155	int refcnt;
152	};	156	};
153		157
154	typedef struct coro *Coro__State;	158	typedef struct coro *Coro__State;
155	typedef struct coro *Coro__State_or_hashref;	159	typedef struct coro *Coro__State_or_hashref;
156		160
…		…
781	#define SV_CORO(sv,func) \	785	#define SV_CORO(sv,func) \
782	do { \	786	do { \
783	if (SvROK (sv)) \	787	if (SvROK (sv)) \
784	sv = SvRV (sv); \	788	sv = SvRV (sv); \
785	\	789	\
786	if (SvTYPE (sv) == SVt_PVHV) \	790	if (SvTYPE (sv) == SVt_PVHV && SvSTASH (sv) != coro_state_stash) \
787	{ \	791	{ \
788	HE he = hv_fetch_ent ((HV )sv, ucoro_state_sv, 0, ucoro_state_hash); \	792	HE he = hv_fetch_ent ((HV )sv, ucoro_state_sv, 0, ucoro_state_hash); \
789	\	793	\
790	if (!he) \	794	if (!he) \
791	croak ("%s() -- %s is a hashref but lacks the " UCORO_STATE " key", func, # sv); \	795	croak ("%s() -- %s is a hashref but lacks the " UCORO_STATE " key", func, # sv); \
…		…
797	if (!SvOBJECT (sv) \|\| SvSTASH (sv) != coro_state_stash) \	801	if (!SvOBJECT (sv) \|\| SvSTASH (sv) != coro_state_stash) \
798	croak ("%s() -- %s is not (and contains not) a Coro::State object", func, # sv); \	802	croak ("%s() -- %s is not (and contains not) a Coro::State object", func, # sv); \
799	\	803	\
800	} while(0)	804	} while(0)
801		805
802	#define SvSTATE(sv) INT2PTR (struct coro *, SvIVX (sv))	806	static void
		807	coro_state_destroy (struct coro *coro)
		808	{
		809	if (coro->refcnt--)
		810	return;
		811
		812	if (coro->mainstack && coro->mainstack != main_mainstack)
		813	{
		814	struct coro temp;
		815
		816	SAVE (aTHX_ (&temp), TRANSFER_SAVE_ALL);
		817	LOAD (aTHX_ coro);
		818
		819	destroy_stacks (aTHX);
		820
		821	LOAD ((&temp)); /* this will get rid of defsv etc.. */
		822
		823	coro->mainstack = 0;
		824	}
		825
		826	deallocate_stack (coro);
		827	SvREFCNT_dec (coro->args);
		828	Safefree (coro);
		829	}
		830
		831	static int
		832	coro_state_clear (SV sv, MAGIC mg)
		833	{
		834	struct coro coro = (struct coro )mg->mg_ptr;
		835	mg->mg_ptr = 0;
		836
		837	coro_state_destroy (coro);
		838
		839	return 0;
		840	}
		841
		842	static int
		843	coro_state_dup (MAGIC mg, CLONE_PARAMS params)
		844	{
		845	struct coro coro = (struct coro )mg->mg_ptr;
		846
		847	++coro->refcnt;
		848
		849	return 0;
		850	}
		851
		852	static MGVTBL coro_state_vtbl = { 0, 0, 0, 0, coro_state_clear, 0, coro_state_dup, 0 };
		853
		854	static struct coro *
		855	SvSTATE (SV *coro)
		856	{
		857	MAGIC *mg = SvMAGIC (SvROK (coro) ? SvRV (coro) : coro);
		858	assert (mg->mg_type == PERL_MAGIC_ext);
		859	return (struct coro *)mg->mg_ptr;
		860	}
803		861
804	static void	862	static void
805	api_transfer (pTHX_ SV prev, SV next, int flags)	863	api_transfer (pTHX_ SV prev, SV next, int flags)
806	{	864	{
807	SV_CORO (prev, "Coro::transfer");	865	SV_CORO (prev, "Coro::transfer");
…		…
825	static int coro_nready;	883	static int coro_nready;
826		884
827	static void	885	static void
828	coro_enq (pTHX_ SV *sv)	886	coro_enq (pTHX_ SV *sv)
829	{	887	{
830	SV **xprio;
831	int prio;	888	int prio;
832		889
833	if (SvTYPE (sv) != SVt_PVHV)	890	if (SvTYPE (sv) != SVt_PVHV)
834	croak ("Coro::ready tried to enqueue something that is not a coroutine");	891	croak ("Coro::ready tried to enqueue something that is not a coroutine");
835		892
836	xprio = hv_fetch ((HV *)sv, "prio", 4, 0);	893	{
837	prio = xprio ? SvIV (*xprio) : PRIO_NORMAL;	894	SV *coro = sv;
838		895	SV_CORO (coro, "omg");
839	prio = prio > PRIO_MAX ? PRIO_MAX	896	prio = SvSTATE (coro)->prio;
840	: prio < PRIO_MIN ? PRIO_MIN	897	}
841	: prio;
842		898
843	av_push (coro_ready [prio - PRIO_MIN], sv);	899	av_push (coro_ready [prio - PRIO_MIN], sv);
844	coro_nready++;	900	coro_nready++;
845	}	901	}
846		902
…		…
917	api_schedule ();	973	api_schedule ();
918	}	974	}
919		975
920	MODULE = Coro::State PACKAGE = Coro::State	976	MODULE = Coro::State PACKAGE = Coro::State
921		977
922	PROTOTYPES: ENABLE	978	PROTOTYPES: DISABLE
923		979
924	BOOT:	980	BOOT:
925	{ /* {} necessary for stoopid perl-5.6.x */	981	{ /* {} necessary for stoopid perl-5.6.x */
926	#ifdef USE_ITHREADS	982	#ifdef USE_ITHREADS
927	MUTEX_INIT (&coro_mutex);	983	MUTEX_INIT (&coro_mutex);
…		…
939		995
940	main_mainstack = PL_mainstack;	996	main_mainstack = PL_mainstack;
941		997
942	coroapi.ver = CORO_API_VERSION;	998	coroapi.ver = CORO_API_VERSION;
943	coroapi.transfer = api_transfer;	999	coroapi.transfer = api_transfer;
944	}
945		1000
946	Coro::State	1001	assert (("PRIO_NORMAL must be 0", !PRIO_NORMAL));
947	_newprocess(args)	1002	}
948	SV * args	1003
949	PROTOTYPE: $	1004	SV *
		1005	new (char *klass, ...)
950	CODE:	1006	CODE:
951	Coro__State coro;	1007	{
		1008	struct coro *coro;
		1009	HV *hv;
		1010	int i;
952		1011
953	if (!SvROK (args) \|\| SvTYPE (SvRV (args)) != SVt_PVAV)
954	croak ("Coro::State::_newprocess expects an arrayref");
955
956	Newz (0, coro, 1, struct coro);	1012	Newz (0, coro, 1, struct coro);
		1013	coro->args = newAV ();
957		1014
958	coro->args = (AV *)SvREFCNT_inc (SvRV (args));	1015	for (i = 1; i < items; i++)
		1016	av_push (coro->args, newSVsv (ST (i)));
		1017
959	/coro->mainstack = 0; //actual work is done inside transfer /	1018	/coro->mainstack = 0; //actual work is done inside transfer /
960	/coro->stack = 0;/	1019	/coro->stack = 0;/
961		1020
962	RETVAL = coro;	1021	hv = newHV ();
		1022	sv_magicext ((SV )hv, 0, PERL_MAGIC_ext, &coro_state_vtbl, (char )coro, 0)->mg_flags \|= MGf_DUP;
		1023	RETVAL = sv_bless (newRV_noinc ((SV *)hv), gv_stashpv (klass, 1));
		1024	}
963	OUTPUT:	1025	OUTPUT:
964	RETVAL	1026	RETVAL
965		1027
966	void	1028	void
967	transfer(prev, next, flags)	1029	transfer(prev, next, flags)
968	SV *prev	1030	SV *prev
969	SV *next	1031	SV *next
970	int flags	1032	int flags
971	PROTOTYPE: @
972	CODE:	1033	CODE:
973	PUTBACK;	1034	PUTBACK;
974	SV_CORO (next, "Coro::transfer");	1035	SV_CORO (next, "Coro::transfer");
975	SV_CORO (prev, "Coro::transfer");	1036	SV_CORO (prev, "Coro::transfer");
976	coro_state_transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags);	1037	coro_state_transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags);
977	SPAGAIN;	1038	SPAGAIN;
978		1039
		1040	int
		1041	prio (Coro::State coro, int newprio = 0)
		1042	ALIAS:
		1043	nice = 1
		1044	CODE:
		1045	{
		1046	RETVAL = coro->prio;
		1047
		1048	if (items > 1)
		1049	{
		1050	if (ix)
		1051	newprio += coro->prio;
		1052
		1053	if (newprio < PRIO_MIN) newprio = PRIO_MIN;
		1054	if (newprio > PRIO_MAX) newprio = PRIO_MAX;
		1055
		1056	coro->prio = newprio;
		1057	}
		1058	}
		1059
979	void	1060	void
980	DESTROY(coro)	1061	_clone_state_from (SV dst, SV src)
981	Coro::State coro	1062	CODE:
982	CODE:	1063	{
		1064	struct coro *coro_src = SvSTATE (src);
983		1065
984	if (coro->mainstack && coro->mainstack != main_mainstack)	1066	sv_unmagic (SvRV (dst), PERL_MAGIC_ext);
985	{
986	struct coro temp;
987		1067
988	PUTBACK;	1068	++coro_src->refcnt;
989	SAVE (aTHX_ (&temp), TRANSFER_SAVE_ALL);	1069	sv_magicext (SvRV (dst), 0, PERL_MAGIC_ext, &coro_state_vtbl, (char *)coro_src, 0)->mg_flags \|= MGf_DUP;
990	LOAD (aTHX_ coro);	1070	}
991	SPAGAIN;
992
993	destroy_stacks (aTHX);
994
995	LOAD ((&temp)); /* this will get rid of defsv etc.. */
996	SPAGAIN;
997
998	coro->mainstack = 0;
999	}
1000
1001	deallocate_stack (coro);
1002	SvREFCNT_dec (coro->args);
1003	Safefree (coro);
1004		1071
1005	void	1072	void
1006	_exit(code)	1073	_exit (code)
1007	int code	1074	int code
1008	PROTOTYPE: $	1075	PROTOTYPE: $
1009	CODE:	1076	CODE:
1010	_exit (code);	1077	_exit (code);
1011		1078
1012	MODULE = Coro::State PACKAGE = Coro::Cont	1079	MODULE = Coro::State PACKAGE = Coro::Cont
1013		1080
1014	void	1081	void
1015	yield(...)	1082	yield (...)
1016	PROTOTYPE: @	1083	PROTOTYPE: @
1017	CODE:	1084	CODE:
1018	SV *yieldstack;	1085	SV *yieldstack;
1019	SV *sv;	1086	SV *sv;
1020	AV *defav = GvAV (PL_defgv);	1087	AV *defav = GvAV (PL_defgv);
…		…
1075	}	1142	}
1076		1143
1077	#if !PERL_MICRO	1144	#if !PERL_MICRO
1078		1145
1079	void	1146	void
1080	ready(self)	1147	ready (self)
1081	SV * self	1148	SV * self
1082	PROTOTYPE: $	1149	PROTOTYPE: $
1083	CODE:	1150	CODE:
1084	api_ready (self);	1151	api_ready (self);
1085		1152
1086	#endif	1153	#endif
1087		1154
1088	int	1155	int
1089	nready(...)	1156	nready (...)
1090	PROTOTYPE:	1157	PROTOTYPE:
1091	CODE:	1158	CODE:
1092	RETVAL = coro_nready;	1159	RETVAL = coro_nready;
1093	OUTPUT:	1160	OUTPUT:
1094	RETVAL	1161	RETVAL
1095		1162
1096	void	1163	void
1097	schedule(...)	1164	schedule (...)
1098	PROTOTYPE:	1165	PROTOTYPE:
1099	CODE:	1166	CODE:
1100	api_schedule ();	1167	api_schedule ();
1101		1168
1102	void	1169	void
1103	cede(...)	1170	cede (...)
1104	PROTOTYPE:	1171	PROTOTYPE:
1105	CODE:	1172	CODE:
1106	api_cede ();	1173	api_cede ();
1107		1174
1108	# and these are hacks	1175	# and these are hacks

Diff Legend

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

Comparing Coro/Coro/State.xs (file contents): Revision 1.85 by root, Fri Nov 24 00:32:04 2006 UTC vs. Revision 1.87 by root, Fri Nov 24 13:40:36 2006 UTC

Diff Legend

Comparing Coro/Coro/State.xs (file contents):
Revision 1.85 by root, Fri Nov 24 00:32:04 2006 UTC vs.
Revision 1.87 by root, Fri Nov 24 13:40:36 2006 UTC