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

Comparing Coro/Coro/State.xs (file contents):
Revision 1.86 by root, Fri Nov 24 11:36:57 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));
		1002	}
		1003
		1004	SV *
947	new (char *klass, ...)	1005	new (char *klass, ...)
948	PROTOTYPE: $@
949	CODE:	1006	CODE:
950	{	1007	{
951	Coro__State coro;	1008	struct coro *coro;
		1009	HV *hv;
952	int i;	1010	int i;
953
954	if (!SvOK (ST (1)))
955	croak ("Coro::State::new needs something callable as first argument");
956		1011
957	Newz (0, coro, 1, struct coro);	1012	Newz (0, coro, 1, struct coro);
958	coro->args = newAV ();	1013	coro->args = newAV ();
959		1014
960	for (i = 1; i < items; i++)	1015	for (i = 1; i < items; i++)
961	av_push (coro->args, newSVsv (ST (i)));	1016	av_push (coro->args, newSVsv (ST (i)));
962		1017
963	RETVAL = coro;
964
965	/coro->mainstack = 0; //actual work is done inside transfer /	1018	/coro->mainstack = 0; //actual work is done inside transfer /
966	/coro->stack = 0;/	1019	/coro->stack = 0;/
		1020
		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));
967	}	1024	}
968	OUTPUT:	1025	OUTPUT:
969	RETVAL	1026	RETVAL
970		1027
971	void	1028	void
972	transfer(prev, next, flags)	1029	transfer(prev, next, flags)
973	SV *prev	1030	SV *prev
974	SV *next	1031	SV *next
975	int flags	1032	int flags
976	PROTOTYPE: @
977	CODE:	1033	CODE:
978	PUTBACK;	1034	PUTBACK;
979	SV_CORO (next, "Coro::transfer");	1035	SV_CORO (next, "Coro::transfer");
980	SV_CORO (prev, "Coro::transfer");	1036	SV_CORO (prev, "Coro::transfer");
981	coro_state_transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags);	1037	coro_state_transfer (aTHX_ SvSTATE (prev), SvSTATE (next), flags);
982	SPAGAIN;	1038	SPAGAIN;
983		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
984	void	1060	void
985	DESTROY(coro)	1061	_clone_state_from (SV dst, SV src)
986	Coro::State coro	1062	CODE:
987	CODE:	1063	{
		1064	struct coro *coro_src = SvSTATE (src);
988		1065
989	if (coro->mainstack && coro->mainstack != main_mainstack)	1066	sv_unmagic (SvRV (dst), PERL_MAGIC_ext);
990	{
991	struct coro temp;
992		1067
993	PUTBACK;	1068	++coro_src->refcnt;
994	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;
995	LOAD (aTHX_ coro);	1070	}
996	SPAGAIN;
997
998	destroy_stacks (aTHX);
999
1000	LOAD ((&temp)); /* this will get rid of defsv etc.. */
1001	SPAGAIN;
1002
1003	coro->mainstack = 0;
1004	}
1005
1006	deallocate_stack (coro);
1007	SvREFCNT_dec (coro->args);
1008	Safefree (coro);
1009		1071
1010	void	1072	void
1011	_exit(code)	1073	_exit (code)
1012	int code	1074	int code
1013	PROTOTYPE: $	1075	PROTOTYPE: $
1014	CODE:	1076	CODE:
1015	_exit (code);	1077	_exit (code);
1016		1078
1017	MODULE = Coro::State PACKAGE = Coro::Cont	1079	MODULE = Coro::State PACKAGE = Coro::Cont
1018		1080
1019	void	1081	void
1020	yield(...)	1082	yield (...)
1021	PROTOTYPE: @	1083	PROTOTYPE: @
1022	CODE:	1084	CODE:
1023	SV *yieldstack;	1085	SV *yieldstack;
1024	SV *sv;	1086	SV *sv;
1025	AV *defav = GvAV (PL_defgv);	1087	AV *defav = GvAV (PL_defgv);
…		…
1080	}	1142	}
1081		1143
1082	#if !PERL_MICRO	1144	#if !PERL_MICRO
1083		1145
1084	void	1146	void
1085	ready(self)	1147	ready (self)
1086	SV * self	1148	SV * self
1087	PROTOTYPE: $	1149	PROTOTYPE: $
1088	CODE:	1150	CODE:
1089	api_ready (self);	1151	api_ready (self);
1090		1152
1091	#endif	1153	#endif
1092		1154
1093	int	1155	int
1094	nready(...)	1156	nready (...)
1095	PROTOTYPE:	1157	PROTOTYPE:
1096	CODE:	1158	CODE:
1097	RETVAL = coro_nready;	1159	RETVAL = coro_nready;
1098	OUTPUT:	1160	OUTPUT:
1099	RETVAL	1161	RETVAL
1100		1162
1101	void	1163	void
1102	schedule(...)	1164	schedule (...)
1103	PROTOTYPE:	1165	PROTOTYPE:
1104	CODE:	1166	CODE:
1105	api_schedule ();	1167	api_schedule ();
1106		1168
1107	void	1169	void
1108	cede(...)	1170	cede (...)
1109	PROTOTYPE:	1171	PROTOTYPE:
1110	CODE:	1172	CODE:
1111	api_cede ();	1173	api_cede ();
1112		1174
1113	# 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.86 by root, Fri Nov 24 11:36:57 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.86 by root, Fri Nov 24 11:36:57 2006 UTC vs.
Revision 1.87 by root, Fri Nov 24 13:40:36 2006 UTC