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

Comparing Coro/Event/Event.xs (file contents):
Revision 1.9 by root, Sat Mar 22 18:50:32 2003 UTC vs.
Revision 1.17 by root, Mon Dec 4 22:05:49 2006 UTC

…		…
1	#include "EXTERN.h"	1	#include "EXTERN.h"
2	#include "perl.h"	2	#include "perl.h"
3	#include "XSUB.h"	3	#include "XSUB.h"
4		4
		5	#include <assert.h>
5	#include <string.h>	6	#include <string.h>
6
7	/* this useful idiom is unfortunately missing... */
8	static void
9	confess (const char *msg)
10	{
11	dSP;
12
13	PUSHMARK(SP);
14	XPUSHs (sv_2mortal(newSVpv("only one coroutine can wait for an event at any given time",0)));
15	PUTBACK;
16	call_pv ("Carp::confess", G_VOID);
17	}
18		7
19	#include "EventAPI.h"	8	#include "EventAPI.h"
20	#include "../Coro/CoroAPI.h"	9	#include "../Coro/CoroAPI.h"
21		10
22	#ifndef PE_PERLCB	11	#define CD_WAIT 0 /* wait queue */
23	# define PE_PERLCB 0x020 /* not public, but we need it :( */
24	#endif
25
26	#define CD_CORO 0
27	#define CD_TYPE 1	12	#define CD_TYPE 1
28	#define CD_OK 2	13	#define CD_OK 2
29	#define CD_PRIO 3 /* hardcoded in Coro::Event */	14
30	#define CD_HITS 4 /* hardcoded in Coro::Event */	15	#define CD_HITS 4 /* hardcoded in Coro::Event */
31	#define CD_GOT 5 /* hardcoded in Coro::Event, Coro::Handle */	16	#define CD_GOT 5 /* hardcoded in Coro::Event, Coro::Handle */
32	#define CD_MAX 5	17	#define CD_MAX 5
33		18
34	#define EV_CLASS "Coro::Event"
35
36	static pe_idle *scheduler;
37	static int do_schedule;
38
39	#define NEED_SCHEDULE if (!do_schedule) \
40	{ \
41	do_schedule = 1; \
42	GEventAPI->now ((pe_watcher *)scheduler); \
43	}
44
45	static void	19	static void
46	coro_std_cb(pe_event *pe)	20	coro_std_cb (pe_event *pe)
47	{	21	{
48	AV priv = (AV )pe->ext_data;	22	AV priv = (AV )pe->ext_data;
49	IV type = SvIV (*av_fetch (priv, CD_TYPE, 1));	23	IV type = SvIV (AvARRAY (priv)[CD_TYPE]);
50	SV **cd_coro = &AvARRAY(priv)[CD_CORO];	24	AV *cd_wait;
		25	SV *coro;
51		26
52	sv_setiv (AvARRAY(priv)[CD_PRIO], pe->prio);
53	sv_setiv (AvARRAY(priv)[CD_HITS], pe->hits);	27	SvIV_set (AvARRAY (priv)[CD_HITS], pe->hits);
		28	SvIV_set (AvARRAY (priv)[CD_GOT], type ? ((pe_ioevent *)pe)->got : 0);
54		29
55	if (type == 1)	30	AvARRAY (priv)[CD_OK] = &PL_sv_yes;
56	sv_setiv (AvARRAY(priv)[CD_GOT], ((pe_ioevent *)pe)->got);
57		31
58	if (*cd_coro != &PL_sv_undef)	32	cd_wait = (AV *)AvARRAY(priv)[CD_WAIT];
		33	if ((coro = av_shift (cd_wait)))
59	{	34	{
60	CORO_READY (*cd_coro);	35	if (av_len (cd_wait) < 0)
61	SvREFCNT_dec (*cd_coro);
62	*cd_coro = &PL_sv_undef;
63	NEED_SCHEDULE;
64	}
65	else
66	{
67	AvARRAY(priv)[CD_OK] = &PL_sv_yes;
68	GEventAPI->stop (pe->up, 0);	36	GEventAPI->stop (pe->up, 0);
		37
		38	CORO_READY (coro);
		39	SvREFCNT_dec (coro);
69	}	40	}
70	}	41	}
71		42
72	static void	43	static void
73	scheduler_cb(pe_event *pe)	44	asynccheck_hook (void *data)
74	{	45	{
		46	/* ceding from C means allocating a stack, but we assume this is a rare case */
75	while (CORO_NREADY)	47	while (CORO_NREADY)
76	CORO_CEDE;	48	CORO_CEDE;
77
78	do_schedule = 0;
79	}	49	}
80		50
81	MODULE = Coro::Event PACKAGE = Coro::Event	51	MODULE = Coro::Event PACKAGE = Coro::Event
82		52
83	PROTOTYPES: ENABLE	53	PROTOTYPES: ENABLE
85	BOOT:	55	BOOT:
86	{	56	{
87	I_EVENT_API ("Coro::Event");	57	I_EVENT_API ("Coro::Event");
88	I_CORO_API ("Coro::Event");	58	I_CORO_API ("Coro::Event");
89		59
90	/* create a fake idle handler (we only ever call now) */	60	GEventAPI->add_hook ("asynccheck", (void *)asynccheck_hook, 0);
91	scheduler = GEventAPI->new_idle (0, 0);
92	scheduler->base.callback = scheduler_cb;
93	scheduler->base.prio = PE_PRIO_NORMAL; /* StarvePrio */
94	scheduler->min_interval = newSVnv (0);
95	scheduler->max_interval = newSVnv (0);
96	GEventAPI->stop ((pe_watcher *)scheduler, 0);
97	}	61	}
98		62
99	void	63	void
100	_install_std_cb(self,type)	64	_install_std_cb (SV *self, int type)
101	SV * self
102	int type
103	CODE:	65	CODE:
		66	{
104	pe_watcher *w = GEventAPI->sv_2watcher (self);	67	pe_watcher *w = GEventAPI->sv_2watcher (self);
105		68
106	if (WaFLAGS (w) & PE_PERLCB)	69	if (w->callback)
107	croak ("Coro::Event watchers must not have a perl callback (see Coro::Event), caught");	70	croak ("Coro::Event watchers must not have a callback (see Coro::Event), caught");
		71
108	{	72	{
109	AV *priv = newAV ();	73	AV *priv = newAV ();
110	SV rv = newRV_noinc ((SV )priv);	74	SV rv = newRV_noinc ((SV )priv);
111		75
112	av_extend (priv, CD_MAX);	76	av_fill (priv, CD_MAX);
113	av_store (priv, CD_CORO, &PL_sv_undef);	77	AvARRAY (priv)[CD_WAIT] = (SV )newAV (); / badbad */
114	av_store (priv, CD_TYPE, newSViv (type));	78	AvARRAY (priv)[CD_TYPE] = newSViv (type);
115	av_store (priv, CD_OK , &PL_sv_no);	79	AvARRAY (priv)[CD_OK ] = &PL_sv_no;
116	av_store (priv, CD_PRIO, newSViv (0));
117	av_store (priv, CD_HITS, newSViv (0));	80	AvARRAY (priv)[CD_HITS] = newSViv (0);
118	av_store (priv, CD_GOT , type ? newSViv (0) : &PL_sv_undef);	81	AvARRAY (priv)[CD_GOT ] = newSViv (0);
119	SvREADONLY_on (priv);	82	SvREADONLY_on (priv);
120		83
121	w->callback = coro_std_cb;	84	w->callback = coro_std_cb;
122	w->ext_data = priv;	85	w->ext_data = priv;
123		86
124	hv_store ((HV *)SvRV (self),	87	/* make sure Event does not use PERL_MAGIC_uvar, which */
125	EV_CLASS, strlen (EV_CLASS),	88	/* we abuse for non-uvar purposes. */
126	rv, 0);	89	sv_magicext (SvRV (self), rv, PERL_MAGIC_uvar, 0, 0, 0);
127
128	GEventAPI->start (w, 0);
129	}	90	}
		91	}
130		92
131	void	93	void
132	_next(self)	94	_next (SV *self)
133	SV * self
134	CODE:	95	CODE:
		96	{
135	pe_watcher *w = GEventAPI->sv_2watcher (self);	97	pe_watcher *w = GEventAPI->sv_2watcher (self);
136	AV priv = (AV )w->ext_data;	98	AV priv = (AV )w->ext_data;
		99
		100	if (AvARRAY (priv)[CD_OK] == &PL_sv_yes)
		101	{
		102	AvARRAY (priv)[CD_OK] = &PL_sv_no;
		103	XSRETURN_NO; /* got an event */
		104	}
		105
		106	av_push ((AV *)AvARRAY (priv)[CD_WAIT], SvREFCNT_inc (CORO_CURRENT));
137		107
138	if (!w->running)	108	if (!w->running)
139	GEventAPI->start (w, 1);	109	GEventAPI->start (w, 1);
140		110
141	if (AvARRAY(priv)[CD_OK] == &PL_sv_yes)	111	XSRETURN_YES; /* schedule */
142	{	112	}
143	AvARRAY(priv)[CD_OK] = &PL_sv_no;
144	XSRETURN_NO;
145	}
146	else
147	{
148	if (AvARRAY(priv)[CD_CORO] != &PL_sv_undef)
149	confess ("only one coroutine can wait for an event");
150		113
151	AvARRAY(priv)[CD_CORO] = SvREFCNT_inc (CORO_CURRENT);	114	SV *
		115	_event (SV *self)
		116	CODE:
		117	{
		118	if (GIMME_V == G_VOID)
152	XSRETURN_YES;	119	XSRETURN_EMPTY;
153	}
154		120
155	MODULE = Coro::Event PACKAGE = Coro	121	{
		122	pe_watcher *w = GEventAPI->sv_2watcher (self);
		123	AV priv = (AV )w->ext_data;
156		124
157	# overwrite the ready function	125	RETVAL = newRV_inc ((SV *)priv);
158	void	126	}
159	ready(self)	127	}
160	SV * self	128	OUTPUT:
161	PROTOTYPE: $	129	RETVAL
162	CODE:
163	NEED_SCHEDULE;
164	CORO_READY (self);
165		130
166

Diff Legend

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

Comparing Coro/Event/Event.xs (file contents): Revision 1.9 by root, Sat Mar 22 18:50:32 2003 UTC vs. Revision 1.17 by root, Mon Dec 4 22:05:49 2006 UTC

Diff Legend

Comparing Coro/Event/Event.xs (file contents):
Revision 1.9 by root, Sat Mar 22 18:50:32 2003 UTC vs.
Revision 1.17 by root, Mon Dec 4 22:05:49 2006 UTC