[ViewVC] Diff of: cvs/EV/EV.xs

Comparing EV/EV.xs (file contents):
Revision 1.94 by root, Thu Dec 20 09:32:19 2007 UTC vs.
Revision 1.103 by root, Wed Dec 26 14:55:22 2007 UTC

…		…
3	#include "XSUB.h"	3	#include "XSUB.h"
4		4
5	/#include <netinet/in.h>/	5	/#include <netinet/in.h>/
6		6
7	#define EV_PROTOTYPES 1	7	#define EV_PROTOTYPES 1
		8	#define EV_USE_NANOSLEEP EV_USE_MONOTONIC
8	#define EV_H <ev.h>	9	#define EV_H <ev.h>
9	#include "EV/EVAPI.h"	10	#include "EV/EVAPI.h"
10		11
11	/* fix perl api breakage */	12	/* fix perl api breakage */
12	#undef signal	13	#undef signal
…		…
40	ev_ref (e_loop (w));	41	ev_ref (e_loop (w));
41		42
42	#define START(type,w) \	43	#define START(type,w) \
43	do { \	44	do { \
44	UNREF (w); \	45	UNREF (w); \
45	ev_ ## type ## _start (e_loop (w), w); \	46	ev_ ## type ## _start (e_loop (w), w); \
46	} while (0)	47	} while (0)
47		48
48	#define STOP(type,w) \	49	#define STOP(type,w) \
49	do { \	50	do { \
50	REF (w); \	51	REF (w); \
51	ev_ ## type ## _stop (e_loop (w), w); \	52	ev_ ## type ## _stop (e_loop (w), w); \
52	} while (0)	53	} while (0)
53		54
54	#define RESET(type,w,seta) \	55	#define RESET(type,w,seta) \
55	do { \	56	do { \
56	int active = ev_is_active (w); \	57	int active = ev_is_active (w); \
…		…
388	evapi.sv_signum = sv_signum;	389	evapi.sv_signum = sv_signum;
389	evapi.supported_backends = ev_supported_backends ();	390	evapi.supported_backends = ev_supported_backends ();
390	evapi.recommended_backends = ev_recommended_backends ();	391	evapi.recommended_backends = ev_recommended_backends ();
391	evapi.embeddable_backends = ev_embeddable_backends ();	392	evapi.embeddable_backends = ev_embeddable_backends ();
392	evapi.time = ev_time;	393	evapi.time = ev_time;
		394	evapi.sleep = ev_sleep;
393	evapi.loop_new = ev_loop_new;	395	evapi.loop_new = ev_loop_new;
394	evapi.loop_destroy = ev_loop_destroy;	396	evapi.loop_destroy = ev_loop_destroy;
395	evapi.loop_fork = ev_loop_fork;	397	evapi.loop_fork = ev_loop_fork;
396	evapi.loop_count = ev_loop_count;	398	evapi.loop_count = ev_loop_count;
397	evapi.now = ev_now;	399	evapi.now = ev_now;
…		…
435	#ifndef _WIN32	437	#ifndef _WIN32
436	pthread_atfork (0, 0, ev_default_fork);	438	pthread_atfork (0, 0, ev_default_fork);
437	#endif	439	#endif
438	}	440	}
439		441
440	SV *ev_default_loop (unsigned int flags = ev_supported_backends ())	442	SV *ev_default_loop (unsigned int flags = 0)
441	CODE:	443	CODE:
442	{	444	{
443	if (!default_loop_sv)	445	if (!default_loop_sv)
444	{	446	{
445	evapi.default_loop = ev_default_loop (flags);	447	evapi.default_loop = ev_default_loop (flags);
…		…
453	RETVAL = newSVsv (default_loop_sv);	455	RETVAL = newSVsv (default_loop_sv);
454	}	456	}
455	OUTPUT:	457	OUTPUT:
456	RETVAL	458	RETVAL
457		459
		460	void ev_default_destroy ()
		461	CODE:
		462	ev_default_destroy ();
		463	SvREFCNT_dec (default_loop_sv);
		464	default_loop_sv = 0;
		465
		466	unsigned int ev_supported_backends ()
		467
		468	unsigned int ev_recommended_backends ()
		469
		470	unsigned int ev_embeddable_backends ()
		471
458	NV ev_time ()	472	NV ev_time ()
459		473
460	NV ev_now ()	474	NV ev_now ()
461	C_ARGS: evapi.default_loop	475	C_ARGS: evapi.default_loop
462		476
463	unsigned int ev_backend ()	477	unsigned int ev_backend ()
464	C_ARGS: evapi.default_loop	478	C_ARGS: evapi.default_loop
465		479
466	unsigned int ev_loop_count ()	480	unsigned int ev_loop_count ()
467	C_ARGS: evapi.default_loop	481	C_ARGS: evapi.default_loop
		482
		483	void ev_set_io_collect_interval (NV interval)
		484	C_ARGS: evapi.default_loop, interval
		485
		486	void ev_set_timeout_collect_interval (NV interval)
		487	C_ARGS: evapi.default_loop, interval
468		488
469	void ev_loop (int flags = 0)	489	void ev_loop (int flags = 0)
470	C_ARGS: evapi.default_loop, flags	490	C_ARGS: evapi.default_loop, flags
471		491
472	void ev_unloop (int how = 1)	492	void ev_unloop (int how = 1)
…		…
603	ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);	623	ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
604	if (!ix) START (stat, RETVAL);	624	if (!ix) START (stat, RETVAL);
605	OUTPUT:	625	OUTPUT:
606	RETVAL	626	RETVAL
607		627
608	ev_embed embed (struct ev_loop loop, SV *cb)	628	ev_embed embed (struct ev_loop loop, SV *cb = &PL_sv_undef)
609	ALIAS:	629	ALIAS:
610	embed_ns = 1	630	embed_ns = 1
611	CODE:	631	CODE:
		632	{
		633	if (!(ev_backend (loop) & ev_embeddable_backends ()))
		634	croak ("passed loop is not embeddable via EV::embed,");
		635
612	RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv);	636	RETVAL = e_new (sizeof (ev_embed), cb, default_loop_sv);
613	RETVAL->fh = newSVsv (ST (0));	637	RETVAL->fh = newSVsv (ST (0));
614	ev_embed_set (RETVAL, loop);	638	ev_embed_set (RETVAL, loop);
		639
		640	if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
		641
615	if (!ix) START (embed, RETVAL);	642	if (!ix) START (embed, RETVAL);
		643	}
616	OUTPUT:	644	OUTPUT:
617	RETVAL	645	RETVAL
618		646
619	void once (SV fh, int events, SV timeout, SV *cb)	647	void once (SV fh, int events, SV timeout, SV *cb)
620	CODE:	648	CODE:
…		…
679	{	707	{
680	SvREFCNT_dec (w->data);	708	SvREFCNT_dec (w->data);
681	w->data = newSVsv (new_data);	709	w->data = newSVsv (new_data);
682	}	710	}
683	}	711	}
		712	OUTPUT:
		713	RETVAL
		714
		715	SV loop (ev_watcher w)
		716	CODE:
		717	RETVAL = newRV_inc (w->loop);
684	OUTPUT:	718	OUTPUT:
685	RETVAL	719	RETVAL
686		720
687	int priority (ev_watcher *w, int new_priority = 0)	721	int priority (ev_watcher *w, int new_priority = 0)
688	CODE:	722	CODE:
…		…
901	void DESTROY (ev_idle *w)	935	void DESTROY (ev_idle *w)
902	CODE:	936	CODE:
903	STOP (idle, w);	937	STOP (idle, w);
904	e_destroy (w);	938	e_destroy (w);
905		939
906	MODULE = EV PACKAGE = EV::Prepare PREFIX = ev_check_	940	MODULE = EV PACKAGE = EV::Prepare PREFIX = ev_prepare_
907		941
908	void ev_prepare_start (ev_prepare *w)	942	void ev_prepare_start (ev_prepare *w)
909	CODE:	943	CODE:
910	START (prepare, w);	944	START (prepare, w);
911		945
…		…
1101	{	1135	{
1102	sv_setsv (w->fh, ST (1));	1136	sv_setsv (w->fh, ST (1));
1103	RESET (embed, w, (w, loop));	1137	RESET (embed, w, (w, loop));
1104	}	1138	}
1105		1139
		1140	SV other (ev_embed w)
		1141	CODE:
		1142	RETVAL = newSVsv (w->fh);
		1143	OUTPUT:
		1144	RETVAL
		1145
1106	MODULE = EV PACKAGE = EV::Loop PREFIX = ev_loop_	1146	MODULE = EV PACKAGE = EV::Loop PREFIX = ev_
1107		1147
1108	SV new (SV klass, unsigned int flags = ev_supported_backends ())	1148	SV new (SV klass, unsigned int flags = 0)
1109	CODE:	1149	CODE:
1110	{	1150	{
1111	struct ev_loop *loop = ev_loop_new (flags);	1151	struct ev_loop *loop = ev_loop_new (flags);
1112		1152
1113	if (!loop)	1153	if (!loop)
1114	XSRETURN_UNDEF;	1154	XSRETURN_UNDEF;
1115		1155
1116	RETVAL = sv_bless (newRV_noinc (newSViv (PTR2IV (evapi.default_loop))), stash_loop);	1156	RETVAL = sv_bless (newRV_noinc (newSViv (PTR2IV (loop))), stash_loop);
1117	}	1157	}
1118	OUTPUT:	1158	OUTPUT:
1119	RETVAL	1159	RETVAL
1120		1160
1121	void DESTROY (struct ev_loop *loop)	1161	void DESTROY (struct ev_loop *loop)
1122	CODE:	1162	CODE:
1123	if (loop != evapi.default_loop) /* global destruction sucks */	1163	if (loop != evapi.default_loop) /* global destruction sucks */
1124	ev_loop_destroy (loop);	1164	ev_loop_destroy (loop);
		1165
		1166	void ev_loop_fork (struct ev_loop *loop)
		1167
		1168	NV ev_now (struct ev_loop *loop)
		1169
		1170	void ev_set_io_collect_interval (struct ev_loop *loop, NV interval)
		1171
		1172	void ev_set_timeout_collect_interval (struct ev_loop *loop, NV interval)
		1173
		1174	unsigned int ev_backend (struct ev_loop *loop)
		1175
		1176	unsigned int ev_loop_count (struct ev_loop *loop)
		1177
		1178	void ev_loop (struct ev_loop *loop, int flags = 0)
		1179
		1180	void ev_unloop (struct ev_loop *loop, int how = 1)
		1181
		1182	void ev_feed_fd_event (struct ev_loop *loop, int fd, int revents = EV_NONE)
		1183
		1184	#if 0
		1185
		1186	void ev_feed_signal_event (struct ev_loop loop, SV signal)
		1187	CODE:
		1188	{
		1189	Signal signum = sv_signum (signal);
		1190	CHECK_SIG (signal, signum);
		1191
		1192	ev_feed_signal_event (loop, signum);
		1193	}
		1194
		1195	#endif
1125		1196
1126	ev_io io (struct ev_loop loop, SV fh, int events, SV cb)	1197	ev_io io (struct ev_loop loop, SV fh, int events, SV cb)
1127	ALIAS:	1198	ALIAS:
1128	io_ns = 1	1199	io_ns = 1
1129	CODE:	1200	CODE:
…		…
1137	if (!ix) START (io, RETVAL);	1208	if (!ix) START (io, RETVAL);
1138	}	1209	}
1139	OUTPUT:	1210	OUTPUT:
1140	RETVAL	1211	RETVAL
1141		1212
		1213	ev_timer timer (struct ev_loop loop, NV after, NV repeat, SV *cb)
		1214	ALIAS:
		1215	timer_ns = 1
		1216	INIT:
		1217	CHECK_REPEAT (repeat);
		1218	CODE:
		1219	RETVAL = e_new (sizeof (ev_timer), cb, ST (0));
		1220	ev_timer_set (RETVAL, after, repeat);
		1221	if (!ix) START (timer, RETVAL);
		1222	OUTPUT:
		1223	RETVAL
		1224
		1225	SV periodic (struct ev_loop loop, NV at, NV interval, SV reschedule_cb, SV cb)
		1226	ALIAS:
		1227	periodic_ns = 1
		1228	INIT:
		1229	CHECK_REPEAT (interval);
		1230	CODE:
		1231	{
		1232	ev_periodic *w;
		1233	w = e_new (sizeof (ev_periodic), cb, ST (0));
		1234	w->fh = SvTRUE (reschedule_cb) ? newSVsv (reschedule_cb) : 0;
		1235	ev_periodic_set (w, at, interval, w->fh ? e_periodic_cb : 0);
		1236	RETVAL = e_bless ((ev_watcher *)w, stash_periodic);
		1237	if (!ix) START (periodic, w);
		1238	}
		1239	OUTPUT:
		1240	RETVAL
		1241
		1242	#if 0
		1243
		1244	ev_signal signal (struct ev_loop loop, SV signal, SV cb)
		1245	ALIAS:
		1246	signal_ns = 1
		1247	CODE:
		1248	{
		1249	Signal signum = sv_signum (signal);
		1250	CHECK_SIG (signal, signum);
		1251
		1252	RETVAL = e_new (sizeof (ev_signal), cb, ST (0));
		1253	ev_signal_set (RETVAL, signum);
		1254	if (!ix) START (signal, RETVAL);
		1255	}
		1256	OUTPUT:
		1257	RETVAL
		1258
		1259	#endif
		1260
		1261	ev_idle idle (struct ev_loop loop, SV *cb)
		1262	ALIAS:
		1263	idle_ns = 1
		1264	CODE:
		1265	RETVAL = e_new (sizeof (ev_idle), cb, ST (0));
		1266	ev_idle_set (RETVAL);
		1267	if (!ix) START (idle, RETVAL);
		1268	OUTPUT:
		1269	RETVAL
		1270
		1271	ev_prepare prepare (struct ev_loop loop, SV *cb)
		1272	ALIAS:
		1273	prepare_ns = 1
		1274	CODE:
		1275	RETVAL = e_new (sizeof (ev_prepare), cb, ST (0));
		1276	ev_prepare_set (RETVAL);
		1277	if (!ix) START (prepare, RETVAL);
		1278	OUTPUT:
		1279	RETVAL
		1280
		1281	ev_check check (struct ev_loop loop, SV *cb)
		1282	ALIAS:
		1283	check_ns = 1
		1284	CODE:
		1285	RETVAL = e_new (sizeof (ev_check), cb, ST (0));
		1286	ev_check_set (RETVAL);
		1287	if (!ix) START (check, RETVAL);
		1288	OUTPUT:
		1289	RETVAL
		1290
		1291	ev_fork fork (struct ev_loop loop, SV *cb)
		1292	ALIAS:
		1293	fork_ns = 1
		1294	CODE:
		1295	RETVAL = e_new (sizeof (ev_fork), cb, ST (0));
		1296	ev_fork_set (RETVAL);
		1297	if (!ix) START (fork, RETVAL);
		1298	OUTPUT:
		1299	RETVAL
		1300
		1301	ev_child child (struct ev_loop loop, int pid, SV *cb)
		1302	ALIAS:
		1303	child_ns = 1
		1304	CODE:
		1305	RETVAL = e_new (sizeof (ev_child), cb, ST (0));
		1306	ev_child_set (RETVAL, pid);
		1307	if (!ix) START (child, RETVAL);
		1308	OUTPUT:
		1309	RETVAL
		1310
		1311	ev_stat stat (struct ev_loop loop, SV path, NV interval, SV cb)
		1312	ALIAS:
		1313	stat_ns = 1
		1314	CODE:
		1315	RETVAL = e_new (sizeof (ev_stat), cb, ST (0));
		1316	RETVAL->fh = newSVsv (path);
		1317	ev_stat_set (RETVAL, SvPVbyte_nolen (RETVAL->fh), interval);
		1318	if (!ix) START (stat, RETVAL);
		1319	OUTPUT:
		1320	RETVAL
		1321
		1322	ev_embed embed (struct ev_loop loop, struct ev_loop other, SV cb = &PL_sv_undef)
		1323	ALIAS:
		1324	embed_ns = 1
		1325	CODE:
		1326	{
		1327	if (!(ev_backend (other) & ev_embeddable_backends ()))
		1328	croak ("passed loop is not embeddable via EV::embed,");
		1329
		1330	RETVAL = e_new (sizeof (ev_embed), cb, ST (0));
		1331	RETVAL->fh = newSVsv (ST (1));
		1332	ev_embed_set (RETVAL, other);
		1333
		1334	if (!SvOK (cb)) ev_set_cb (RETVAL, 0);
		1335
		1336	if (!ix) START (embed, RETVAL);
		1337	}
		1338	OUTPUT:
		1339	RETVAL
		1340
		1341	void once (struct ev_loop loop, SV fh, int events, SV timeout, SV cb)
		1342	CODE:
		1343	ev_once (
		1344	loop,
		1345	sv_fileno (fh), events,
		1346	SvOK (timeout) ? SvNV (timeout) : -1.,
		1347	e_once_cb,
		1348	newSVsv (cb)
		1349	);
		1350

Diff Legend

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

Comparing EV/EV.xs (file contents): Revision 1.94 by root, Thu Dec 20 09:32:19 2007 UTC vs. Revision 1.103 by root, Wed Dec 26 14:55:22 2007 UTC

Diff Legend

Comparing EV/EV.xs (file contents):
Revision 1.94 by root, Thu Dec 20 09:32:19 2007 UTC vs.
Revision 1.103 by root, Wed Dec 26 14:55:22 2007 UTC