[ViewVC] Diff of: cvs/libeio/eio.c

Comparing libeio/eio.c (file contents):
Revision 1.5 by root, Sun May 11 01:08:05 2008 UTC vs.
Revision 1.6 by root, Sun May 11 19:11:05 2008 UTC

…		…
271	return 0;	271	return 0;
272	}	272	}
273		273
274	void eio_destroy (eio_req *req)	274	void eio_destroy (eio_req *req)
275	{	275	{
		276	if ((req)->flags & EIO_FLAG_PTR1_FREE) free (req->ptr1);
276	if ((req)->flags & EIO_FLAG_PTR2_FREE)	277	if ((req)->flags & EIO_FLAG_PTR2_FREE) free (req->ptr2);
277	free (req->ptr2);
278		278
279	EIO_DESTROY (req);	279	EIO_DESTROY (req);
280	}	280	}
281		281
282	static int eio_finish (eio_req *req)	282	static int eio_finish (eio_req *req)
…		…
312	eio_cancel (grp);	312	eio_cancel (grp);
313	}	313	}
314		314
315	void eio_cancel (eio_req *req)	315	void eio_cancel (eio_req *req)
316	{	316	{
		317	X_LOCK (wrklock);
317	req->flags \|= EIO_FLAG_CANCELLED;	318	req->flags \|= EIO_FLAG_CANCELLED;
		319	X_UNLOCK (wrklock);
318		320
319	eio_grp_cancel (req);	321	eio_grp_cancel (req);
320	}	322	}
321		323
322	X_THREAD_PROC (eio_proc);	324	X_THREAD_PROC (eio_proc);
…		…
765	req->result = res;	767	req->result = res;
766	}	768	}
767		769
768	/*****************************************************************************/	770	/*****************************************************************************/
769		771
		772	#define ALLOC(len) \
		773	X_LOCK (wrklock); \
		774	req->flags \|= EIO_FLAG_PTR2_FREE; \
		775	X_UNLOCK (wrklock); \
		776	req->ptr2 = malloc (len); \
		777	if (!req->ptr2) \
		778	{ \
		779	errno = ENOMEM; \
		780	req->result = -1; \
		781	break; \
		782	}
		783
770	X_THREAD_PROC (eio_proc)	784	X_THREAD_PROC (eio_proc)
771	{	785	{
772	eio_req *req;	786	eio_req *req;
773	struct timespec ts;	787	struct timespec ts;
774	worker self = (worker )thr_arg;	788	worker self = (worker )thr_arg;
…		…
828	: write (req->int1, req->ptr2, req->size); break;	842	: write (req->int1, req->ptr2, req->size); break;
829		843
830	case EIO_READAHEAD: req->result = readahead (req->int1, req->offs, req->size); break;	844	case EIO_READAHEAD: req->result = readahead (req->int1, req->offs, req->size); break;
831	case EIO_SENDFILE: req->result = sendfile_ (req->int1, req->int2, req->offs, req->size, self); break;	845	case EIO_SENDFILE: req->result = sendfile_ (req->int1, req->int2, req->offs, req->size, self); break;
832		846
		847	case EIO_STAT: ALLOC (sizeof (EIO_STRUCT_STAT));
833	case EIO_STAT: req->result = stat (req->ptr1, (EIO_STRUCT_STAT *)req->ptr2); break;	848	req->result = stat (req->ptr1, (EIO_STRUCT_STAT *)req->ptr2); break;
		849	case EIO_LSTAT: ALLOC (sizeof (EIO_STRUCT_STAT));
834	case EIO_LSTAT: req->result = lstat (req->ptr1, (EIO_STRUCT_STAT *)req->ptr2); break;	850	req->result = lstat (req->ptr1, (EIO_STRUCT_STAT *)req->ptr2); break;
		851	case EIO_FSTAT: ALLOC (sizeof (EIO_STRUCT_STAT));
835	case EIO_FSTAT: req->result = fstat (req->int1, (EIO_STRUCT_STAT *)req->ptr2); break;	852	req->result = fstat (req->int1, (EIO_STRUCT_STAT *)req->ptr2); break;
836		853
837	case EIO_CHOWN: req->result = chown (req->ptr1, req->int2, req->int3); break;	854	case EIO_CHOWN: req->result = chown (req->ptr1, req->int2, req->int3); break;
838	case EIO_FCHOWN: req->result = fchown (req->int1, req->int2, req->int3); break;	855	case EIO_FCHOWN: req->result = fchown (req->int1, req->int2, req->int3); break;
839	case EIO_CHMOD: req->result = chmod (req->ptr1, (mode_t)req->int2); break;	856	case EIO_CHMOD: req->result = chmod (req->ptr1, (mode_t)req->int2); break;
840	case EIO_FCHMOD: req->result = fchmod (req->int1, (mode_t)req->int2); break;	857	case EIO_FCHMOD: req->result = fchmod (req->int1, (mode_t)req->int2); break;
…		…
849	case EIO_MKDIR: req->result = mkdir (req->ptr1, (mode_t)req->int2); break;	866	case EIO_MKDIR: req->result = mkdir (req->ptr1, (mode_t)req->int2); break;
850	case EIO_RENAME: req->result = rename (req->ptr1, req->ptr2); break;	867	case EIO_RENAME: req->result = rename (req->ptr1, req->ptr2); break;
851	case EIO_LINK: req->result = link (req->ptr1, req->ptr2); break;	868	case EIO_LINK: req->result = link (req->ptr1, req->ptr2); break;
852	case EIO_SYMLINK: req->result = symlink (req->ptr1, req->ptr2); break;	869	case EIO_SYMLINK: req->result = symlink (req->ptr1, req->ptr2); break;
853	case EIO_MKNOD: req->result = mknod (req->ptr1, (mode_t)req->int2, (dev_t)req->offs); break;	870	case EIO_MKNOD: req->result = mknod (req->ptr1, (mode_t)req->int2, (dev_t)req->offs); break;
		871	case EIO_READLINK: ALLOC (NAME_MAX);
854	case EIO_READLINK: req->result = readlink (req->ptr1, req->ptr2, NAME_MAX); break;	872	req->result = readlink (req->ptr1, req->ptr2, NAME_MAX); break;
855		873
856	case EIO_SYNC: req->result = 0; sync (); break;	874	case EIO_SYNC: req->result = 0; sync (); break;
857	case EIO_FSYNC: req->result = fsync (req->int1); break;	875	case EIO_FSYNC: req->result = fsync (req->int1); break;
858	case EIO_FDATASYNC: req->result = fdatasync (req->int1); break;	876	case EIO_FDATASYNC: req->result = fdatasync (req->int1); break;
859		877
…		…
1008	#endif	1026	#endif
1009		1027
1010	X_THREAD_ATFORK (eio_atfork_prepare, eio_atfork_parent, eio_atfork_child);	1028	X_THREAD_ATFORK (eio_atfork_prepare, eio_atfork_parent, eio_atfork_child);
1011	}	1029	}
1012		1030
		1031	static void eio_api_destroy (eio_req *req)
		1032	{
		1033	free (req);
		1034	}
		1035
		1036	#define REQ(rtype) \
		1037	eio_req *req; \
		1038	\
		1039	req = (eio_req )calloc (1, sizeof req); \
		1040	if (!req) \
		1041	return 0; \
		1042	\
		1043	req->type = EIO_ ## rtype; \
		1044	req->pri = EIO_DEFAULT_PRI + EIO_PRI_BIAS; \
		1045	req->finish = cb; \
		1046	req->destroy = eio_api_destroy;
		1047
		1048	#define SEND eio_submit (req); return req
		1049
		1050	#define PATH (void)0
		1051
		1052	eio_req *eio_fsync (int fd, eio_cb cb)
		1053	{
		1054	REQ (FSYNC); req->int1 = fd; SEND;
		1055	}
		1056
		1057	eio_req *eio_fdatasync (int fd, eio_cb cb)
		1058	{
		1059	REQ (FDATASYNC); req->int1 = fd; SEND;
		1060	}
		1061
		1062	eio_req *eio_readahead (int fd, off_t offset, size_t length, eio_cb cb)
		1063	{
		1064	REQ (READAHEAD); req->int1 = fd; req->offs = offset; req->size = length; SEND;
		1065	}
		1066
		1067	eio_req eio_read (int fd, off_t offset, size_t length, void data, eio_cb cb)
		1068	{
		1069	REQ (READ); req->int1 = fd; req->offs = offset; req->size = length; req->ptr2 = data; SEND;
		1070	}
		1071
		1072	eio_req eio_write (int fd, off_t offset, size_t length, void data, eio_cb cb)
		1073	{
		1074	REQ (WRITE); req->int1 = fd; req->offs = offset; req->size = length; req->ptr2 = data; SEND;
		1075	}
		1076
		1077	eio_req *eio_fstat (int fd, eio_cb cb)
		1078	{
		1079	REQ (FSTAT); req->int1 = fd; SEND;
		1080	}
		1081
		1082	eio_req *eio_futime (int fd, double atime, double mtime, eio_cb cb)
		1083	{
		1084	REQ (FUTIME); req->int1 = fd; req->nv1 = atime; req->nv2 = mtime; SEND;
		1085	}
		1086
		1087	eio_req *eio_ftruncate (int fd, off_t offset, eio_cb cb)
		1088	{
		1089	REQ (FTRUNCATE); req->int1 = fd; req->offs = offset; SEND;
		1090	}
		1091
		1092	eio_req *eio_fchmod (int fd, mode_t mode, eio_cb cb)
		1093	{
		1094	REQ (FCHMOD); req->int1 = fd; req->int2 = (long)mode; SEND;
		1095	}
		1096
		1097	eio_req *eio_fchown (int fd, uid_t uid, gid_t gid, eio_cb cb)
		1098	{
		1099	REQ (FCHOWN); req->int1 = fd; req->int2 = (long)uid; req->int3 = (long)gid; SEND;
		1100	}
		1101
		1102	eio_req *eio_dup2 (int fd, int fd2, eio_cb cb)
		1103	{
		1104	REQ (DUP2); req->int1 = fd; req->int2 = fd2; SEND;
		1105	}
		1106
		1107	eio_req *eio_sendfile (int out_fd, int in_fd, off_t in_offset, size_t length, eio_cb cb)
		1108	{
		1109	REQ (SENDFILE); req->int1 = out_fd; req->int2 = in_fd; req->offs = in_offset; req->size = length; SEND;
		1110	}
		1111
		1112	eio_req eio_open (const char path, int flags, mode_t mode, eio_cb cb)
		1113	{
		1114	REQ (OPEN); PATH; req->int1 = flags; req->int2 = (long)mode; SEND;
		1115	}
		1116
		1117	eio_req eio_readlink (const char path, eio_cb cb)
		1118	{
		1119	REQ (READLINK); PATH; SEND;
		1120	}
		1121
		1122	eio_req eio_stat (const char path, eio_cb cb)
		1123	{
		1124	REQ (STAT); PATH; SEND;
		1125	}
		1126
		1127	eio_req eio_lstat (const char path, eio_cb cb)
		1128	{
		1129	REQ (LSTAT); PATH; SEND;
		1130	}
		1131
		1132	eio_req eio_utime (const char path, double atime, double mtime, eio_cb cb)
		1133	{
		1134	REQ (UTIME); PATH; req->nv1 = atime; req->nv2 = mtime; SEND;
		1135	}
		1136
		1137	eio_req eio_truncate (const char path, off_t offset, eio_cb cb)
		1138	{
		1139	REQ (TRUNCATE); PATH; req->offs = offset; SEND;
		1140	}
		1141
		1142	eio_req eio_chown (const char path, uid_t uid, gid_t gid, eio_cb cb)
		1143	{
		1144	REQ (CHOWN); PATH; req->int2 = (long)uid; req->int3 = (long)gid; SEND;
		1145	}
		1146
		1147	eio_req eio_chmod (const char path, mode_t mode, eio_cb cb)
		1148	{
		1149	REQ (CHMOD); PATH; req->int2 = (long)mode; SEND;
		1150	}
		1151
		1152	eio_req eio_mkdir (const char path, mode_t mode, eio_cb cb)
		1153	{
		1154	REQ (MKDIR); PATH; req->int2 = (long)mode; SEND;
		1155	}
		1156
		1157	eio_req eio_unlink (const char path, eio_cb cb)
		1158	{
		1159	REQ (UNLINK); PATH; SEND;
		1160	}
		1161
		1162	eio_req eio_rmdir (const char path, eio_cb cb)
		1163	{
		1164	REQ (RMDIR); PATH; SEND;
		1165	}
		1166
		1167	eio_req eio_readdir (const char path, eio_cb cb)
		1168	{
		1169	REQ (READDIR); PATH; SEND;
		1170	}
		1171
		1172	eio_req eio_mknod (const char path, mode_t mode, dev_t dev, eio_cb cb)
		1173	{
		1174	REQ (MKNOD); PATH; req->int2 = (long)mode; req->int2 = (long)dev; SEND;
		1175	}
		1176
		1177	eio_req *eio_busy (double delay, eio_cb cb)
		1178	{
		1179	REQ (BUSY); req->nv1 = delay; SEND;
		1180	}
		1181
		1182	eio_req *eio_nop (eio_cb cb)
		1183	{
		1184	REQ (NOP); SEND;
		1185	}
		1186
		1187	#undef REQ
		1188	#undef PATH
		1189	#undef SEND
		1190
1013	#if 0	1191	#if 0
1014		1192
1015	eio_req *eio_fsync (int fd, eio_cb cb);
1016	eio_req *eio_fdatasync (int fd, eio_cb cb);
1017	eio_req *eio_dupclose (int fd, eio_cb cb);
1018	eio_req *eio_readahead (int fd, off_t offset, size_t length, eio_cb cb);
1019	eio_req eio_read (int fd, off_t offs, size_t length, char data, eio_cb cb);
1020	eio_req eio_write (int fd, off_t offs, size_t length, char data, eio_cb cb);
1021	eio_req eio_fstat (int fd, eio_cb cb); / stat buffer=ptr2 allocates dynamically */
1022	eio_req *eio_futime (int fd, double atime, double mtime, eio_cb cb);
1023	eio_req *eio_ftruncate (int fd, off_t offset, eio_cb cb);
1024	eio_req *eio_fchmod (int fd, mode_t mode, eio_cb cb);
1025	eio_req *eio_fchown (int fd, uid_t uid, gid_t gid, eio_cb cb);
1026	eio_req *eio_dup2 (int fd, int fd2, eio_cb cb);
1027	eio_req *eio_sendfile (int out_fd, int in_fd, off_t in_offset, size_t length, eio_cb cb);
1028	eio_req eio_open (const char path, int flags, mode_t mode, eio_cb cb);
1029	eio_req eio_readlink (const char path, eio_cb cb); /* result=ptr2 allocated dynamically */
1030	eio_req eio_stat (const char path, eio_cb cb); /* stat buffer=ptr2 allocates dynamically */
1031	eio_req eio_lstat (const char path, eio_cb cb); /* stat buffer=ptr2 allocates dynamically */
1032	eio_req eio_utime (const char path, double atime, double mtime, eio_cb cb);
1033	eio_req eio_truncate (const char path, off_t offset, eio_cb cb);
1034	eio_req eio_chmod (const char path, mode_t mode, eio_cb cb);
1035	eio_req eio_mkdir (const char path, mode_t mode, eio_cb cb);
1036	eio_req eio_chown (const char path, uid_t uid, gid_t gid, eio_cb cb);
1037	eio_req eio_unlink (const char path, eio_cb cb);
1038	eio_req eio_rmdir (const char path, eio_cb cb);
1039	eio_req eio_readdir (const char path, eio_cb cb); /* result=ptr2 allocated dynamically */
1040	eio_req eio_mknod (const char path, mode_t mode, dev_t dev, eio_cb cb);
1041	eio_req eio_busy (double delay, eio_cb cb); / ties a thread for this long, simulating busyness */
1042	eio_req eio_nop (eio_cb cb); / does nothing except go through the whole process */
1043	void	1193	void
1044	aio_open (SV8 pathname, int flags, int mode, SV callback=&PL_sv_undef)	1194	aio_open (SV8 pathname, int flags, int mode, SV callback=&PL_sv_undef)
1045	PROTOTYPE: $$$;$	1195	PROTOTYPE: $$$;$
1046	PPCODE:	1196	PPCODE:
1047	{	1197	{

Diff Legend

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

Comparing libeio/eio.c (file contents): Revision 1.5 by root, Sun May 11 01:08:05 2008 UTC vs. Revision 1.6 by root, Sun May 11 19:11:05 2008 UTC

Diff Legend

Comparing libeio/eio.c (file contents):
Revision 1.5 by root, Sun May 11 01:08:05 2008 UTC vs.
Revision 1.6 by root, Sun May 11 19:11:05 2008 UTC