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

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.156 by root, Thu Nov 12 00:01:52 2009 UTC vs.
Revision 1.159 by root, Thu Jan 7 18:08:21 2010 UTC

…		…
11	#include <stddef.h>	11	#include <stddef.h>
12	#include <stdlib.h>	12	#include <stdlib.h>
13	#include <errno.h>	13	#include <errno.h>
14	#include <sys/types.h>	14	#include <sys/types.h>
15	#include <sys/stat.h>	15	#include <sys/stat.h>
		16	#include <sys/statvfs.h>
16	#include <limits.h>	17	#include <limits.h>
17	#include <fcntl.h>	18	#include <fcntl.h>
18	#include <sched.h>	19	#include <sched.h>
19		20
20	/* perl namespace pollution */	21	/* perl namespace pollution */
…		…
140		141
141	#ifndef POSIX_FADV_DONTNEED	142	#ifndef POSIX_FADV_DONTNEED
142	# define POSIX_FADV_DONTNEED 0	143	# define POSIX_FADV_DONTNEED 0
143	#endif	144	#endif
144		145
		146	#ifndef ST_NODEV
		147	# define ST_NODEV 0
		148	#endif
		149
		150	#ifndef ST_NOEXEC
		151	# define ST_NOEXEC 0
		152	#endif
		153
		154	#ifndef ST_SYNCHRONOUS
		155	# define ST_SYNCHRONOUS 0
		156	#endif
		157
		158	#ifndef ST_MANDLOCK
		159	# define ST_MANDLOCK 0
		160	#endif
		161
		162	#ifndef ST_WRITE
		163	# define ST_WRITE 0
		164	#endif
		165
		166	#ifndef ST_APPEND
		167	# define ST_APPEND 0
		168	#endif
		169
		170	#ifndef ST_IMMUTABLE
		171	# define ST_IMMUTABLE 0
		172	#endif
		173
		174	#ifndef ST_NOATIME
		175	# define ST_NOATIME 0
		176	#endif
		177
		178	#ifndef ST_NODIRATIME
		179	# define ST_NODIRATIME 0
		180	#endif
		181
		182	#ifndef ST_RELATIME
		183	# define ST_RELATIME 0
		184	#endif
		185
145	static int req_invoke (eio_req *req);	186	static int req_invoke (eio_req *req);
146	#define EIO_FINISH(req) req_invoke (req)	187	#define EIO_FINISH(req) req_invoke (req)
147	static void req_destroy (eio_req *grp);	188	static void req_destroy (eio_req *grp);
148	#define EIO_DESTROY(req) req_destroy (req)	189	#define EIO_DESTROY(req) req_destroy (req)
149		190
…		…
343	fh = (SV *)gv;	384	fh = (SV *)gv;
344	}	385	}
345		386
346	PUSHs (fh);	387	PUSHs (fh);
347	}	388	}
		389	break;
		390
		391	case EIO_STATVFS:
		392	case EIO_FSTATVFS:
		393	{
		394	SV *rv = &PL_sv_undef;
		395
		396	if (req->result >= 0)
		397	{
		398	EIO_STRUCT_STATVFS *f = EIO_STATVFS_BUF (req);
		399	HV *hv = newHV ();
		400
		401	rv = sv_2mortal (newRV_noinc (hv));
		402
		403	hv_store (hv, "bsize" , sizeof ("bsize" ) - 1, newSVval64 (f->f_bsize ), 0);
		404	hv_store (hv, "frsize" , sizeof ("frsize" ) - 1, newSVval64 (f->f_frsize ), 0);
		405	hv_store (hv, "blocks" , sizeof ("blocks" ) - 1, newSVval64 (f->f_blocks ), 0);
		406	hv_store (hv, "bfree" , sizeof ("bfree" ) - 1, newSVval64 (f->f_bfree ), 0);
		407	hv_store (hv, "bavail" , sizeof ("bavail" ) - 1, newSVval64 (f->f_bavail ), 0);
		408	hv_store (hv, "files" , sizeof ("files" ) - 1, newSVval64 (f->f_files ), 0);
		409	hv_store (hv, "ffree" , sizeof ("ffree" ) - 1, newSVval64 (f->f_ffree ), 0);
		410	hv_store (hv, "favail" , sizeof ("favail" ) - 1, newSVval64 (f->f_favail ), 0);
		411	hv_store (hv, "fsid" , sizeof ("fsid" ) - 1, newSVval64 (f->f_fsid ), 0);
		412	hv_store (hv, "flag" , sizeof ("flag" ) - 1, newSVval64 (f->f_flag ), 0);
		413	hv_store (hv, "namemax", sizeof ("namemax") - 1, newSVval64 (f->f_namemax), 0);
		414	}
		415
		416	PUSHs (rv);
		417	}
		418
348	break;	419	break;
349		420
350	case EIO_GROUP:	421	case EIO_GROUP:
351	req->int1 = 2; /* mark group as finished */	422	req->int1 = 2; /* mark group as finished */
352		423
…		…
545	const_iv (FADV_RANDOM , POSIX_FADV_RANDOM)	616	const_iv (FADV_RANDOM , POSIX_FADV_RANDOM)
546	const_iv (FADV_NOREUSE , POSIX_FADV_NOREUSE)	617	const_iv (FADV_NOREUSE , POSIX_FADV_NOREUSE)
547	const_iv (FADV_WILLNEED , POSIX_FADV_WILLNEED)	618	const_iv (FADV_WILLNEED , POSIX_FADV_WILLNEED)
548	const_iv (FADV_DONTNEED , POSIX_FADV_DONTNEED)	619	const_iv (FADV_DONTNEED , POSIX_FADV_DONTNEED)
549		620
		621	const_iv (ST_RDONLY , ST_RDONLY)
		622	const_iv (ST_NOSUID , ST_NOSUID)
		623	const_iv (ST_NODEV , ST_NODEV)
		624	const_iv (ST_NOEXEC , ST_NOEXEC)
		625	const_iv (ST_SYNCHRONOUS , ST_SYNCHRONOUS)
		626	const_iv (ST_MANDLOCK , ST_MANDLOCK)
		627	const_iv (ST_WRITE , ST_WRITE)
		628	const_iv (ST_APPEND , ST_APPEND)
		629	const_iv (ST_IMMUTABLE , ST_IMMUTABLE)
		630	const_iv (ST_NOATIME , ST_NOATIME)
		631	const_iv (ST_NODIRATIME , ST_NODIRATIME)
		632	const_iv (ST_RELATIME , ST_RELATIME)
		633
		634	const_eio (MS_ASYNC)
		635	const_eio (MS_INVALIDATE)
		636	const_eio (MS_SYNC)
		637
		638	const_eio (MT_MODIFY)
		639
550	const_eio (SYNC_FILE_RANGE_WAIT_BEFORE)	640	const_eio (SYNC_FILE_RANGE_WAIT_BEFORE)
551	const_eio (SYNC_FILE_RANGE_WRITE)	641	const_eio (SYNC_FILE_RANGE_WRITE)
552	const_eio (SYNC_FILE_RANGE_WAIT_AFTER)	642	const_eio (SYNC_FILE_RANGE_WAIT_AFTER)
553		643
554	const_eio (READDIR_DENTS)	644	const_eio (READDIR_DENTS)
…		…
807	}	897	}
808		898
809	void	899	void
810	aio_stat (SV8 fh_or_path, SV callback=&PL_sv_undef)	900	aio_stat (SV8 fh_or_path, SV callback=&PL_sv_undef)
811	ALIAS:	901	ALIAS:
812	aio_stat = EIO_STAT	902	aio_stat = EIO_STAT
813	aio_lstat = EIO_LSTAT	903	aio_lstat = EIO_LSTAT
		904	aio_statvfs = EIO_STATVFS
814	PPCODE:	905	PPCODE:
815	{	906	{
816	dREQ;	907	dREQ;
817		908
818	req->sv1 = newSVsv (fh_or_path);	909	req->sv1 = newSVsv (fh_or_path);
…		…
822	req->type = ix;	913	req->type = ix;
823	req->ptr1 = SvPVbyte_nolen (req->sv1);	914	req->ptr1 = SvPVbyte_nolen (req->sv1);
824	}	915	}
825	else	916	else
826	{	917	{
827	req->type = EIO_FSTAT;	918	req->type = ix == EIO_STATVFS ? EIO_FSTATVFS : EIO_FSTAT;
828	req->int1 = PerlIO_fileno (IoIFP (sv_2io (fh_or_path)));	919	req->int1 = PerlIO_fileno (IoIFP (sv_2io (fh_or_path)));
829	}	920	}
830		921
831	REQ_SEND;	922	REQ_SEND;
832	}	923	}
…		…
995		1086
996	REQ_SEND;	1087	REQ_SEND;
997	}	1088	}
998		1089
999	void	1090	void
		1091	aio_mtouch (SV8 data, IV offset = 0, SV length = &PL_sv_undef, int flags = 0, SV *callback=&PL_sv_undef)
		1092	ALIAS:
		1093	aio_mtouch = EIO_MTOUCH
		1094	aio_msync = EIO_MSYNC
		1095	PROTOTYPE: $$$$;$
		1096	PPCODE:
		1097	{
		1098	STRLEN svlen;
		1099	UV len = SvUV (length);
		1100	char *svptr = SvPVbyte (data, svlen);
		1101
		1102	if (offset < 0)
		1103	offset += svlen;
		1104
		1105	if (offset < 0 \|\| offset > svlen)
		1106	croak ("offset outside of scalar");
		1107
		1108	if (!SvOK (length) \|\| len + offset > svlen)
		1109	len = svlen - offset;
		1110
		1111	{
		1112	dREQ;
		1113
		1114	req->type = ix;
		1115	req->size = len;
		1116	req->sv2 = SvREFCNT_inc (data);
		1117	req->ptr2 = (char *)svptr + offset;
		1118	req->int1 = flags;
		1119
		1120	REQ_SEND;
		1121	}
		1122	}
		1123
		1124	void
1000	aio_busy (double delay, SV *callback=&PL_sv_undef)	1125	aio_busy (double delay, SV *callback=&PL_sv_undef)
1001	PPCODE:	1126	PPCODE:
1002	{	1127	{
1003	dREQ;	1128	dREQ;
1004		1129
…		…
1144		1269
1145	ssize_t	1270	ssize_t
1146	sendfile (aio_wfd ofh, aio_rfd ifh, off_t offset, size_t count)	1271	sendfile (aio_wfd ofh, aio_rfd ifh, off_t offset, size_t count)
1147	PROTOTYPE: $$$$	1272	PROTOTYPE: $$$$
1148	CODE:	1273	CODE:
1149	eio_sendfile_sync (ofh, ifh, offset, count);	1274	RETVAL = eio_sendfile_sync (ofh, ifh, offset, count);
		1275	OUTPUT:
		1276	RETVAL
1150		1277
1151	void _on_next_submit (SV *cb)	1278	void _on_next_submit (SV *cb)
1152	CODE:	1279	CODE:
1153	SvREFCNT_dec (on_next_submit);	1280	SvREFCNT_dec (on_next_submit);
1154	on_next_submit = SvOK (cb) ? newSVsv (cb) : 0;	1281	on_next_submit = SvOK (cb) ? newSVsv (cb) : 0;

Diff Legend

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

Comparing IO-AIO/AIO.xs (file contents): Revision 1.156 by root, Thu Nov 12 00:01:52 2009 UTC vs. Revision 1.159 by root, Thu Jan 7 18:08:21 2010 UTC

Diff Legend

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.156 by root, Thu Nov 12 00:01:52 2009 UTC vs.
Revision 1.159 by root, Thu Jan 7 18:08:21 2010 UTC