1 7763a61a 2003-11-23 devnull #include "stdinc.h"
  2 7763a61a 2003-11-23 devnull #include <auth.h>
  3 7763a61a 2003-11-23 devnull #include <fcall.h>
  4 a20a1468 2005-01-16 devnull #include <thread.h>
  5 7763a61a 2003-11-23 devnull #include "vac.h"
  6 7763a61a 2003-11-23 devnull 
  7 7763a61a 2003-11-23 devnull typedef struct Fid Fid;
  8 7763a61a 2003-11-23 devnull typedef struct DirBuf DirBuf;
  9 7763a61a 2003-11-23 devnull 
 10 7763a61a 2003-11-23 devnull enum
 11 7763a61a 2003-11-23 devnull {
 12 7763a61a 2003-11-23 devnull 	OPERM	= 0x3,		/* mask of all permission types in open mode */
 13 7763a61a 2003-11-23 devnull };
 14 7763a61a 2003-11-23 devnull 
 15 7763a61a 2003-11-23 devnull enum
 16 7763a61a 2003-11-23 devnull {
 17 7763a61a 2003-11-23 devnull 	DirBufSize = 20,
 18 7763a61a 2003-11-23 devnull };
 19 7763a61a 2003-11-23 devnull 
 20 7763a61a 2003-11-23 devnull struct Fid
 21 7763a61a 2003-11-23 devnull {
 22 7763a61a 2003-11-23 devnull 	short busy;
 23 7763a61a 2003-11-23 devnull 	short open;
 24 7763a61a 2003-11-23 devnull 	int fid;
 25 7763a61a 2003-11-23 devnull 	char *user;
 26 7763a61a 2003-11-23 devnull 	Qid qid;
 27 7763a61a 2003-11-23 devnull 	VacFile *file;
 28 7763a61a 2003-11-23 devnull 
 29 7763a61a 2003-11-23 devnull 	DirBuf *db;
 30 7763a61a 2003-11-23 devnull 
 31 7763a61a 2003-11-23 devnull 	Fid	*next;
 32 7763a61a 2003-11-23 devnull };
 33 7763a61a 2003-11-23 devnull 
 34 7763a61a 2003-11-23 devnull struct DirBuf
 35 7763a61a 2003-11-23 devnull {
 36 7763a61a 2003-11-23 devnull 	VacDirEnum *vde;
 37 7763a61a 2003-11-23 devnull 	VacDir buf[DirBufSize];
 38 7763a61a 2003-11-23 devnull 	int i, n;
 39 7763a61a 2003-11-23 devnull 	int eof;
 40 7763a61a 2003-11-23 devnull };
 41 7763a61a 2003-11-23 devnull 
 42 7763a61a 2003-11-23 devnull enum
 43 7763a61a 2003-11-23 devnull {
 44 7763a61a 2003-11-23 devnull 	Pexec =		1,
 45 7763a61a 2003-11-23 devnull 	Pwrite = 	2,
 46 7763a61a 2003-11-23 devnull 	Pread = 	4,
 47 7763a61a 2003-11-23 devnull 	Pother = 	1,
 48 7763a61a 2003-11-23 devnull 	Pgroup = 	8,
 49 7763a61a 2003-11-23 devnull 	Powner =	64,
 50 7763a61a 2003-11-23 devnull };
 51 7763a61a 2003-11-23 devnull 
 52 7763a61a 2003-11-23 devnull Fid	*fids;
 53 7763a61a 2003-11-23 devnull uchar	*data;
 54 7763a61a 2003-11-23 devnull int	mfd[2];
 55 7763a61a 2003-11-23 devnull char	*user;
 56 7763a61a 2003-11-23 devnull uchar	mdata[8192+IOHDRSZ];
 57 7763a61a 2003-11-23 devnull int messagesize = sizeof mdata;
 58 7763a61a 2003-11-23 devnull Fcall	rhdr;
 59 7763a61a 2003-11-23 devnull Fcall	thdr;
 60 a20a1468 2005-01-16 devnull VacFs	*fs;
 61 a20a1468 2005-01-16 devnull VtConn  *conn;
 62 a20a1468 2005-01-16 devnull // VtSession *session;
 63 7763a61a 2003-11-23 devnull int	noperm;
 64 7763a61a 2003-11-23 devnull 
 65 7763a61a 2003-11-23 devnull Fid *	newfid(int);
 66 7763a61a 2003-11-23 devnull void	error(char*);
 67 7763a61a 2003-11-23 devnull void	io(void);
 68 a331ac4c 2005-01-19 devnull void	vacshutdown(void);
 69 7763a61a 2003-11-23 devnull void	usage(void);
 70 7763a61a 2003-11-23 devnull int	perm(Fid*, int);
 71 7763a61a 2003-11-23 devnull int	permf(VacFile*, char*, int);
 72 7763a61a 2003-11-23 devnull ulong	getl(void *p);
 73 7763a61a 2003-11-23 devnull void	init(char*, char*, long, int);
 74 7763a61a 2003-11-23 devnull DirBuf	*dirBufAlloc(VacFile*);
 75 7763a61a 2003-11-23 devnull VacDir	*dirBufGet(DirBuf*);
 76 7763a61a 2003-11-23 devnull int	dirBufUnget(DirBuf*);
 77 7763a61a 2003-11-23 devnull void	dirBufFree(DirBuf*);
 78 7763a61a 2003-11-23 devnull int	vacdirread(Fid *f, char *p, long off, long cnt);
 79 7763a61a 2003-11-23 devnull int	vdStat(VacDir *vd, uchar *p, int np);
 80 a20a1468 2005-01-16 devnull void 	srv(void* a);
 81 7763a61a 2003-11-23 devnull 
 82 a20a1468 2005-01-16 devnull 
 83 7763a61a 2003-11-23 devnull char	*rflush(Fid*), *rversion(Fid*),
 84 7763a61a 2003-11-23 devnull 	*rauth(Fid*), *rattach(Fid*), *rwalk(Fid*),
 85 7763a61a 2003-11-23 devnull 	*ropen(Fid*), *rcreate(Fid*),
 86 7763a61a 2003-11-23 devnull 	*rread(Fid*), *rwrite(Fid*), *rclunk(Fid*),
 87 7763a61a 2003-11-23 devnull 	*rremove(Fid*), *rstat(Fid*), *rwstat(Fid*);
 88 7763a61a 2003-11-23 devnull 
 89 9b3d503b 2005-01-19 devnull char 	*(*fcalls[Tmax])(Fid*);
 90 9b3d503b 2005-01-19 devnull 
 91 9b3d503b 2005-01-19 devnull void
 92 9b3d503b 2005-01-19 devnull initfcalls(void)
 93 9b3d503b 2005-01-19 devnull {
 94 9b3d503b 2005-01-19 devnull 	fcalls[Tflush]=	rflush;
 95 9b3d503b 2005-01-19 devnull 	fcalls[Tversion]=	rversion;
 96 9b3d503b 2005-01-19 devnull 	fcalls[Tattach]=	rattach;
 97 9b3d503b 2005-01-19 devnull 	fcalls[Tauth]=		rauth;
 98 9b3d503b 2005-01-19 devnull 	fcalls[Twalk]=		rwalk;
 99 9b3d503b 2005-01-19 devnull 	fcalls[Topen]=		ropen;
100 9b3d503b 2005-01-19 devnull 	fcalls[Tcreate]=	rcreate;
101 9b3d503b 2005-01-19 devnull 	fcalls[Tread]=		rread;
102 9b3d503b 2005-01-19 devnull 	fcalls[Twrite]=	rwrite;
103 9b3d503b 2005-01-19 devnull 	fcalls[Tclunk]=	rclunk;
104 9b3d503b 2005-01-19 devnull 	fcalls[Tremove]=	rremove;
105 9b3d503b 2005-01-19 devnull 	fcalls[Tstat]=		rstat;
106 9b3d503b 2005-01-19 devnull 	fcalls[Twstat]=	rwstat;
107 7763a61a 2003-11-23 devnull };
108 7763a61a 2003-11-23 devnull 
109 7763a61a 2003-11-23 devnull char	Eperm[] =	"permission denied";
110 7763a61a 2003-11-23 devnull char	Enotdir[] =	"not a directory";
111 7763a61a 2003-11-23 devnull char	Enotexist[] =	"file does not exist";
112 7763a61a 2003-11-23 devnull char	Einuse[] =	"file in use";
113 7763a61a 2003-11-23 devnull char	Eexist[] =	"file exists";
114 7763a61a 2003-11-23 devnull char	Enotowner[] =	"not owner";
115 7763a61a 2003-11-23 devnull char	Eisopen[] = 	"file already open for I/O";
116 7763a61a 2003-11-23 devnull char	Excl[] = 	"exclusive use file already open";
117 7763a61a 2003-11-23 devnull char	Ename[] = 	"illegal name";
118 7763a61a 2003-11-23 devnull char	Erdonly[] = 	"read only file system";
119 7763a61a 2003-11-23 devnull char	Eio[] = 	"i/o error";
120 7763a61a 2003-11-23 devnull char	Eempty[] = 	"directory is not empty";
121 7763a61a 2003-11-23 devnull char	Emode[] =	"illegal mode";
122 7763a61a 2003-11-23 devnull 
123 7763a61a 2003-11-23 devnull int dflag;
124 7763a61a 2003-11-23 devnull 
125 7763a61a 2003-11-23 devnull void
126 7763a61a 2003-11-23 devnull notifyf(void *a, char *s)
127 7763a61a 2003-11-23 devnull {
128 7763a61a 2003-11-23 devnull 	USED(a);
129 7763a61a 2003-11-23 devnull 	if(strncmp(s, "interrupt", 9) == 0)
130 7763a61a 2003-11-23 devnull 		noted(NCONT);
131 7763a61a 2003-11-23 devnull 	noted(NDFLT);
132 7763a61a 2003-11-23 devnull }
133 7763a61a 2003-11-23 devnull 
134 7763a61a 2003-11-23 devnull void
135 a20a1468 2005-01-16 devnull threadmain(int argc, char *argv[])
136 7763a61a 2003-11-23 devnull {
137 91124c1b 2005-01-16 devnull 	char *defsrv, *q;
138 91124c1b 2005-01-16 devnull 	int p[2], l;
139 7763a61a 2003-11-23 devnull 	int stdio = 0;
140 7763a61a 2003-11-23 devnull 	char *host = nil;
141 7763a61a 2003-11-23 devnull 	long ncache = 1000;
142 7763a61a 2003-11-23 devnull 	int readOnly = 1;
143 7763a61a 2003-11-23 devnull 
144 91124c1b 2005-01-16 devnull 	defsrv = nil;
145 7763a61a 2003-11-23 devnull 	ARGBEGIN{
146 7763a61a 2003-11-23 devnull 	case 'd':
147 7763a61a 2003-11-23 devnull 		fmtinstall('F', fcallfmt);
148 7763a61a 2003-11-23 devnull 		dflag = 1;
149 7763a61a 2003-11-23 devnull 		break;
150 7763a61a 2003-11-23 devnull 	case 'c':
151 32053cdf 2005-01-16 devnull 		ncache = atoi(EARGF(usage()));
152 7763a61a 2003-11-23 devnull 		break;
153 7763a61a 2003-11-23 devnull 	case 'i':
154 7763a61a 2003-11-23 devnull 		stdio = 1;
155 7763a61a 2003-11-23 devnull 		mfd[0] = 0;
156 7763a61a 2003-11-23 devnull 		mfd[1] = 1;
157 7763a61a 2003-11-23 devnull 		break;
158 7763a61a 2003-11-23 devnull 	case 'h':
159 32053cdf 2005-01-16 devnull 		host = EARGF(usage());
160 7763a61a 2003-11-23 devnull 		break;
161 7763a61a 2003-11-23 devnull 	case 's':
162 32053cdf 2005-01-16 devnull 		defsrv = EARGF(usage());
163 7763a61a 2003-11-23 devnull 		break;
164 7763a61a 2003-11-23 devnull 	case 'p':
165 7763a61a 2003-11-23 devnull 		noperm = 1;
166 7763a61a 2003-11-23 devnull 		break;
167 7763a61a 2003-11-23 devnull 	default:
168 7763a61a 2003-11-23 devnull 		usage();
169 7763a61a 2003-11-23 devnull 	}ARGEND
170 7763a61a 2003-11-23 devnull 
171 7763a61a 2003-11-23 devnull 	if(argc != 1)
172 7763a61a 2003-11-23 devnull 		usage();
173 7763a61a 2003-11-23 devnull 
174 9b3d503b 2005-01-19 devnull 	initfcalls();
175 7763a61a 2003-11-23 devnull 	init(argv[0], host, ncache, readOnly);
176 7763a61a 2003-11-23 devnull 
177 7763a61a 2003-11-23 devnull 	if(pipe(p) < 0)
178 7763a61a 2003-11-23 devnull 		sysfatal("pipe failed: %r");
179 7763a61a 2003-11-23 devnull 
180 a20a1468 2005-01-16 devnull 	mfd[0] = p[0];
181 a20a1468 2005-01-16 devnull 	mfd[1] = p[0];
182 a20a1468 2005-01-16 devnull 	proccreate(srv, 0, 32 * 1024);
183 a20a1468 2005-01-16 devnull 
184 91124c1b 2005-01-16 devnull 	if(defsrv == nil){
185 91124c1b 2005-01-16 devnull 		q = strrchr(argv[0], '/');
186 91124c1b 2005-01-16 devnull 		if(q)
187 91124c1b 2005-01-16 devnull 			q++;
188 91124c1b 2005-01-16 devnull 		else
189 91124c1b 2005-01-16 devnull 			q = argv[0];
190 91124c1b 2005-01-16 devnull 		defsrv = vtmalloc(6+strlen(q)+1);
191 91124c1b 2005-01-16 devnull 		strcpy(defsrv, "vacfs.");
192 91124c1b 2005-01-16 devnull 		strcat(defsrv, q);
193 91124c1b 2005-01-16 devnull 		l = strlen(defsrv);
194 91124c1b 2005-01-16 devnull 		if(strcmp(defsrv+l-4, ".vac") == 0)
195 91124c1b 2005-01-16 devnull 			defsrv[l-4] = 0;
196 91124c1b 2005-01-16 devnull 	}
197 91124c1b 2005-01-16 devnull 
198 91124c1b 2005-01-16 devnull 	if(post9pservice(p[1], defsrv) != 0) 
199 a20a1468 2005-01-16 devnull 		sysfatal("post9pservice");
200 a20a1468 2005-01-16 devnull 
201 a20a1468 2005-01-16 devnull 
202 a20a1468 2005-01-16 devnull 	threadexits(0);
203 7763a61a 2003-11-23 devnull }
204 7763a61a 2003-11-23 devnull 
205 a331ac4c 2005-01-19 devnull void
206 a331ac4c 2005-01-19 devnull srv(void *a)
207 a331ac4c 2005-01-19 devnull {
208 a20a1468 2005-01-16 devnull 	io();
209 a331ac4c 2005-01-19 devnull 	vacshutdown();
210 a20a1468 2005-01-16 devnull }
211 a20a1468 2005-01-16 devnull 
212 7763a61a 2003-11-23 devnull void
213 7763a61a 2003-11-23 devnull usage(void)
214 7763a61a 2003-11-23 devnull {
215 7763a61a 2003-11-23 devnull 	fprint(2, "usage: %s [-sd] [-h host] [-c ncache] [-m mountpoint] vacfile\n", argv0);
216 38c10d1a 2005-01-17 devnull 	threadexitsall("usage");
217 7763a61a 2003-11-23 devnull }
218 7763a61a 2003-11-23 devnull 
219 7763a61a 2003-11-23 devnull char*
220 7763a61a 2003-11-23 devnull rversion(Fid *unused)
221 7763a61a 2003-11-23 devnull {
222 7763a61a 2003-11-23 devnull 	Fid *f;
223 7763a61a 2003-11-23 devnull 
224 7763a61a 2003-11-23 devnull 	USED(unused);
225 7763a61a 2003-11-23 devnull 
226 7763a61a 2003-11-23 devnull 	for(f = fids; f; f = f->next)
227 7763a61a 2003-11-23 devnull 		if(f->busy)
228 7763a61a 2003-11-23 devnull 			rclunk(f);
229 7763a61a 2003-11-23 devnull 
230 7763a61a 2003-11-23 devnull 	if(rhdr.msize < 256)
231 a20a1468 2005-01-16 devnull 		return vtstrdup("version: message size too small");
232 7763a61a 2003-11-23 devnull 	messagesize = rhdr.msize;
233 7763a61a 2003-11-23 devnull 	if(messagesize > sizeof mdata)
234 7763a61a 2003-11-23 devnull 		messagesize = sizeof mdata;
235 7763a61a 2003-11-23 devnull 	thdr.msize = messagesize;
236 7763a61a 2003-11-23 devnull 	if(strncmp(rhdr.version, "9P2000", 6) != 0)
237 a20a1468 2005-01-16 devnull 		return vtstrdup("unrecognized 9P version");
238 7763a61a 2003-11-23 devnull 	thdr.version = "9P2000";
239 7763a61a 2003-11-23 devnull 	return nil;
240 7763a61a 2003-11-23 devnull }
241 7763a61a 2003-11-23 devnull 
242 7763a61a 2003-11-23 devnull char*
243 7763a61a 2003-11-23 devnull rflush(Fid *f)
244 7763a61a 2003-11-23 devnull {
245 7763a61a 2003-11-23 devnull 	USED(f);
246 7763a61a 2003-11-23 devnull 	return 0;
247 7763a61a 2003-11-23 devnull }
248 7763a61a 2003-11-23 devnull 
249 7763a61a 2003-11-23 devnull char*
250 7763a61a 2003-11-23 devnull rauth(Fid *f)
251 7763a61a 2003-11-23 devnull {
252 7763a61a 2003-11-23 devnull 	USED(f);
253 a20a1468 2005-01-16 devnull 	return vtstrdup("vacfs: authentication not required");
254 7763a61a 2003-11-23 devnull }
255 7763a61a 2003-11-23 devnull 
256 7763a61a 2003-11-23 devnull char*
257 7763a61a 2003-11-23 devnull rattach(Fid *f)
258 7763a61a 2003-11-23 devnull {
259 7763a61a 2003-11-23 devnull 	/* no authentication for the momment */
260 7763a61a 2003-11-23 devnull 	VacFile *file;
261 a20a1468 2005-01-16 devnull 	char err[80];
262 7763a61a 2003-11-23 devnull 
263 a20a1468 2005-01-16 devnull 	file = vacfsgetroot(fs);
264 a20a1468 2005-01-16 devnull 	if(file == nil) {
265 a20a1468 2005-01-16 devnull 		rerrstr(err, sizeof err);
266 a20a1468 2005-01-16 devnull 		return vtstrdup(err);
267 a20a1468 2005-01-16 devnull 	}
268 a20a1468 2005-01-16 devnull 
269 7763a61a 2003-11-23 devnull 	f->busy = 1;
270 7763a61a 2003-11-23 devnull 	f->file = file;
271 9b3d503b 2005-01-19 devnull 	f->qid.path = vacfilegetid(f->file);
272 9b3d503b 2005-01-19 devnull 	f->qid.vers = 0;
273 9b3d503b 2005-01-19 devnull 	f->qid.type = QTDIR;
274 7763a61a 2003-11-23 devnull 	thdr.qid = f->qid;
275 7763a61a 2003-11-23 devnull 	if(rhdr.uname[0])
276 a20a1468 2005-01-16 devnull 		f->user = vtstrdup(rhdr.uname);
277 7763a61a 2003-11-23 devnull 	else
278 7763a61a 2003-11-23 devnull 		f->user = "none";
279 7763a61a 2003-11-23 devnull 	return 0;
280 7763a61a 2003-11-23 devnull }
281 7763a61a 2003-11-23 devnull 
282 7763a61a 2003-11-23 devnull VacFile*
283 7763a61a 2003-11-23 devnull _vfWalk(VacFile *file, char *name)
284 7763a61a 2003-11-23 devnull {
285 7763a61a 2003-11-23 devnull 	VacFile *n;
286 7763a61a 2003-11-23 devnull 
287 a20a1468 2005-01-16 devnull 	n = vacfilewalk(file, name);
288 7763a61a 2003-11-23 devnull 	if(n)
289 7763a61a 2003-11-23 devnull 		return n;
290 7763a61a 2003-11-23 devnull 	if(strcmp(name, "SLASH") == 0)
291 a20a1468 2005-01-16 devnull 		return vacfilewalk(file, "/");
292 7763a61a 2003-11-23 devnull 	return nil;
293 7763a61a 2003-11-23 devnull }
294 7763a61a 2003-11-23 devnull 
295 7763a61a 2003-11-23 devnull char*
296 7763a61a 2003-11-23 devnull rwalk(Fid *f)
297 7763a61a 2003-11-23 devnull {
298 7763a61a 2003-11-23 devnull 	VacFile *file, *nfile;
299 7763a61a 2003-11-23 devnull 	Fid *nf;
300 7763a61a 2003-11-23 devnull 	int nqid, nwname;
301 7763a61a 2003-11-23 devnull 	Qid qid;
302 a20a1468 2005-01-16 devnull 	char *err = nil;
303 7763a61a 2003-11-23 devnull 
304 7763a61a 2003-11-23 devnull 	if(f->busy == 0)
305 7763a61a 2003-11-23 devnull 		return Enotexist;
306 7763a61a 2003-11-23 devnull 	nf = nil;
307 7763a61a 2003-11-23 devnull 	if(rhdr.fid != rhdr.newfid){
308 7763a61a 2003-11-23 devnull 		if(f->open)
309 a20a1468 2005-01-16 devnull 			return vtstrdup(Eisopen);
310 7763a61a 2003-11-23 devnull 		if(f->busy == 0)
311 a20a1468 2005-01-16 devnull 			return vtstrdup(Enotexist);
312 7763a61a 2003-11-23 devnull 		nf = newfid(rhdr.newfid);
313 7763a61a 2003-11-23 devnull 		if(nf->busy)
314 a20a1468 2005-01-16 devnull 			return vtstrdup(Eisopen);
315 7763a61a 2003-11-23 devnull 		nf->busy = 1;
316 7763a61a 2003-11-23 devnull 		nf->open = 0;
317 7763a61a 2003-11-23 devnull 		nf->qid = f->qid;
318 a20a1468 2005-01-16 devnull 		nf->file = vacfileincref(f->file);
319 a20a1468 2005-01-16 devnull 		nf->user = vtstrdup(f->user);
320 7763a61a 2003-11-23 devnull 		f = nf;
321 7763a61a 2003-11-23 devnull 	}
322 7763a61a 2003-11-23 devnull 
323 7763a61a 2003-11-23 devnull 	nwname = rhdr.nwname;
324 7763a61a 2003-11-23 devnull 
325 7763a61a 2003-11-23 devnull 	/* easy case */
326 7763a61a 2003-11-23 devnull 	if(nwname == 0) {
327 7763a61a 2003-11-23 devnull 		thdr.nwqid = 0;
328 7763a61a 2003-11-23 devnull 		return 0;
329 7763a61a 2003-11-23 devnull 	}
330 7763a61a 2003-11-23 devnull 
331 7763a61a 2003-11-23 devnull 	file = f->file;
332 a20a1468 2005-01-16 devnull 	vacfileincref(file);
333 7763a61a 2003-11-23 devnull 	qid = f->qid;
334 7763a61a 2003-11-23 devnull 
335 7763a61a 2003-11-23 devnull 	for(nqid = 0; nqid < nwname; nqid++){
336 7763a61a 2003-11-23 devnull 		if((qid.type & QTDIR) == 0){
337 a20a1468 2005-01-16 devnull 			err = Enotdir;
338 7763a61a 2003-11-23 devnull 			break;
339 7763a61a 2003-11-23 devnull 		}
340 7763a61a 2003-11-23 devnull 		if(!permf(file, f->user, Pexec)) {
341 a20a1468 2005-01-16 devnull 			err = Eperm;
342 7763a61a 2003-11-23 devnull 			break;
343 7763a61a 2003-11-23 devnull 		}
344 7763a61a 2003-11-23 devnull 		nfile = _vfWalk(file, rhdr.wname[nqid]);
345 7763a61a 2003-11-23 devnull 		if(nfile == nil)
346 7763a61a 2003-11-23 devnull 			break;
347 a20a1468 2005-01-16 devnull 		vacfiledecref(file);
348 7763a61a 2003-11-23 devnull 		file = nfile;
349 7763a61a 2003-11-23 devnull 		qid.type = QTFILE;
350 a20a1468 2005-01-16 devnull 		if(vacfileisdir(file))
351 7763a61a 2003-11-23 devnull 			qid.type = QTDIR;
352 a20a1468 2005-01-16 devnull 		qid.vers = vacfilegetmcount(file);
353 a20a1468 2005-01-16 devnull 		qid.path = vacfilegetid(file);
354 7763a61a 2003-11-23 devnull 		thdr.wqid[nqid] = qid;
355 7763a61a 2003-11-23 devnull 	}
356 7763a61a 2003-11-23 devnull 
357 7763a61a 2003-11-23 devnull 	thdr.nwqid = nqid;
358 7763a61a 2003-11-23 devnull 
359 7763a61a 2003-11-23 devnull 	if(nqid == nwname){
360 7763a61a 2003-11-23 devnull 		/* success */
361 7763a61a 2003-11-23 devnull 		f->qid = thdr.wqid[nqid-1];
362 a20a1468 2005-01-16 devnull 		vacfiledecref(f->file);
363 7763a61a 2003-11-23 devnull 		f->file = file;
364 7763a61a 2003-11-23 devnull 		return 0;
365 7763a61a 2003-11-23 devnull 	}
366 7763a61a 2003-11-23 devnull 
367 a20a1468 2005-01-16 devnull 	vacfiledecref(file);
368 7763a61a 2003-11-23 devnull 	if(nf != nil)
369 7763a61a 2003-11-23 devnull 		rclunk(nf);
370 7763a61a 2003-11-23 devnull 
371 7763a61a 2003-11-23 devnull 	/* only error on the first element */
372 7763a61a 2003-11-23 devnull 	if(nqid == 0)
373 a20a1468 2005-01-16 devnull 		return vtstrdup(err);
374 7763a61a 2003-11-23 devnull 
375 7763a61a 2003-11-23 devnull 	return 0;
376 7763a61a 2003-11-23 devnull }
377 7763a61a 2003-11-23 devnull 
378 7763a61a 2003-11-23 devnull char *
379 7763a61a 2003-11-23 devnull ropen(Fid *f)
380 7763a61a 2003-11-23 devnull {
381 7763a61a 2003-11-23 devnull 	int mode, trunc;
382 7763a61a 2003-11-23 devnull 
383 7763a61a 2003-11-23 devnull 	if(f->open)
384 a20a1468 2005-01-16 devnull 		return vtstrdup(Eisopen);
385 7763a61a 2003-11-23 devnull 	if(!f->busy)
386 a20a1468 2005-01-16 devnull 		return vtstrdup(Enotexist);
387 a20a1468 2005-01-16 devnull 
388 7763a61a 2003-11-23 devnull 	mode = rhdr.mode;
389 7763a61a 2003-11-23 devnull 	thdr.iounit = messagesize - IOHDRSZ;
390 7763a61a 2003-11-23 devnull 	if(f->qid.type & QTDIR){
391 7763a61a 2003-11-23 devnull 		if(mode != OREAD)
392 a20a1468 2005-01-16 devnull 			return vtstrdup(Eperm);
393 7763a61a 2003-11-23 devnull 		if(!perm(f, Pread))
394 a20a1468 2005-01-16 devnull 			return vtstrdup(Eperm);
395 7763a61a 2003-11-23 devnull 		thdr.qid = f->qid;
396 7763a61a 2003-11-23 devnull 		f->db = nil;
397 7763a61a 2003-11-23 devnull 		f->open = 1;
398 7763a61a 2003-11-23 devnull 		return 0;
399 7763a61a 2003-11-23 devnull 	}
400 7763a61a 2003-11-23 devnull 	if(mode & ORCLOSE)
401 a20a1468 2005-01-16 devnull 		return vtstrdup(Erdonly);
402 7763a61a 2003-11-23 devnull 	trunc = mode & OTRUNC;
403 7763a61a 2003-11-23 devnull 	mode &= OPERM;
404 7763a61a 2003-11-23 devnull 	if(mode==OWRITE || mode==ORDWR || trunc)
405 7763a61a 2003-11-23 devnull 		if(!perm(f, Pwrite))
406 a20a1468 2005-01-16 devnull 			return vtstrdup(Eperm);
407 7763a61a 2003-11-23 devnull 	if(mode==OREAD || mode==ORDWR)
408 7763a61a 2003-11-23 devnull 		if(!perm(f, Pread))
409 a20a1468 2005-01-16 devnull 			return vtstrdup(Eperm);
410 7763a61a 2003-11-23 devnull 	if(mode==OEXEC)
411 7763a61a 2003-11-23 devnull 		if(!perm(f, Pexec))
412 a20a1468 2005-01-16 devnull 			return vtstrdup(Eperm);
413 7763a61a 2003-11-23 devnull 	thdr.qid = f->qid;
414 7763a61a 2003-11-23 devnull 	thdr.iounit = messagesize - IOHDRSZ;
415 7763a61a 2003-11-23 devnull 	f->open = 1;
416 7763a61a 2003-11-23 devnull 	return 0;
417 7763a61a 2003-11-23 devnull }
418 7763a61a 2003-11-23 devnull 
419 7763a61a 2003-11-23 devnull char*
420 7763a61a 2003-11-23 devnull rcreate(Fid* fid)
421 7763a61a 2003-11-23 devnull {
422 7763a61a 2003-11-23 devnull 	VacFile *vf;
423 7763a61a 2003-11-23 devnull 	ulong mode;
424 7763a61a 2003-11-23 devnull 
425 7763a61a 2003-11-23 devnull 	if(fid->open)
426 a20a1468 2005-01-16 devnull 		return vtstrdup(Eisopen);
427 7763a61a 2003-11-23 devnull 	if(!fid->busy)
428 a20a1468 2005-01-16 devnull 		return vtstrdup(Enotexist);
429 a20a1468 2005-01-16 devnull 	if(fs->mode & ModeSnapshot)
430 a20a1468 2005-01-16 devnull 		return vtstrdup(Erdonly);
431 7763a61a 2003-11-23 devnull 	vf = fid->file;
432 a20a1468 2005-01-16 devnull 	if(!vacfileisdir(vf))
433 a20a1468 2005-01-16 devnull 		return vtstrdup(Enotdir);
434 7763a61a 2003-11-23 devnull 	if(!permf(vf, fid->user, Pwrite))
435 a20a1468 2005-01-16 devnull 		return vtstrdup(Eperm);
436 7763a61a 2003-11-23 devnull 
437 7763a61a 2003-11-23 devnull 	mode = rhdr.perm & 0777;
438 7763a61a 2003-11-23 devnull 
439 7763a61a 2003-11-23 devnull 	if(rhdr.perm & DMDIR){
440 7763a61a 2003-11-23 devnull 		if((rhdr.mode & OTRUNC) || (rhdr.perm & DMAPPEND))
441 a20a1468 2005-01-16 devnull 			return vtstrdup(Emode);
442 7763a61a 2003-11-23 devnull 		switch(rhdr.mode & OPERM){
443 7763a61a 2003-11-23 devnull 		default:
444 a20a1468 2005-01-16 devnull 			return vtstrdup(Emode);
445 7763a61a 2003-11-23 devnull 		case OEXEC:
446 7763a61a 2003-11-23 devnull 		case OREAD:
447 7763a61a 2003-11-23 devnull 			break;
448 7763a61a 2003-11-23 devnull 		case OWRITE:
449 7763a61a 2003-11-23 devnull 		case ORDWR:
450 a20a1468 2005-01-16 devnull 			return vtstrdup(Eperm);
451 7763a61a 2003-11-23 devnull 		}
452 7763a61a 2003-11-23 devnull 		mode |= ModeDir;
453 7763a61a 2003-11-23 devnull 	}
454 a20a1468 2005-01-16 devnull 	vf = vacfilecreate(vf, rhdr.name, mode, "none");
455 a20a1468 2005-01-16 devnull 	if(vf == nil) {
456 a20a1468 2005-01-16 devnull 		char err[80];
457 a20a1468 2005-01-16 devnull 		rerrstr(err, sizeof err);
458 7763a61a 2003-11-23 devnull 
459 a20a1468 2005-01-16 devnull 		return vtstrdup(err);
460 a20a1468 2005-01-16 devnull 	}
461 a20a1468 2005-01-16 devnull 
462 a20a1468 2005-01-16 devnull 	vacfiledecref(fid->file);
463 a20a1468 2005-01-16 devnull 
464 7763a61a 2003-11-23 devnull 	fid->file = vf;
465 7763a61a 2003-11-23 devnull 	fid->qid.type = QTFILE;
466 a20a1468 2005-01-16 devnull 	if(vacfileisdir(vf))
467 7763a61a 2003-11-23 devnull 		fid->qid.type = QTDIR;
468 a20a1468 2005-01-16 devnull 	fid->qid.vers = vacfilegetmcount(vf);
469 a20a1468 2005-01-16 devnull 	fid->qid.path = vacfilegetid(vf);
470 7763a61a 2003-11-23 devnull 
471 7763a61a 2003-11-23 devnull 	thdr.qid = fid->qid;
472 7763a61a 2003-11-23 devnull 	thdr.iounit = messagesize - IOHDRSZ;
473 7763a61a 2003-11-23 devnull 
474 7763a61a 2003-11-23 devnull 	return 0;
475 7763a61a 2003-11-23 devnull }
476 7763a61a 2003-11-23 devnull 
477 7763a61a 2003-11-23 devnull char*
478 7763a61a 2003-11-23 devnull rread(Fid *f)
479 7763a61a 2003-11-23 devnull {
480 7763a61a 2003-11-23 devnull 	char *buf;
481 7763a61a 2003-11-23 devnull 	vlong off;
482 7763a61a 2003-11-23 devnull 	int cnt;
483 7763a61a 2003-11-23 devnull 	VacFile *vf;
484 a20a1468 2005-01-16 devnull 	char err[80];
485 7763a61a 2003-11-23 devnull 	int n;
486 7763a61a 2003-11-23 devnull 
487 7763a61a 2003-11-23 devnull 	if(!f->busy)
488 a20a1468 2005-01-16 devnull 		return vtstrdup(Enotexist);
489 7763a61a 2003-11-23 devnull 	vf = f->file;
490 7763a61a 2003-11-23 devnull 	thdr.count = 0;
491 7763a61a 2003-11-23 devnull 	off = rhdr.offset;
492 7763a61a 2003-11-23 devnull 	buf = thdr.data;
493 7763a61a 2003-11-23 devnull 	cnt = rhdr.count;
494 7763a61a 2003-11-23 devnull 	if(f->qid.type & QTDIR)
495 7763a61a 2003-11-23 devnull 		n = vacdirread(f, buf, off, cnt);
496 7763a61a 2003-11-23 devnull 	else
497 a20a1468 2005-01-16 devnull 		n = vacfileread(vf, buf, cnt, off);
498 7763a61a 2003-11-23 devnull 	if(n < 0) {
499 a20a1468 2005-01-16 devnull 		rerrstr(err, sizeof err);
500 a20a1468 2005-01-16 devnull 		return vtstrdup(err);
501 7763a61a 2003-11-23 devnull 	}
502 7763a61a 2003-11-23 devnull 	thdr.count = n;
503 7763a61a 2003-11-23 devnull 	return 0;
504 7763a61a 2003-11-23 devnull }
505 7763a61a 2003-11-23 devnull 
506 7763a61a 2003-11-23 devnull char*
507 7763a61a 2003-11-23 devnull rwrite(Fid *f)
508 7763a61a 2003-11-23 devnull {
509 7763a61a 2003-11-23 devnull 	char *buf;
510 7763a61a 2003-11-23 devnull 	vlong off;
511 7763a61a 2003-11-23 devnull 	int cnt;
512 7763a61a 2003-11-23 devnull 	VacFile *vf;
513 7763a61a 2003-11-23 devnull 
514 7763a61a 2003-11-23 devnull 	if(!f->busy)
515 a20a1468 2005-01-16 devnull 		return vtstrdup(Enotexist);
516 7763a61a 2003-11-23 devnull 	vf = f->file;
517 7763a61a 2003-11-23 devnull 	thdr.count = 0;
518 7763a61a 2003-11-23 devnull 	off = rhdr.offset;
519 7763a61a 2003-11-23 devnull 	buf = rhdr.data;
520 7763a61a 2003-11-23 devnull 	cnt = rhdr.count;
521 7763a61a 2003-11-23 devnull 	if(f->qid.type & QTDIR)
522 7763a61a 2003-11-23 devnull 		return "file is a directory";
523 a20a1468 2005-01-16 devnull 	thdr.count = vacfilewrite(vf, buf, cnt, off, "none");
524 7763a61a 2003-11-23 devnull 	if(thdr.count < 0) {
525 a20a1468 2005-01-16 devnull 		char err[80];
526 a20a1468 2005-01-16 devnull 
527 a20a1468 2005-01-16 devnull 		rerrstr(err, sizeof err);
528 a20a1468 2005-01-16 devnull fprint(2, "write failed: %s\n", err);
529 a20a1468 2005-01-16 devnull 		return vtstrdup(err);
530 7763a61a 2003-11-23 devnull 	}
531 7763a61a 2003-11-23 devnull 	return 0;
532 7763a61a 2003-11-23 devnull }
533 7763a61a 2003-11-23 devnull 
534 7763a61a 2003-11-23 devnull char *
535 7763a61a 2003-11-23 devnull rclunk(Fid *f)
536 7763a61a 2003-11-23 devnull {
537 7763a61a 2003-11-23 devnull 	f->busy = 0;
538 7763a61a 2003-11-23 devnull 	f->open = 0;
539 a20a1468 2005-01-16 devnull 	vtfree(f->user);
540 7763a61a 2003-11-23 devnull 	f->user = nil;
541 a20a1468 2005-01-16 devnull 	vacfiledecref(f->file);
542 7763a61a 2003-11-23 devnull 	f->file = nil;
543 7763a61a 2003-11-23 devnull 	dirBufFree(f->db);
544 7763a61a 2003-11-23 devnull 	f->db = nil;
545 7763a61a 2003-11-23 devnull 	return 0;
546 7763a61a 2003-11-23 devnull }
547 7763a61a 2003-11-23 devnull 
548 7763a61a 2003-11-23 devnull char *
549 7763a61a 2003-11-23 devnull rremove(Fid *f)
550 7763a61a 2003-11-23 devnull {
551 7763a61a 2003-11-23 devnull 	VacFile *vf, *vfp;
552 a20a1468 2005-01-16 devnull 	char errbuf[80];
553 7763a61a 2003-11-23 devnull 	char *err = nil;
554 7763a61a 2003-11-23 devnull 
555 7763a61a 2003-11-23 devnull 	if(!f->busy)
556 a20a1468 2005-01-16 devnull 		return vtstrdup(Enotexist);
557 7763a61a 2003-11-23 devnull 	vf = f->file;
558 a20a1468 2005-01-16 devnull 	vfp = vacfilegetparent(vf);
559 7763a61a 2003-11-23 devnull 
560 7763a61a 2003-11-23 devnull 	if(!permf(vfp, f->user, Pwrite)) {
561 7763a61a 2003-11-23 devnull 		err = Eperm;
562 7763a61a 2003-11-23 devnull 		goto Exit;
563 7763a61a 2003-11-23 devnull 	}
564 7763a61a 2003-11-23 devnull 
565 a20a1468 2005-01-16 devnull 	if(!vacfileremove(vf, "none")) {
566 a20a1468 2005-01-16 devnull 		rerrstr(errbuf, sizeof errbuf);
567 a20a1468 2005-01-16 devnull print("vfRemove failed: %s\n", errbuf);
568 a20a1468 2005-01-16 devnull 
569 a20a1468 2005-01-16 devnull 		err = errbuf;
570 7763a61a 2003-11-23 devnull 	}
571 7763a61a 2003-11-23 devnull 
572 7763a61a 2003-11-23 devnull Exit:
573 a20a1468 2005-01-16 devnull 	vacfiledecref(vfp);
574 7763a61a 2003-11-23 devnull 	rclunk(f);
575 a20a1468 2005-01-16 devnull 	return vtstrdup(err);
576 7763a61a 2003-11-23 devnull }
577 7763a61a 2003-11-23 devnull 
578 7763a61a 2003-11-23 devnull char *
579 7763a61a 2003-11-23 devnull rstat(Fid *f)
580 7763a61a 2003-11-23 devnull {
581 7763a61a 2003-11-23 devnull 	VacDir dir;
582 7763a61a 2003-11-23 devnull 	static uchar statbuf[1024];
583 7763a61a 2003-11-23 devnull 
584 7763a61a 2003-11-23 devnull 	if(!f->busy)
585 a20a1468 2005-01-16 devnull 		return vtstrdup(Enotexist);
586 a20a1468 2005-01-16 devnull 	vacfilegetdir(f->file, &dir);
587 7763a61a 2003-11-23 devnull 	thdr.stat = statbuf;
588 7763a61a 2003-11-23 devnull 	thdr.nstat = vdStat(&dir, thdr.stat, sizeof statbuf);
589 a20a1468 2005-01-16 devnull 	vdcleanup(&dir);
590 7763a61a 2003-11-23 devnull 	return 0;
591 7763a61a 2003-11-23 devnull }
592 7763a61a 2003-11-23 devnull 
593 7763a61a 2003-11-23 devnull char *
594 7763a61a 2003-11-23 devnull rwstat(Fid *f)
595 7763a61a 2003-11-23 devnull {
596 7763a61a 2003-11-23 devnull 	if(!f->busy)
597 a20a1468 2005-01-16 devnull 		return vtstrdup(Enotexist);
598 a20a1468 2005-01-16 devnull 	return vtstrdup(Erdonly);
599 7763a61a 2003-11-23 devnull }
600 7763a61a 2003-11-23 devnull 
601 7763a61a 2003-11-23 devnull int
602 7763a61a 2003-11-23 devnull vdStat(VacDir *vd, uchar *p, int np)
603 7763a61a 2003-11-23 devnull {
604 7763a61a 2003-11-23 devnull 	Dir dir;
605 7763a61a 2003-11-23 devnull 
606 7763a61a 2003-11-23 devnull 	memset(&dir, 0, sizeof(dir));
607 7763a61a 2003-11-23 devnull 
608 7763a61a 2003-11-23 devnull 	/*
609 7763a61a 2003-11-23 devnull 	 * Where do path and version come from
610 7763a61a 2003-11-23 devnull 	 */
611 7763a61a 2003-11-23 devnull 	dir.qid.path = vd->qid;
612 7763a61a 2003-11-23 devnull 	dir.qid.vers = vd->mcount;
613 7763a61a 2003-11-23 devnull 	dir.mode = vd->mode & 0777;
614 7763a61a 2003-11-23 devnull 	if(vd->mode & ModeAppend){
615 7763a61a 2003-11-23 devnull 		dir.qid.type |= QTAPPEND;
616 7763a61a 2003-11-23 devnull 		dir.mode |= DMAPPEND;
617 7763a61a 2003-11-23 devnull 	}
618 7763a61a 2003-11-23 devnull 	if(vd->mode & ModeExclusive){
619 7763a61a 2003-11-23 devnull 		dir.qid.type |= QTEXCL;
620 7763a61a 2003-11-23 devnull 		dir.mode |= DMEXCL;
621 7763a61a 2003-11-23 devnull 	}
622 7763a61a 2003-11-23 devnull 	if(vd->mode & ModeDir){
623 7763a61a 2003-11-23 devnull 		dir.qid.type |= QTDIR;
624 7763a61a 2003-11-23 devnull 		dir.mode |= DMDIR;
625 7763a61a 2003-11-23 devnull 	}
626 7763a61a 2003-11-23 devnull 
627 7763a61a 2003-11-23 devnull 	dir.atime = vd->atime;
628 7763a61a 2003-11-23 devnull 	dir.mtime = vd->mtime;
629 7763a61a 2003-11-23 devnull 	dir.length = vd->size;
630 7763a61a 2003-11-23 devnull 
631 7763a61a 2003-11-23 devnull 	dir.name = vd->elem;
632 7763a61a 2003-11-23 devnull 	dir.uid = vd->uid;
633 7763a61a 2003-11-23 devnull 	dir.gid = vd->gid;
634 7763a61a 2003-11-23 devnull 	dir.muid = vd->mid;
635 7763a61a 2003-11-23 devnull 
636 7763a61a 2003-11-23 devnull 	return convD2M(&dir, p, np);
637 7763a61a 2003-11-23 devnull }
638 7763a61a 2003-11-23 devnull 
639 7763a61a 2003-11-23 devnull DirBuf*
640 7763a61a 2003-11-23 devnull dirBufAlloc(VacFile *vf)
641 7763a61a 2003-11-23 devnull {
642 7763a61a 2003-11-23 devnull 	DirBuf *db;
643 7763a61a 2003-11-23 devnull 
644 a20a1468 2005-01-16 devnull 	db = vtmallocz(sizeof(DirBuf));
645 a20a1468 2005-01-16 devnull 	db->vde = vdeopen(vf);
646 7763a61a 2003-11-23 devnull 	return db;
647 7763a61a 2003-11-23 devnull }
648 7763a61a 2003-11-23 devnull 
649 7763a61a 2003-11-23 devnull VacDir *
650 7763a61a 2003-11-23 devnull dirBufGet(DirBuf *db)
651 7763a61a 2003-11-23 devnull {
652 7763a61a 2003-11-23 devnull 	VacDir *vd;
653 7763a61a 2003-11-23 devnull 	int n;
654 7763a61a 2003-11-23 devnull 
655 7763a61a 2003-11-23 devnull 	if(db->eof)
656 7763a61a 2003-11-23 devnull 		return nil;
657 7763a61a 2003-11-23 devnull 
658 7763a61a 2003-11-23 devnull 	if(db->i >= db->n) {
659 a20a1468 2005-01-16 devnull 		n = vderead(db->vde, db->buf);
660 7763a61a 2003-11-23 devnull 		if(n < 0)
661 7763a61a 2003-11-23 devnull 			return nil;
662 7763a61a 2003-11-23 devnull 		db->i = 0;
663 7763a61a 2003-11-23 devnull 		db->n = n;
664 7763a61a 2003-11-23 devnull 		if(n == 0) {
665 7763a61a 2003-11-23 devnull 			db->eof = 1;
666 7763a61a 2003-11-23 devnull 			return nil;
667 7763a61a 2003-11-23 devnull 		}
668 7763a61a 2003-11-23 devnull 	}
669 7763a61a 2003-11-23 devnull 
670 7763a61a 2003-11-23 devnull 	vd = db->buf + db->i;
671 7763a61a 2003-11-23 devnull 	db->i++;
672 7763a61a 2003-11-23 devnull 
673 7763a61a 2003-11-23 devnull 	return vd;
674 7763a61a 2003-11-23 devnull }
675 7763a61a 2003-11-23 devnull 
676 7763a61a 2003-11-23 devnull int
677 7763a61a 2003-11-23 devnull dirBufUnget(DirBuf *db)
678 7763a61a 2003-11-23 devnull {
679 7763a61a 2003-11-23 devnull 	assert(db->i > 0);
680 7763a61a 2003-11-23 devnull 	db->i--;
681 7763a61a 2003-11-23 devnull 	return 1;
682 7763a61a 2003-11-23 devnull }
683 7763a61a 2003-11-23 devnull 
684 7763a61a 2003-11-23 devnull void
685 7763a61a 2003-11-23 devnull dirBufFree(DirBuf *db)
686 7763a61a 2003-11-23 devnull {
687 7763a61a 2003-11-23 devnull 	int i;
688 7763a61a 2003-11-23 devnull 
689 7763a61a 2003-11-23 devnull 	if(db == nil)
690 7763a61a 2003-11-23 devnull 		return;
691 7763a61a 2003-11-23 devnull 
692 7763a61a 2003-11-23 devnull 	for(i=db->i; i<db->n; i++)
693 a20a1468 2005-01-16 devnull 		vdcleanup(db->buf + i);
694 a20a1468 2005-01-16 devnull 	vdeclose(db->vde);
695 a20a1468 2005-01-16 devnull 	vtfree(db);
696 7763a61a 2003-11-23 devnull }
697 7763a61a 2003-11-23 devnull 
698 7763a61a 2003-11-23 devnull int
699 7763a61a 2003-11-23 devnull vacdirread(Fid *f, char *p, long off, long cnt)
700 7763a61a 2003-11-23 devnull {
701 7763a61a 2003-11-23 devnull 	int n, nb;
702 7763a61a 2003-11-23 devnull 	VacDir *vd;
703 7763a61a 2003-11-23 devnull 
704 7763a61a 2003-11-23 devnull 	/*
705 7763a61a 2003-11-23 devnull 	 * special case of rewinding a directory
706 7763a61a 2003-11-23 devnull 	 * otherwise ignore the offset
707 7763a61a 2003-11-23 devnull 	 */
708 7763a61a 2003-11-23 devnull 	if(off == 0 && f->db) {
709 7763a61a 2003-11-23 devnull 		dirBufFree(f->db);
710 7763a61a 2003-11-23 devnull 		f->db = nil;
711 7763a61a 2003-11-23 devnull 	}
712 7763a61a 2003-11-23 devnull 
713 7763a61a 2003-11-23 devnull 	if(f->db == nil)
714 7763a61a 2003-11-23 devnull 		f->db = dirBufAlloc(f->file);
715 7763a61a 2003-11-23 devnull 
716 7763a61a 2003-11-23 devnull 	for(nb = 0; nb < cnt; nb += n) {
717 7763a61a 2003-11-23 devnull 		vd = dirBufGet(f->db);
718 7763a61a 2003-11-23 devnull 		if(vd == nil) {
719 7763a61a 2003-11-23 devnull 			if(!f->db->eof)
720 7763a61a 2003-11-23 devnull 				return -1;
721 7763a61a 2003-11-23 devnull 			break;
722 7763a61a 2003-11-23 devnull 		}
723 7763a61a 2003-11-23 devnull 		n = vdStat(vd, (uchar*)p, cnt-nb);
724 7763a61a 2003-11-23 devnull 		if(n <= BIT16SZ) {
725 7763a61a 2003-11-23 devnull 			dirBufUnget(f->db);
726 7763a61a 2003-11-23 devnull 			break;
727 7763a61a 2003-11-23 devnull 		}
728 a20a1468 2005-01-16 devnull 		vdcleanup(vd);
729 7763a61a 2003-11-23 devnull 		p += n;
730 7763a61a 2003-11-23 devnull 	}
731 7763a61a 2003-11-23 devnull 	return nb;
732 7763a61a 2003-11-23 devnull }
733 7763a61a 2003-11-23 devnull 
734 7763a61a 2003-11-23 devnull Fid *
735 7763a61a 2003-11-23 devnull newfid(int fid)
736 7763a61a 2003-11-23 devnull {
737 7763a61a 2003-11-23 devnull 	Fid *f, *ff;
738 7763a61a 2003-11-23 devnull 
739 7763a61a 2003-11-23 devnull 	ff = 0;
740 7763a61a 2003-11-23 devnull 	for(f = fids; f; f = f->next)
741 7763a61a 2003-11-23 devnull 		if(f->fid == fid)
742 7763a61a 2003-11-23 devnull 			return f;
743 7763a61a 2003-11-23 devnull 		else if(!ff && !f->busy)
744 7763a61a 2003-11-23 devnull 			ff = f;
745 7763a61a 2003-11-23 devnull 	if(ff){
746 7763a61a 2003-11-23 devnull 		ff->fid = fid;
747 7763a61a 2003-11-23 devnull 		return ff;
748 7763a61a 2003-11-23 devnull 	}
749 a20a1468 2005-01-16 devnull 	f = vtmallocz(sizeof *f);
750 7763a61a 2003-11-23 devnull 	f->fid = fid;
751 7763a61a 2003-11-23 devnull 	f->next = fids;
752 7763a61a 2003-11-23 devnull 	fids = f;
753 7763a61a 2003-11-23 devnull 	return f;
754 7763a61a 2003-11-23 devnull }
755 7763a61a 2003-11-23 devnull 
756 7763a61a 2003-11-23 devnull void
757 7763a61a 2003-11-23 devnull io(void)
758 7763a61a 2003-11-23 devnull {
759 7763a61a 2003-11-23 devnull 	char *err;
760 7763a61a 2003-11-23 devnull 	int n;
761 7763a61a 2003-11-23 devnull 
762 7763a61a 2003-11-23 devnull 	for(;;){
763 7763a61a 2003-11-23 devnull 		/*
764 7763a61a 2003-11-23 devnull 		 * reading from a pipe or a network device
765 7763a61a 2003-11-23 devnull 		 * will give an error after a few eof reads
766 7763a61a 2003-11-23 devnull 		 * however, we cannot tell the difference
767 7763a61a 2003-11-23 devnull 		 * between a zero-length read and an interrupt
768 7763a61a 2003-11-23 devnull 		 * on the processes writing to us,
769 7763a61a 2003-11-23 devnull 		 * so we wait for the error
770 7763a61a 2003-11-23 devnull 		 */
771 7763a61a 2003-11-23 devnull 		n = read9pmsg(mfd[0], mdata, sizeof mdata);
772 7763a61a 2003-11-23 devnull 		if(n == 0)
773 7763a61a 2003-11-23 devnull 			continue;
774 7763a61a 2003-11-23 devnull 		if(n < 0)
775 7763a61a 2003-11-23 devnull 			break;
776 7763a61a 2003-11-23 devnull 		if(convM2S(mdata, n, &rhdr) != n)
777 7763a61a 2003-11-23 devnull 			sysfatal("convM2S conversion error");
778 7763a61a 2003-11-23 devnull 
779 7763a61a 2003-11-23 devnull 		if(dflag)
780 7763a61a 2003-11-23 devnull 			fprint(2, "vacfs:<-%F\n", &rhdr);
781 7763a61a 2003-11-23 devnull 
782 7763a61a 2003-11-23 devnull 		thdr.data = (char*)mdata + IOHDRSZ;
783 7763a61a 2003-11-23 devnull 		if(!fcalls[rhdr.type])
784 7763a61a 2003-11-23 devnull 			err = "bad fcall type";
785 7763a61a 2003-11-23 devnull 		else
786 7763a61a 2003-11-23 devnull 			err = (*fcalls[rhdr.type])(newfid(rhdr.fid));
787 7763a61a 2003-11-23 devnull 		if(err){
788 7763a61a 2003-11-23 devnull 			thdr.type = Rerror;
789 7763a61a 2003-11-23 devnull 			thdr.ename = err;
790 7763a61a 2003-11-23 devnull 		}else{
791 7763a61a 2003-11-23 devnull 			thdr.type = rhdr.type + 1;
792 7763a61a 2003-11-23 devnull 			thdr.fid = rhdr.fid;
793 7763a61a 2003-11-23 devnull 		}
794 7763a61a 2003-11-23 devnull 		thdr.tag = rhdr.tag;
795 7763a61a 2003-11-23 devnull 		if(dflag)
796 7763a61a 2003-11-23 devnull 			fprint(2, "vacfs:->%F\n", &thdr);
797 7763a61a 2003-11-23 devnull 		n = convS2M(&thdr, mdata, messagesize);
798 a20a1468 2005-01-16 devnull 		if (err)
799 a20a1468 2005-01-16 devnull 			vtfree(err);
800 a20a1468 2005-01-16 devnull 
801 7763a61a 2003-11-23 devnull 		if(write(mfd[1], mdata, n) != n)
802 7763a61a 2003-11-23 devnull 			sysfatal("mount write: %r");
803 7763a61a 2003-11-23 devnull 	}
804 7763a61a 2003-11-23 devnull }
805 7763a61a 2003-11-23 devnull 
806 7763a61a 2003-11-23 devnull int
807 7763a61a 2003-11-23 devnull permf(VacFile *vf, char *user, int p)
808 7763a61a 2003-11-23 devnull {
809 7763a61a 2003-11-23 devnull 	VacDir dir;
810 7763a61a 2003-11-23 devnull 	ulong perm;
811 7763a61a 2003-11-23 devnull 
812 a20a1468 2005-01-16 devnull 	if(vacfilegetdir(vf, &dir))
813 7763a61a 2003-11-23 devnull 		return 0;
814 7763a61a 2003-11-23 devnull 	perm = dir.mode & 0777;
815 a20a1468 2005-01-16 devnull 
816 7763a61a 2003-11-23 devnull 	if(noperm)
817 7763a61a 2003-11-23 devnull 		goto Good;
818 7763a61a 2003-11-23 devnull 	if((p*Pother) & perm)
819 7763a61a 2003-11-23 devnull 		goto Good;
820 7763a61a 2003-11-23 devnull 	if(strcmp(user, dir.gid)==0 && ((p*Pgroup) & perm))
821 7763a61a 2003-11-23 devnull 		goto Good;
822 7763a61a 2003-11-23 devnull 	if(strcmp(user, dir.uid)==0 && ((p*Powner) & perm))
823 7763a61a 2003-11-23 devnull 		goto Good;
824 a20a1468 2005-01-16 devnull 	vdcleanup(&dir);
825 7763a61a 2003-11-23 devnull 	return 0;
826 7763a61a 2003-11-23 devnull Good:
827 a20a1468 2005-01-16 devnull 	vdcleanup(&dir);
828 7763a61a 2003-11-23 devnull 	return 1;
829 7763a61a 2003-11-23 devnull }
830 7763a61a 2003-11-23 devnull 
831 7763a61a 2003-11-23 devnull int
832 7763a61a 2003-11-23 devnull perm(Fid *f, int p)
833 7763a61a 2003-11-23 devnull {
834 7763a61a 2003-11-23 devnull 	return permf(f->file, f->user, p);
835 7763a61a 2003-11-23 devnull }
836 7763a61a 2003-11-23 devnull 
837 7763a61a 2003-11-23 devnull void
838 7763a61a 2003-11-23 devnull init(char *file, char *host, long ncache, int readOnly)
839 7763a61a 2003-11-23 devnull {
840 7763a61a 2003-11-23 devnull 	notify(notifyf);
841 7763a61a 2003-11-23 devnull 	user = getuser();
842 7763a61a 2003-11-23 devnull 
843 a20a1468 2005-01-16 devnull 	fmtinstall('V', vtscorefmt);
844 a20a1468 2005-01-16 devnull //	fmtinstall('R', vtErrFmt);
845 7763a61a 2003-11-23 devnull 
846 a20a1468 2005-01-16 devnull 	conn = vtdial(host);
847 a20a1468 2005-01-16 devnull 	if(conn == nil)
848 a20a1468 2005-01-16 devnull 		sysfatal("could not connect to server: %r");
849 7763a61a 2003-11-23 devnull 
850 a20a1468 2005-01-16 devnull 	if(vtconnect(conn) < 0)
851 a20a1468 2005-01-16 devnull 		sysfatal("vtconnect: %r");
852 7763a61a 2003-11-23 devnull 
853 a20a1468 2005-01-16 devnull 	fs = vacfsopen(conn, file, /*readOnly ? ModeSnapshot :*/ VtOREAD, ncache);
854 7763a61a 2003-11-23 devnull 	if(fs == nil)
855 a20a1468 2005-01-16 devnull 		sysfatal("vfsOpen: %r");
856 7763a61a 2003-11-23 devnull }
857 7763a61a 2003-11-23 devnull 
858 7763a61a 2003-11-23 devnull void
859 a331ac4c 2005-01-19 devnull vacshutdown(void)
860 7763a61a 2003-11-23 devnull {
861 7763a61a 2003-11-23 devnull 	Fid *f;
862 7763a61a 2003-11-23 devnull 
863 7763a61a 2003-11-23 devnull 	for(f = fids; f; f = f->next) {
864 7763a61a 2003-11-23 devnull 		if(!f->busy)
865 7763a61a 2003-11-23 devnull 			continue;
866 7763a61a 2003-11-23 devnull fprint(2, "open fid: %d\n", f->fid);
867 7763a61a 2003-11-23 devnull 		rclunk(f);
868 7763a61a 2003-11-23 devnull 	}
869 7763a61a 2003-11-23 devnull 
870 a20a1468 2005-01-16 devnull 	vacfsclose(fs);
871 a20a1468 2005-01-16 devnull 	vthangup(conn);
872 7763a61a 2003-11-23 devnull }
873 7763a61a 2003-11-23 devnull