[ViewVC] Diff of: cvs/IO-AIO/AIO.xs

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.58 by root, Mon Oct 23 18:48:08 2006 UTC vs.
Revision 1.63 by root, Mon Oct 23 23:48:31 2006 UTC

…		…
		1	#if __linux
		2	# define _GNU_SOURCE
		3	#endif
		4
1	#define _REENTRANT 1	5	#define _REENTRANT 1
		6
2	#include <errno.h>	7	#include <errno.h>
3		8
4	#include "EXTERN.h"	9	#include "EXTERN.h"
5	#include "perl.h"	10	#include "perl.h"
6	#include "XSUB.h"	11	#include "XSUB.h"
66		71
67	typedef struct aio_cb	72	typedef struct aio_cb
68	{	73	{
69	struct aio_cb *volatile next;	74	struct aio_cb *volatile next;
70		75
71	struct aio_cb grp, grp_prev, grp_next, grp_first;
72
73	SV self; / the perl counterpart of this request, if any */
74
75	SV data, callback;	76	SV data, callback;
76	SV fh, fh2;	77	SV fh, fh2;
77	void dataptr, data2ptr;	78	void dataptr, data2ptr;
78	Stat_t *statdata;	79	Stat_t *statdata;
79	off_t offset;	80	off_t offset;
80	size_t length;	81	size_t length;
81	ssize_t result;	82	ssize_t result;
82		83
		84	STRLEN dataoffset;
83	int type;	85	int type;
84	int fd, fd2;	86	int fd, fd2;
85	int errorno;	87	int errorno;
86	STRLEN dataoffset;
87	mode_t mode; /* open */	88	mode_t mode; /* open */
		89
		90	unsigned char flags;
88	unsigned char pri;	91	unsigned char pri;
89	unsigned char flags;	92
		93	SV self; / the perl counterpart of this request, if any */
		94	struct aio_cb grp, grp_prev, grp_next, grp_first;
90	} aio_cb;	95	} aio_cb;
91		96
92	enum {	97	enum {
93	FLAG_CANCELLED = 0x01,	98	FLAG_CANCELLED = 0x01,
94	};	99	};
95		100
96	typedef aio_cb *aio_req;	101	typedef aio_cb *aio_req;
97	typedef aio_cb *aio_req_ornot;	102	typedef aio_cb *aio_req_ornot;
		103
		104	enum {
		105	PRI_MIN = -4,
		106	PRI_MAX = 4,
		107
		108	DEFAULT_PRI = 0,
		109	PRI_BIAS = -PRI_MIN,
		110	};
		111
		112	static int next_pri = DEFAULT_PRI + PRI_BIAS;
98		113
99	static int started, wanted;	114	static int started, wanted;
100	static volatile int nreqs;	115	static volatile int nreqs;
101	static int max_outstanding = 1<<30;	116	static int max_outstanding = 1<<30;
102	static int respipe [2];	117	static int respipe [2];
103		118
		119	#if __linux && defined (PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP)
		120	# define AIO_MUTEX_INIT PTHREAD_ADAPTIVE_MUTEX_INITIALIZER_NP
		121	#else
		122	# define AIO_MUTEX_INIT PTHREAD_MUTEX_INITIALIZER
		123	#endif
		124
104	static pthread_mutex_t reslock = PTHREAD_MUTEX_INITIALIZER;	125	static pthread_mutex_t reslock = AIO_MUTEX_INIT;
105	static pthread_mutex_t reqlock = PTHREAD_MUTEX_INITIALIZER;	126	static pthread_mutex_t reqlock = AIO_MUTEX_INIT;
106	static pthread_cond_t reqwait = PTHREAD_COND_INITIALIZER;	127	static pthread_cond_t reqwait = PTHREAD_COND_INITIALIZER;
107		128
108	static volatile aio_req reqs, reqe; /* queue start, queue end */	129	static volatile aio_req reqs, reqe; /* queue start, queue end */
109	static volatile aio_req ress, rese; /* queue start, queue end */	130	static volatile aio_req ress, rese; /* queue start, queue end */
110		131
…		…
181	}	202	}
182	}	203	}
183		204
184	static void poll_wait ()	205	static void poll_wait ()
185	{	206	{
186	if (nreqs && !ress)
187	{
188	fd_set rfd;	207	fd_set rfd;
		208
		209	while (nreqs)
		210	{
		211	aio_req req;
		212	pthread_mutex_lock (&reslock);
		213	req = ress;
		214	pthread_mutex_unlock (&reslock);
		215
		216	if (req)
		217	return;
		218
189	FD_ZERO(&rfd);	219	FD_ZERO(&rfd);
190	FD_SET(respipe [0], &rfd);	220	FD_SET(respipe [0], &rfd);
191		221
192	select (respipe [0] + 1, &rfd, 0, 0, 0);	222	select (respipe [0] + 1, &rfd, 0, 0, 0);
193	}	223	}
…		…
790	}	820	}
791		821
792	pthread_mutex_unlock (&reqlock);	822	pthread_mutex_unlock (&reqlock);
793		823
794	errno = 0; /* strictly unnecessary */	824	errno = 0; /* strictly unnecessary */
		825	type = req->type; /* remember type for QUIT check */
795		826
796	if (!(req->flags & FLAG_CANCELLED))	827	if (!(req->flags & FLAG_CANCELLED))
797	switch (type = req->type) /* remember type for QUIT check */	828	switch (type)
798	{	829	{
799	case REQ_READ: req->result = pread (req->fd, req->dataptr, req->length, req->offset); break;	830	case REQ_READ: req->result = pread (req->fd, req->dataptr, req->length, req->offset); break;
800	case REQ_WRITE: req->result = pwrite (req->fd, req->dataptr, req->length, req->offset); break;	831	case REQ_WRITE: req->result = pwrite (req->fd, req->dataptr, req->length, req->offset); break;
801		832
802	case REQ_READAHEAD: req->result = readahead (req->fd, req->offset, req->length); break;	833	case REQ_READAHEAD: req->result = readahead (req->fd, req->offset, req->length); break;
…		…
921	atfork_parent ();	952	atfork_parent ();
922	}	953	}
923		954
924	#define dREQ \	955	#define dREQ \
925	aio_req req; \	956	aio_req req; \
		957	int req_pri = next_pri; \
		958	next_pri = DEFAULT_PRI + PRI_BIAS; \
926	\	959	\
927	if (SvOK (callback) && !SvROK (callback)) \	960	if (SvOK (callback) && !SvROK (callback)) \
928	croak ("callback must be undef or of reference type"); \	961	croak ("callback must be undef or of reference type"); \
929	\	962	\
930	Newz (0, req, 1, aio_cb); \	963	Newz (0, req, 1, aio_cb); \
931	if (!req) \	964	if (!req) \
932	croak ("out of memory during aio_req allocation"); \	965	croak ("out of memory during aio_req allocation"); \
933	\	966	\
934	req->callback = newSVsv (callback)	967	req->callback = newSVsv (callback); \
		968	req->pri = req_pri
935		969
936	#define REQ_SEND \	970	#define REQ_SEND \
937	req_send (req); \	971	req_send (req); \
938	\	972	\
939	if (GIMME_V != G_VOID) \	973	if (GIMME_V != G_VOID) \
…		…
1214	SV * callback	1248	SV * callback
1215	PROTOTYPE: ;$	1249	PROTOTYPE: ;$
1216	PPCODE:	1250	PPCODE:
1217	{	1251	{
1218	dREQ;	1252	dREQ;
		1253
1219	req->type = REQ_GROUP;	1254	req->type = REQ_GROUP;
1220	req_send (req);	1255	req_send (req);
		1256
1221	XPUSHs (req_sv (req, AIO_GRP_KLASS));	1257	XPUSHs (req_sv (req, AIO_GRP_KLASS));
1222	}	1258	}
1223		1259
1224	void	1260	void
1225	aio_nop (callback=&PL_sv_undef)	1261	aio_nop (callback=&PL_sv_undef)
…		…
1230		1266
1231	req->type = REQ_NOP;	1267	req->type = REQ_NOP;
1232		1268
1233	REQ_SEND;	1269	REQ_SEND;
1234	}	1270	}
		1271
		1272	#if 0
		1273
		1274	void
		1275	aio_pri (int pri = DEFAULT_PRI)
		1276	CODE:
		1277	if (pri < PRI_MIN) pri = PRI_MIN;
		1278	if (pri > PRI_MAX) pri = PRI_MAX;
		1279	next_pri = pri + PRI_BIAS;
		1280
		1281	#endif
1235		1282
1236	void	1283	void
1237	flush ()	1284	flush ()
1238	PROTOTYPE:	1285	PROTOTYPE:
1239	CODE:	1286	CODE:
…		…
1293	PROTOTYPE:	1340	PROTOTYPE:
1294	CODE:	1341	CODE:
1295	req_cancel (req);	1342	req_cancel (req);
1296		1343
1297	void	1344	void
1298	cb (aio_req req, SV *callback=&PL_sv_undef)	1345	cb (aio_req_ornot req, SV *callback=&PL_sv_undef)
1299	CODE:	1346	CODE:
1300	SvREFCNT_dec (req->callback);	1347	SvREFCNT_dec (req->callback);
1301	req->callback = newSVsv (callback);	1348	req->callback = newSVsv (callback);
1302		1349
1303	MODULE = IO::AIO PACKAGE = IO::AIO::GRP	1350	MODULE = IO::AIO PACKAGE = IO::AIO::GRP

Diff Legend

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

Comparing IO-AIO/AIO.xs (file contents): Revision 1.58 by root, Mon Oct 23 18:48:08 2006 UTC vs. Revision 1.63 by root, Mon Oct 23 23:48:31 2006 UTC

Diff Legend

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.58 by root, Mon Oct 23 18:48:08 2006 UTC vs.
Revision 1.63 by root, Mon Oct 23 23:48:31 2006 UTC