1 2277c5d7 2004-03-21 devnull #include <u.h>
2 2277c5d7 2004-03-21 devnull #include <libc.h>
3 2277c5d7 2004-03-21 devnull #include <auth.h>
4 2277c5d7 2004-03-21 devnull #include <fcall.h>
5 2277c5d7 2004-03-21 devnull #include <thread.h>
6 2277c5d7 2004-03-21 devnull #include <9p.h>
8 8ba38113 2005-03-04 devnull int chatty9p;
10 2277c5d7 2004-03-21 devnull // static char Ebadattach[] = "unknown specifier in attach";
11 2277c5d7 2004-03-21 devnull static char Ebadoffset[] = "bad offset";
12 2277c5d7 2004-03-21 devnull // static char Ebadcount[] = "bad count";
13 2277c5d7 2004-03-21 devnull static char Ebotch[] = "9P protocol botch";
14 2277c5d7 2004-03-21 devnull static char Ecreatenondir[] = "create in non-directory";
15 2277c5d7 2004-03-21 devnull static char Edupfid[] = "duplicate fid";
16 2277c5d7 2004-03-21 devnull static char Eduptag[] = "duplicate tag";
17 2277c5d7 2004-03-21 devnull static char Eisdir[] = "is a directory";
18 2277c5d7 2004-03-21 devnull static char Enocreate[] = "create prohibited";
19 2277c5d7 2004-03-21 devnull // static char Enomem[] = "out of memory";
20 2277c5d7 2004-03-21 devnull static char Enoremove[] = "remove prohibited";
21 2277c5d7 2004-03-21 devnull static char Enostat[] = "stat prohibited";
22 2277c5d7 2004-03-21 devnull static char Enotfound[] = "file not found";
23 2277c5d7 2004-03-21 devnull // static char Enowrite[] = "write prohibited";
24 2277c5d7 2004-03-21 devnull static char Enowstat[] = "wstat prohibited";
25 2277c5d7 2004-03-21 devnull static char Eperm[] = "permission denied";
26 2277c5d7 2004-03-21 devnull static char Eunknownfid[] = "unknown fid";
27 2277c5d7 2004-03-21 devnull static char Ebaddir[] = "bad directory in wstat";
28 2277c5d7 2004-03-21 devnull static char Ewalknodir[] = "walk in non-directory";
30 2277c5d7 2004-03-21 devnull static void
31 2277c5d7 2004-03-21 devnull setfcallerror(Fcall *f, char *err)
33 2277c5d7 2004-03-21 devnull f->ename = err;
34 2277c5d7 2004-03-21 devnull f->type = Rerror;
37 2277c5d7 2004-03-21 devnull static void
38 2277c5d7 2004-03-21 devnull changemsize(Srv *srv, int msize)
40 2277c5d7 2004-03-21 devnull if(srv->rbuf && srv->wbuf && srv->msize == msize)
42 2277c5d7 2004-03-21 devnull qlock(&srv->rlock);
43 2277c5d7 2004-03-21 devnull qlock(&srv->wlock);
44 2277c5d7 2004-03-21 devnull srv->msize = msize;
45 2277c5d7 2004-03-21 devnull free(srv->rbuf);
46 2277c5d7 2004-03-21 devnull free(srv->wbuf);
47 2277c5d7 2004-03-21 devnull srv->rbuf = emalloc9p(msize);
48 2277c5d7 2004-03-21 devnull srv->wbuf = emalloc9p(msize);
49 2277c5d7 2004-03-21 devnull qunlock(&srv->rlock);
50 2277c5d7 2004-03-21 devnull qunlock(&srv->wlock);
53 2277c5d7 2004-03-21 devnull static Req*
54 2277c5d7 2004-03-21 devnull getreq(Srv *s)
57 2277c5d7 2004-03-21 devnull uchar *buf;
61 2277c5d7 2004-03-21 devnull qlock(&s->rlock);
62 2277c5d7 2004-03-21 devnull if((n = read9pmsg(s->infd, s->rbuf, s->msize)) <= 0){
63 2277c5d7 2004-03-21 devnull qunlock(&s->rlock);
64 2277c5d7 2004-03-21 devnull return nil;
67 2277c5d7 2004-03-21 devnull buf = emalloc9p(n);
68 2277c5d7 2004-03-21 devnull memmove(buf, s->rbuf, n);
69 2277c5d7 2004-03-21 devnull qunlock(&s->rlock);
71 90c892d8 2006-01-27 devnull if(convM2Su(buf, n, &f, s->dotu) != n){
72 2277c5d7 2004-03-21 devnull free(buf);
73 2277c5d7 2004-03-21 devnull return nil;
76 2277c5d7 2004-03-21 devnull if((r=allocreq(s->rpool, f.tag)) == nil){ /* duplicate tag: cons up a fake Req */
77 2277c5d7 2004-03-21 devnull r = emalloc9p(sizeof *r);
78 2277c5d7 2004-03-21 devnull incref(&r->ref);
79 2277c5d7 2004-03-21 devnull r->tag = f.tag;
80 2277c5d7 2004-03-21 devnull r->ifcall = f;
81 2277c5d7 2004-03-21 devnull r->error = Eduptag;
82 2277c5d7 2004-03-21 devnull r->buf = buf;
83 2277c5d7 2004-03-21 devnull r->responded = 0;
84 2277c5d7 2004-03-21 devnull r->type = 0;
85 2277c5d7 2004-03-21 devnull r->srv = s;
86 2277c5d7 2004-03-21 devnull r->pool = nil;
87 2277c5d7 2004-03-21 devnull if(chatty9p)
88 2277c5d7 2004-03-21 devnull fprint(2, "<-%d- %F: dup tag\n", s->infd, &f);
89 2277c5d7 2004-03-21 devnull return r;
92 2277c5d7 2004-03-21 devnull r->srv = s;
93 2277c5d7 2004-03-21 devnull r->responded = 0;
94 2277c5d7 2004-03-21 devnull r->buf = buf;
95 2277c5d7 2004-03-21 devnull r->ifcall = f;
96 2277c5d7 2004-03-21 devnull memset(&r->ofcall, 0, sizeof r->ofcall);
97 2277c5d7 2004-03-21 devnull r->type = r->ifcall.type;
99 2277c5d7 2004-03-21 devnull if(chatty9p)
100 2277c5d7 2004-03-21 devnull if(r->error)
101 2277c5d7 2004-03-21 devnull fprint(2, "<-%d- %F: %s\n", s->infd, &r->ifcall, r->error);
103 2277c5d7 2004-03-21 devnull fprint(2, "<-%d- %F\n", s->infd, &r->ifcall);
105 2277c5d7 2004-03-21 devnull return r;
108 2277c5d7 2004-03-21 devnull static void
109 2277c5d7 2004-03-21 devnull filewalk(Req *r)
112 2277c5d7 2004-03-21 devnull File *f;
114 2277c5d7 2004-03-21 devnull f = r->fid->file;
115 2277c5d7 2004-03-21 devnull assert(f != nil);
117 2277c5d7 2004-03-21 devnull incref(&f->ref);
118 2277c5d7 2004-03-21 devnull for(i=0; i<r->ifcall.nwname; i++)
119 2277c5d7 2004-03-21 devnull if(f = walkfile(f, r->ifcall.wname[i]))
120 2277c5d7 2004-03-21 devnull r->ofcall.wqid[i] = f->dir.qid;
124 2277c5d7 2004-03-21 devnull r->ofcall.nwqid = i;
126 2277c5d7 2004-03-21 devnull r->newfid->file = f;
127 2277c5d7 2004-03-21 devnull r->newfid->qid = r->newfid->file->dir.qid;
129 2277c5d7 2004-03-21 devnull respond(r, nil);
133 2277c5d7 2004-03-21 devnull walkandclone(Req *r, char *(*walk1)(Fid*, char*, void*), char *(*clone)(Fid*, Fid*, void*), void *arg)
136 2277c5d7 2004-03-21 devnull char *e;
138 2277c5d7 2004-03-21 devnull if(r->fid == r->newfid && r->ifcall.nwname > 1){
139 2277c5d7 2004-03-21 devnull respond(r, "lib9p: unused documented feature not implemented");
143 2277c5d7 2004-03-21 devnull if(r->fid != r->newfid){
144 2277c5d7 2004-03-21 devnull r->newfid->qid = r->fid->qid;
145 2277c5d7 2004-03-21 devnull if(clone && (e = clone(r->fid, r->newfid, arg))){
146 2277c5d7 2004-03-21 devnull respond(r, e);
151 2277c5d7 2004-03-21 devnull e = nil;
152 2277c5d7 2004-03-21 devnull for(i=0; i<r->ifcall.nwname; i++){
153 2277c5d7 2004-03-21 devnull if(e = walk1(r->newfid, r->ifcall.wname[i], arg))
155 2277c5d7 2004-03-21 devnull r->ofcall.wqid[i] = r->newfid->qid;
158 2277c5d7 2004-03-21 devnull r->ofcall.nwqid = i;
159 2277c5d7 2004-03-21 devnull if(e && i==0)
160 2277c5d7 2004-03-21 devnull respond(r, e);
162 2277c5d7 2004-03-21 devnull respond(r, nil);
165 2277c5d7 2004-03-21 devnull static void
166 2277c5d7 2004-03-21 devnull sversion(Srv *srv, Req *r)
168 2277c5d7 2004-03-21 devnull USED(srv);
170 2277c5d7 2004-03-21 devnull if(strncmp(r->ifcall.version, "9P", 2) != 0){
171 2277c5d7 2004-03-21 devnull r->ofcall.version = "unknown";
172 2277c5d7 2004-03-21 devnull respond(r, nil);
176 90c892d8 2006-01-27 devnull if(strncmp(r->ifcall.version, "9P2000.u", 8) == 0){
177 90c892d8 2006-01-27 devnull r->ofcall.version = "9P2000.u";
178 90c892d8 2006-01-27 devnull srv->dotu = 1;
180 90c892d8 2006-01-27 devnull r->ofcall.version = "9P2000";
181 90c892d8 2006-01-27 devnull srv->dotu = 0;
183 2277c5d7 2004-03-21 devnull r->ofcall.msize = r->ifcall.msize;
184 2277c5d7 2004-03-21 devnull respond(r, nil);
186 2277c5d7 2004-03-21 devnull static void
187 2277c5d7 2004-03-21 devnull rversion(Req *r, char *error)
189 2277c5d7 2004-03-21 devnull assert(error == nil);
190 2277c5d7 2004-03-21 devnull changemsize(r->srv, r->ofcall.msize);
193 2277c5d7 2004-03-21 devnull static void
194 2277c5d7 2004-03-21 devnull sauth(Srv *srv, Req *r)
196 2277c5d7 2004-03-21 devnull char e[ERRMAX];
198 2277c5d7 2004-03-21 devnull if((r->afid = allocfid(srv->fpool, r->ifcall.afid)) == nil){
199 2277c5d7 2004-03-21 devnull respond(r, Edupfid);
202 2277c5d7 2004-03-21 devnull if(srv->auth)
203 2277c5d7 2004-03-21 devnull srv->auth(r);
205 2277c5d7 2004-03-21 devnull snprint(e, sizeof e, "%s: authentication not required", argv0);
206 2277c5d7 2004-03-21 devnull respond(r, e);
209 2277c5d7 2004-03-21 devnull static void
210 2277c5d7 2004-03-21 devnull rauth(Req *r, char *error)
212 2277c5d7 2004-03-21 devnull if(error && r->afid)
213 2277c5d7 2004-03-21 devnull closefid(removefid(r->srv->fpool, r->afid->fid));
216 2277c5d7 2004-03-21 devnull static void
217 2277c5d7 2004-03-21 devnull sattach(Srv *srv, Req *r)
219 2277c5d7 2004-03-21 devnull if((r->fid = allocfid(srv->fpool, r->ifcall.fid)) == nil){
220 2277c5d7 2004-03-21 devnull respond(r, Edupfid);
223 2277c5d7 2004-03-21 devnull r->afid = nil;
224 2277c5d7 2004-03-21 devnull if(r->ifcall.afid != NOFID && (r->afid = lookupfid(srv->fpool, r->ifcall.afid)) == nil){
225 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
228 2277c5d7 2004-03-21 devnull r->fid->uid = estrdup9p(r->ifcall.uname);
229 2277c5d7 2004-03-21 devnull if(srv->tree){
230 2277c5d7 2004-03-21 devnull r->fid->file = srv->tree->root;
231 2277c5d7 2004-03-21 devnull /* BUG? incref(r->fid->file) ??? */
232 2277c5d7 2004-03-21 devnull r->ofcall.qid = r->fid->file->dir.qid;
233 2277c5d7 2004-03-21 devnull r->fid->qid = r->ofcall.qid;
235 2277c5d7 2004-03-21 devnull if(srv->attach)
236 2277c5d7 2004-03-21 devnull srv->attach(r);
238 2277c5d7 2004-03-21 devnull respond(r, nil);
241 2277c5d7 2004-03-21 devnull static void
242 2277c5d7 2004-03-21 devnull rattach(Req *r, char *error)
244 2277c5d7 2004-03-21 devnull if(error && r->fid)
245 2277c5d7 2004-03-21 devnull closefid(removefid(r->srv->fpool, r->fid->fid));
248 2277c5d7 2004-03-21 devnull static void
249 2277c5d7 2004-03-21 devnull sflush(Srv *srv, Req *r)
251 2277c5d7 2004-03-21 devnull r->oldreq = lookupreq(srv->rpool, r->ifcall.oldtag);
252 2277c5d7 2004-03-21 devnull if(r->oldreq == nil || r->oldreq == r)
253 2277c5d7 2004-03-21 devnull respond(r, nil);
254 2277c5d7 2004-03-21 devnull else if(srv->flush)
255 2277c5d7 2004-03-21 devnull srv->flush(r);
257 2277c5d7 2004-03-21 devnull respond(r, nil);
259 2277c5d7 2004-03-21 devnull static int
260 2277c5d7 2004-03-21 devnull rflush(Req *r, char *error)
262 2277c5d7 2004-03-21 devnull Req *or;
264 2277c5d7 2004-03-21 devnull assert(error == nil);
265 2277c5d7 2004-03-21 devnull or = r->oldreq;
267 2277c5d7 2004-03-21 devnull qlock(&or->lk);
268 2277c5d7 2004-03-21 devnull if(or->responded == 0){
269 2277c5d7 2004-03-21 devnull or->flush = erealloc9p(or->flush, (or->nflush+1)*sizeof(or->flush[0]));
270 2277c5d7 2004-03-21 devnull or->flush[or->nflush++] = r;
271 2277c5d7 2004-03-21 devnull qunlock(&or->lk);
272 2277c5d7 2004-03-21 devnull return -1; /* delay response until or is responded */
274 2277c5d7 2004-03-21 devnull qunlock(&or->lk);
275 2277c5d7 2004-03-21 devnull closereq(or);
277 2277c5d7 2004-03-21 devnull r->oldreq = nil;
278 2277c5d7 2004-03-21 devnull return 0;
281 2277c5d7 2004-03-21 devnull static char*
282 2277c5d7 2004-03-21 devnull oldwalk1(Fid *fid, char *name, void *arg)
284 2277c5d7 2004-03-21 devnull char *e;
285 2277c5d7 2004-03-21 devnull Qid qid;
286 2277c5d7 2004-03-21 devnull Srv *srv;
288 2277c5d7 2004-03-21 devnull srv = arg;
289 2277c5d7 2004-03-21 devnull e = srv->walk1(fid, name, &qid);
291 2277c5d7 2004-03-21 devnull return e;
292 2277c5d7 2004-03-21 devnull fid->qid = qid;
293 2277c5d7 2004-03-21 devnull return nil;
296 2277c5d7 2004-03-21 devnull static char*
297 2277c5d7 2004-03-21 devnull oldclone(Fid *fid, Fid *newfid, void *arg)
299 2277c5d7 2004-03-21 devnull Srv *srv;
301 2277c5d7 2004-03-21 devnull srv = arg;
302 2277c5d7 2004-03-21 devnull if(srv->clone == nil)
303 2277c5d7 2004-03-21 devnull return nil;
304 2277c5d7 2004-03-21 devnull return srv->clone(fid, newfid);
307 2277c5d7 2004-03-21 devnull static void
308 2277c5d7 2004-03-21 devnull swalk(Srv *srv, Req *r)
310 2277c5d7 2004-03-21 devnull if((r->fid = lookupfid(srv->fpool, r->ifcall.fid)) == nil){
311 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
314 2277c5d7 2004-03-21 devnull if(r->fid->omode != -1){
315 2277c5d7 2004-03-21 devnull respond(r, "cannot clone open fid");
318 2277c5d7 2004-03-21 devnull if(r->ifcall.nwname && !(r->fid->qid.type&QTDIR)){
319 2277c5d7 2004-03-21 devnull respond(r, Ewalknodir);
322 2277c5d7 2004-03-21 devnull if(r->ifcall.fid != r->ifcall.newfid){
323 2277c5d7 2004-03-21 devnull if((r->newfid = allocfid(srv->fpool, r->ifcall.newfid)) == nil){
324 2277c5d7 2004-03-21 devnull respond(r, Edupfid);
327 2277c5d7 2004-03-21 devnull r->newfid->uid = estrdup9p(r->fid->uid);
329 2277c5d7 2004-03-21 devnull incref(&r->fid->ref);
330 2277c5d7 2004-03-21 devnull r->newfid = r->fid;
332 2277c5d7 2004-03-21 devnull if(r->fid->file){
333 2277c5d7 2004-03-21 devnull filewalk(r);
334 2277c5d7 2004-03-21 devnull }else if(srv->walk1)
335 2277c5d7 2004-03-21 devnull walkandclone(r, oldwalk1, oldclone, srv);
336 2277c5d7 2004-03-21 devnull else if(srv->walk)
337 2277c5d7 2004-03-21 devnull srv->walk(r);
339 2277c5d7 2004-03-21 devnull sysfatal("no walk function, no file trees");
341 2277c5d7 2004-03-21 devnull static void
342 2277c5d7 2004-03-21 devnull rwalk(Req *r, char *error)
344 2277c5d7 2004-03-21 devnull if(error || r->ofcall.nwqid < r->ifcall.nwname){
345 2277c5d7 2004-03-21 devnull if(r->ifcall.fid != r->ifcall.newfid && r->newfid)
346 2277c5d7 2004-03-21 devnull closefid(removefid(r->srv->fpool, r->newfid->fid));
347 2277c5d7 2004-03-21 devnull if (r->ofcall.nwqid==0){
348 2277c5d7 2004-03-21 devnull if(error==nil && r->ifcall.nwname!=0)
349 2277c5d7 2004-03-21 devnull r->error = Enotfound;
351 2277c5d7 2004-03-21 devnull r->error = nil; // No error on partial walks
353 2277c5d7 2004-03-21 devnull if(r->ofcall.nwqid == 0){
354 2277c5d7 2004-03-21 devnull /* Just a clone */
355 2277c5d7 2004-03-21 devnull r->newfid->qid = r->fid->qid;
357 2277c5d7 2004-03-21 devnull /* if file trees are in use, filewalk took care of the rest */
358 2277c5d7 2004-03-21 devnull r->newfid->qid = r->ofcall.wqid[r->ofcall.nwqid-1];
363 2277c5d7 2004-03-21 devnull static void
364 2277c5d7 2004-03-21 devnull sopen(Srv *srv, Req *r)
368 2277c5d7 2004-03-21 devnull if((r->fid = lookupfid(srv->fpool, r->ifcall.fid)) == nil){
369 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
372 2277c5d7 2004-03-21 devnull if(r->fid->omode != -1){
373 2277c5d7 2004-03-21 devnull respond(r, Ebotch);
376 2277c5d7 2004-03-21 devnull if((r->fid->qid.type&QTDIR) && (r->ifcall.mode&~ORCLOSE) != OREAD){
377 2277c5d7 2004-03-21 devnull respond(r, Eisdir);
380 2277c5d7 2004-03-21 devnull r->ofcall.qid = r->fid->qid;
381 2277c5d7 2004-03-21 devnull switch(r->ifcall.mode&3){
382 2277c5d7 2004-03-21 devnull default:
383 2277c5d7 2004-03-21 devnull assert(0);
384 2277c5d7 2004-03-21 devnull case OREAD:
385 2277c5d7 2004-03-21 devnull p = AREAD;
387 2277c5d7 2004-03-21 devnull case OWRITE:
388 2277c5d7 2004-03-21 devnull p = AWRITE;
390 2277c5d7 2004-03-21 devnull case ORDWR:
391 2277c5d7 2004-03-21 devnull p = AREAD|AWRITE;
393 2277c5d7 2004-03-21 devnull case OEXEC:
394 2277c5d7 2004-03-21 devnull p = AEXEC;
397 2277c5d7 2004-03-21 devnull if(r->ifcall.mode&OTRUNC)
398 2277c5d7 2004-03-21 devnull p |= AWRITE;
399 2277c5d7 2004-03-21 devnull if((r->fid->qid.type&QTDIR) && p!=AREAD){
400 2277c5d7 2004-03-21 devnull respond(r, Eperm);
403 2277c5d7 2004-03-21 devnull if(r->fid->file){
404 2277c5d7 2004-03-21 devnull if(!hasperm(r->fid->file, r->fid->uid, p)){
405 2277c5d7 2004-03-21 devnull respond(r, Eperm);
408 2277c5d7 2004-03-21 devnull /* BUG RACE */
409 2277c5d7 2004-03-21 devnull if((r->ifcall.mode&ORCLOSE)
410 2277c5d7 2004-03-21 devnull && !hasperm(r->fid->file->parent, r->fid->uid, AWRITE)){
411 2277c5d7 2004-03-21 devnull respond(r, Eperm);
414 2277c5d7 2004-03-21 devnull r->ofcall.qid = r->fid->file->dir.qid;
415 2277c5d7 2004-03-21 devnull if((r->ofcall.qid.type&QTDIR)
416 2277c5d7 2004-03-21 devnull && (r->fid->rdir = opendirfile(r->fid->file)) == nil){
417 2277c5d7 2004-03-21 devnull respond(r, "opendirfile failed");
421 2277c5d7 2004-03-21 devnull if(srv->open)
422 2277c5d7 2004-03-21 devnull srv->open(r);
424 2277c5d7 2004-03-21 devnull respond(r, nil);
426 2277c5d7 2004-03-21 devnull static void
427 2277c5d7 2004-03-21 devnull ropen(Req *r, char *error)
429 2277c5d7 2004-03-21 devnull char errbuf[ERRMAX];
430 2277c5d7 2004-03-21 devnull if(error)
432 2277c5d7 2004-03-21 devnull if(chatty9p){
433 2277c5d7 2004-03-21 devnull snprint(errbuf, sizeof errbuf, "fid mode is 0x%ux\n", r->ifcall.mode);
434 2277c5d7 2004-03-21 devnull write(2, errbuf, strlen(errbuf));
436 2277c5d7 2004-03-21 devnull r->fid->omode = r->ifcall.mode;
437 2277c5d7 2004-03-21 devnull r->fid->qid = r->ofcall.qid;
438 2277c5d7 2004-03-21 devnull if(r->ofcall.qid.type&QTDIR)
439 2277c5d7 2004-03-21 devnull r->fid->diroffset = 0;
442 2277c5d7 2004-03-21 devnull static void
443 2277c5d7 2004-03-21 devnull screate(Srv *srv, Req *r)
445 2277c5d7 2004-03-21 devnull if((r->fid = lookupfid(srv->fpool, r->ifcall.fid)) == nil)
446 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
447 2277c5d7 2004-03-21 devnull else if(r->fid->omode != -1)
448 2277c5d7 2004-03-21 devnull respond(r, Ebotch);
449 2277c5d7 2004-03-21 devnull else if(!(r->fid->qid.type&QTDIR))
450 2277c5d7 2004-03-21 devnull respond(r, Ecreatenondir);
451 2277c5d7 2004-03-21 devnull else if(r->fid->file && !hasperm(r->fid->file, r->fid->uid, AWRITE))
452 2277c5d7 2004-03-21 devnull respond(r, Eperm);
453 2277c5d7 2004-03-21 devnull else if(srv->create)
454 2277c5d7 2004-03-21 devnull srv->create(r);
456 2277c5d7 2004-03-21 devnull respond(r, Enocreate);
458 2277c5d7 2004-03-21 devnull static void
459 2277c5d7 2004-03-21 devnull rcreate(Req *r, char *error)
461 2277c5d7 2004-03-21 devnull if(error)
463 2277c5d7 2004-03-21 devnull r->fid->omode = r->ifcall.mode;
464 2277c5d7 2004-03-21 devnull r->fid->qid = r->ofcall.qid;
467 2277c5d7 2004-03-21 devnull static void
468 2277c5d7 2004-03-21 devnull sread(Srv *srv, Req *r)
472 2277c5d7 2004-03-21 devnull if((r->fid = lookupfid(srv->fpool, r->ifcall.fid)) == nil){
473 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
476 2277c5d7 2004-03-21 devnull if(r->ifcall.count < 0){
477 2277c5d7 2004-03-21 devnull respond(r, Ebotch);
480 2277c5d7 2004-03-21 devnull if(r->ifcall.offset < 0
481 2277c5d7 2004-03-21 devnull || ((r->fid->qid.type&QTDIR) && r->ifcall.offset != 0 && r->ifcall.offset != r->fid->diroffset)){
482 2277c5d7 2004-03-21 devnull respond(r, Ebadoffset);
486 2277c5d7 2004-03-21 devnull if(r->ifcall.count > srv->msize - IOHDRSZ)
487 2277c5d7 2004-03-21 devnull r->ifcall.count = srv->msize - IOHDRSZ;
488 2277c5d7 2004-03-21 devnull r->rbuf = emalloc9p(r->ifcall.count);
489 2277c5d7 2004-03-21 devnull r->ofcall.data = r->rbuf;
490 2277c5d7 2004-03-21 devnull o = r->fid->omode & 3;
491 2277c5d7 2004-03-21 devnull if(o != OREAD && o != ORDWR && o != OEXEC){
492 2277c5d7 2004-03-21 devnull respond(r, Ebotch);
495 2277c5d7 2004-03-21 devnull if((r->fid->qid.type&QTDIR) && r->fid->file){
496 2277c5d7 2004-03-21 devnull r->ofcall.count = readdirfile(r->fid->rdir, r->rbuf, r->ifcall.count);
497 2277c5d7 2004-03-21 devnull respond(r, nil);
500 2277c5d7 2004-03-21 devnull if(srv->read)
501 2277c5d7 2004-03-21 devnull srv->read(r);
503 2277c5d7 2004-03-21 devnull respond(r, "no srv->read");
505 2277c5d7 2004-03-21 devnull static void
506 2277c5d7 2004-03-21 devnull rread(Req *r, char *error)
508 2277c5d7 2004-03-21 devnull if(error==nil && (r->fid->qid.type&QTDIR))
509 2277c5d7 2004-03-21 devnull r->fid->diroffset += r->ofcall.count;
512 2277c5d7 2004-03-21 devnull static void
513 2277c5d7 2004-03-21 devnull swrite(Srv *srv, Req *r)
516 2277c5d7 2004-03-21 devnull char e[ERRMAX];
518 2277c5d7 2004-03-21 devnull if((r->fid = lookupfid(srv->fpool, r->ifcall.fid)) == nil){
519 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
522 2277c5d7 2004-03-21 devnull if(r->ifcall.count < 0){
523 2277c5d7 2004-03-21 devnull respond(r, Ebotch);
526 2277c5d7 2004-03-21 devnull if(r->ifcall.offset < 0){
527 2277c5d7 2004-03-21 devnull respond(r, Ebotch);
530 2277c5d7 2004-03-21 devnull if(r->ifcall.count > srv->msize - IOHDRSZ)
531 2277c5d7 2004-03-21 devnull r->ifcall.count = srv->msize - IOHDRSZ;
532 2277c5d7 2004-03-21 devnull o = r->fid->omode & 3;
533 2277c5d7 2004-03-21 devnull if(o != OWRITE && o != ORDWR){
534 2277c5d7 2004-03-21 devnull snprint(e, sizeof e, "write on fid with open mode 0x%ux", r->fid->omode);
535 2277c5d7 2004-03-21 devnull respond(r, e);
538 2277c5d7 2004-03-21 devnull if(srv->write)
539 2277c5d7 2004-03-21 devnull srv->write(r);
541 2277c5d7 2004-03-21 devnull respond(r, "no srv->write");
543 2277c5d7 2004-03-21 devnull static void
544 2277c5d7 2004-03-21 devnull rwrite(Req *r, char *error)
546 2277c5d7 2004-03-21 devnull if(error)
548 2277c5d7 2004-03-21 devnull if(r->fid->file)
549 2277c5d7 2004-03-21 devnull r->fid->file->dir.qid.vers++;
552 2277c5d7 2004-03-21 devnull static void
553 2277c5d7 2004-03-21 devnull sclunk(Srv *srv, Req *r)
555 2277c5d7 2004-03-21 devnull if((r->fid = removefid(srv->fpool, r->ifcall.fid)) == nil)
556 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
558 2277c5d7 2004-03-21 devnull respond(r, nil);
560 2277c5d7 2004-03-21 devnull static void
561 2277c5d7 2004-03-21 devnull rclunk(Req *r, char *msg)
563 2277c5d7 2004-03-21 devnull USED(r);
564 2277c5d7 2004-03-21 devnull USED(msg);
567 2277c5d7 2004-03-21 devnull static void
568 2277c5d7 2004-03-21 devnull sremove(Srv *srv, Req *r)
570 2277c5d7 2004-03-21 devnull if((r->fid = removefid(srv->fpool, r->ifcall.fid)) == nil){
571 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
574 2277c5d7 2004-03-21 devnull /* BUG RACE */
575 2277c5d7 2004-03-21 devnull if(r->fid->file && !hasperm(r->fid->file->parent, r->fid->uid, AWRITE)){
576 2277c5d7 2004-03-21 devnull respond(r, Eperm);
579 2277c5d7 2004-03-21 devnull if(srv->remove)
580 2277c5d7 2004-03-21 devnull srv->remove(r);
582 2277c5d7 2004-03-21 devnull respond(r, r->fid->file ? nil : Enoremove);
584 2277c5d7 2004-03-21 devnull static void
585 2277c5d7 2004-03-21 devnull rremove(Req *r, char *error, char *errbuf)
587 2277c5d7 2004-03-21 devnull if(error)
589 2277c5d7 2004-03-21 devnull if(r->fid->file){
590 2277c5d7 2004-03-21 devnull if(removefile(r->fid->file) < 0){
591 2277c5d7 2004-03-21 devnull snprint(errbuf, ERRMAX, "remove %s: %r",
592 2277c5d7 2004-03-21 devnull r->fid->file->dir.name);
593 2277c5d7 2004-03-21 devnull r->error = errbuf;
595 2277c5d7 2004-03-21 devnull r->fid->file = nil;
599 2277c5d7 2004-03-21 devnull static void
600 2277c5d7 2004-03-21 devnull sstat(Srv *srv, Req *r)
602 2277c5d7 2004-03-21 devnull if((r->fid = lookupfid(srv->fpool, r->ifcall.fid)) == nil){
603 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
606 2277c5d7 2004-03-21 devnull if(r->fid->file){
607 2277c5d7 2004-03-21 devnull r->d = r->fid->file->dir;
608 2277c5d7 2004-03-21 devnull if(r->d.name)
609 2277c5d7 2004-03-21 devnull r->d.name = estrdup9p(r->d.name);
610 2277c5d7 2004-03-21 devnull if(r->d.uid)
611 2277c5d7 2004-03-21 devnull r->d.uid = estrdup9p(r->d.uid);
612 2277c5d7 2004-03-21 devnull if(r->d.gid)
613 2277c5d7 2004-03-21 devnull r->d.gid = estrdup9p(r->d.gid);
614 2277c5d7 2004-03-21 devnull if(r->d.muid)
615 2277c5d7 2004-03-21 devnull r->d.muid = estrdup9p(r->d.muid);
617 2277c5d7 2004-03-21 devnull if(srv->stat)
618 2277c5d7 2004-03-21 devnull srv->stat(r);
619 2277c5d7 2004-03-21 devnull else if(r->fid->file)
620 2277c5d7 2004-03-21 devnull respond(r, nil);
622 2277c5d7 2004-03-21 devnull respond(r, Enostat);
624 2277c5d7 2004-03-21 devnull static void
625 2277c5d7 2004-03-21 devnull rstat(Req *r, char *error)
628 2277c5d7 2004-03-21 devnull uchar *statbuf;
629 2277c5d7 2004-03-21 devnull uchar tmp[BIT16SZ];
631 2277c5d7 2004-03-21 devnull if(error)
633 90c892d8 2006-01-27 devnull if(convD2Mu(&r->d, tmp, BIT16SZ, r->srv->dotu) != BIT16SZ){
634 90c892d8 2006-01-27 devnull r->error = "convD2Mu(_,_,BIT16SZ,_) did not return BIT16SZ";
637 2277c5d7 2004-03-21 devnull n = GBIT16(tmp)+BIT16SZ;
638 2277c5d7 2004-03-21 devnull statbuf = emalloc9p(n);
639 2277c5d7 2004-03-21 devnull if(statbuf == nil){
640 2277c5d7 2004-03-21 devnull r->error = "out of memory";
643 90c892d8 2006-01-27 devnull r->ofcall.nstat = convD2Mu(&r->d, statbuf, n, r->srv->dotu);
644 2277c5d7 2004-03-21 devnull r->ofcall.stat = statbuf; /* freed in closereq */
645 2277c5d7 2004-03-21 devnull if(r->ofcall.nstat <= BIT16SZ){
646 90c892d8 2006-01-27 devnull r->error = "convD2Mu fails";
647 2277c5d7 2004-03-21 devnull free(statbuf);
652 2277c5d7 2004-03-21 devnull static void
653 2277c5d7 2004-03-21 devnull swstat(Srv *srv, Req *r)
655 2277c5d7 2004-03-21 devnull if((r->fid = lookupfid(srv->fpool, r->ifcall.fid)) == nil){
656 2277c5d7 2004-03-21 devnull respond(r, Eunknownfid);
659 2277c5d7 2004-03-21 devnull if(srv->wstat == nil){
660 2277c5d7 2004-03-21 devnull respond(r, Enowstat);
663 90c892d8 2006-01-27 devnull if(convM2Du(r->ifcall.stat, r->ifcall.nstat, &r->d, (char*)r->ifcall.stat, srv->dotu) != r->ifcall.nstat){
664 2277c5d7 2004-03-21 devnull respond(r, Ebaddir);
667 2277c5d7 2004-03-21 devnull if((ushort)~r->d.type){
668 2277c5d7 2004-03-21 devnull respond(r, "wstat -- attempt to change type");
671 2277c5d7 2004-03-21 devnull if((uint)~r->d.dev){
672 2277c5d7 2004-03-21 devnull respond(r, "wstat -- attempt to change dev");
675 2277c5d7 2004-03-21 devnull if((uchar)~r->d.qid.type || (ulong)~r->d.qid.vers || (uvlong)~r->d.qid.path){
676 2277c5d7 2004-03-21 devnull respond(r, "wstat -- attempt to change qid");
679 2277c5d7 2004-03-21 devnull if(r->d.muid && r->d.muid[0]){
680 2277c5d7 2004-03-21 devnull respond(r, "wstat -- attempt to change muid");
683 2277c5d7 2004-03-21 devnull if((ulong)~r->d.mode && ((r->d.mode&DMDIR)>>24) != (r->fid->qid.type&QTDIR)){
684 2277c5d7 2004-03-21 devnull respond(r, "wstat -- attempt to change DMDIR bit");
687 2277c5d7 2004-03-21 devnull srv->wstat(r);
689 2277c5d7 2004-03-21 devnull static void
690 2277c5d7 2004-03-21 devnull rwstat(Req *r, char *msg)
692 2277c5d7 2004-03-21 devnull USED(r);
693 2277c5d7 2004-03-21 devnull USED(msg);
697 2277c5d7 2004-03-21 devnull srv(Srv *srv)
701 2277c5d7 2004-03-21 devnull fmtinstall('D', dirfmt);
702 2277c5d7 2004-03-21 devnull fmtinstall('F', fcallfmt);
704 2277c5d7 2004-03-21 devnull if(srv->fpool == nil)
705 2277c5d7 2004-03-21 devnull srv->fpool = allocfidpool(srv->destroyfid);
706 2277c5d7 2004-03-21 devnull if(srv->rpool == nil)
707 2277c5d7 2004-03-21 devnull srv->rpool = allocreqpool(srv->destroyreq);
708 2277c5d7 2004-03-21 devnull if(srv->msize == 0)
709 2277c5d7 2004-03-21 devnull srv->msize = 8192+IOHDRSZ;
711 2277c5d7 2004-03-21 devnull changemsize(srv, srv->msize);
713 2277c5d7 2004-03-21 devnull srv->fpool->srv = srv;
714 2277c5d7 2004-03-21 devnull srv->rpool->srv = srv;
716 2aa7d303 2005-02-11 devnull if(srv->start)
717 2aa7d303 2005-02-11 devnull srv->start(srv);
719 2277c5d7 2004-03-21 devnull while(r = getreq(srv)){
720 2277c5d7 2004-03-21 devnull if(r->error){
721 2277c5d7 2004-03-21 devnull respond(r, r->error);
722 2277c5d7 2004-03-21 devnull continue;
724 2277c5d7 2004-03-21 devnull switch(r->ifcall.type){
725 2277c5d7 2004-03-21 devnull default:
726 2277c5d7 2004-03-21 devnull respond(r, "unknown message");
728 2277c5d7 2004-03-21 devnull case Tversion: sversion(srv, r); break;
729 2277c5d7 2004-03-21 devnull case Tauth: sauth(srv, r); break;
730 2277c5d7 2004-03-21 devnull case Tattach: sattach(srv, r); break;
731 2277c5d7 2004-03-21 devnull case Tflush: sflush(srv, r); break;
732 2277c5d7 2004-03-21 devnull case Twalk: swalk(srv, r); break;
733 2277c5d7 2004-03-21 devnull case Topen: sopen(srv, r); break;
734 2277c5d7 2004-03-21 devnull case Tcreate: screate(srv, r); break;
735 2277c5d7 2004-03-21 devnull case Tread: sread(srv, r); break;
736 2277c5d7 2004-03-21 devnull case Twrite: swrite(srv, r); break;
737 2277c5d7 2004-03-21 devnull case Tclunk: sclunk(srv, r); break;
738 2277c5d7 2004-03-21 devnull case Tremove: sremove(srv, r); break;
739 2277c5d7 2004-03-21 devnull case Tstat: sstat(srv, r); break;
740 2277c5d7 2004-03-21 devnull case Twstat: swstat(srv, r); break;
744 2277c5d7 2004-03-21 devnull if(srv->end)
745 2277c5d7 2004-03-21 devnull srv->end(srv);
749 2277c5d7 2004-03-21 devnull respond(Req *r, char *error)
751 2277c5d7 2004-03-21 devnull int i, m, n;
752 2277c5d7 2004-03-21 devnull char errbuf[ERRMAX];
753 2277c5d7 2004-03-21 devnull Srv *srv;
755 2277c5d7 2004-03-21 devnull srv = r->srv;
756 2277c5d7 2004-03-21 devnull assert(srv != nil);
758 39e5957a 2006-02-05 devnull if(r->responded){
759 39e5957a 2006-02-05 devnull assert(r->pool);
760 39e5957a 2006-02-05 devnull goto free;
763 2277c5d7 2004-03-21 devnull assert(r->responded == 0);
764 2277c5d7 2004-03-21 devnull r->error = error;
766 2277c5d7 2004-03-21 devnull switch(r->ifcall.type){
767 2277c5d7 2004-03-21 devnull default:
768 2277c5d7 2004-03-21 devnull assert(0);
770 2277c5d7 2004-03-21 devnull * Flush is special. If the handler says so, we return
771 2277c5d7 2004-03-21 devnull * without further processing. Respond will be called
772 2277c5d7 2004-03-21 devnull * again once it is safe.
774 2277c5d7 2004-03-21 devnull case Tflush:
775 2277c5d7 2004-03-21 devnull if(rflush(r, error)<0)
778 2277c5d7 2004-03-21 devnull case Tversion: rversion(r, error); break;
779 2277c5d7 2004-03-21 devnull case Tauth: rauth(r, error); break;
780 2277c5d7 2004-03-21 devnull case Tattach: rattach(r, error); break;
781 2277c5d7 2004-03-21 devnull case Twalk: rwalk(r, error); break;
782 2277c5d7 2004-03-21 devnull case Topen: ropen(r, error); break;
783 2277c5d7 2004-03-21 devnull case Tcreate: rcreate(r, error); break;
784 2277c5d7 2004-03-21 devnull case Tread: rread(r, error); break;
785 2277c5d7 2004-03-21 devnull case Twrite: rwrite(r, error); break;
786 2277c5d7 2004-03-21 devnull case Tclunk: rclunk(r, error); break;
787 2277c5d7 2004-03-21 devnull case Tremove: rremove(r, error, errbuf); break;
788 2277c5d7 2004-03-21 devnull case Tstat: rstat(r, error); break;
789 2277c5d7 2004-03-21 devnull case Twstat: rwstat(r, error); break;
792 2277c5d7 2004-03-21 devnull r->ofcall.tag = r->ifcall.tag;
793 2277c5d7 2004-03-21 devnull r->ofcall.type = r->ifcall.type+1;
794 2277c5d7 2004-03-21 devnull if(r->error)
795 2277c5d7 2004-03-21 devnull setfcallerror(&r->ofcall, r->error);
797 2277c5d7 2004-03-21 devnull if(chatty9p)
798 2277c5d7 2004-03-21 devnull fprint(2, "-%d-> %F\n", srv->outfd, &r->ofcall);
800 2277c5d7 2004-03-21 devnull qlock(&srv->wlock);
801 90c892d8 2006-01-27 devnull n = convS2Mu(&r->ofcall, srv->wbuf, srv->msize, srv->dotu);
802 2277c5d7 2004-03-21 devnull if(n <= 0){
803 2277c5d7 2004-03-21 devnull fprint(2, "n = %d %F\n", n, &r->ofcall);
804 2277c5d7 2004-03-21 devnull abort();
806 2277c5d7 2004-03-21 devnull assert(n > 2);
807 2277c5d7 2004-03-21 devnull if(r->pool) /* not a fake */
808 2277c5d7 2004-03-21 devnull closereq(removereq(r->pool, r->ifcall.tag));
809 2277c5d7 2004-03-21 devnull m = write(srv->outfd, srv->wbuf, n);
810 2277c5d7 2004-03-21 devnull if(m != n)
811 2277c5d7 2004-03-21 devnull sysfatal("lib9p srv: write %d returned %d on fd %d: %r", n, m, srv->outfd);
812 2277c5d7 2004-03-21 devnull qunlock(&srv->wlock);
815 2277c5d7 2004-03-21 devnull qlock(&r->lk); /* no one will add flushes now */
816 2277c5d7 2004-03-21 devnull r->responded = 1;
818 2277c5d7 2004-03-21 devnull for(i=0; i<r->nflush; i++)
819 2277c5d7 2004-03-21 devnull respond(r->flush[i], nil);
820 2277c5d7 2004-03-21 devnull free(r->flush);
821 39e5957a 2006-02-05 devnull r->nflush = 0;
822 39e5957a 2006-02-05 devnull r->flush = nil;
823 39e5957a 2006-02-05 devnull qunlock(&r->lk);
825 2277c5d7 2004-03-21 devnull if(r->pool)
826 2277c5d7 2004-03-21 devnull closereq(r);
828 2277c5d7 2004-03-21 devnull free(r);
832 2277c5d7 2004-03-21 devnull postfd(char *name, int pfd)
835 2277c5d7 2004-03-21 devnull char buf[80];
837 2277c5d7 2004-03-21 devnull snprint(buf, sizeof buf, "/srv/%s", name);
838 2277c5d7 2004-03-21 devnull if(chatty9p)
839 2277c5d7 2004-03-21 devnull fprint(2, "postfd %s\n", buf);
840 2277c5d7 2004-03-21 devnull fd = create(buf, OWRITE|ORCLOSE|OCEXEC, 0600);
841 2277c5d7 2004-03-21 devnull if(fd < 0){
842 2277c5d7 2004-03-21 devnull if(chatty9p)
843 2277c5d7 2004-03-21 devnull fprint(2, "create fails: %r\n");
844 2277c5d7 2004-03-21 devnull return -1;
846 2277c5d7 2004-03-21 devnull if(fprint(fd, "%d", pfd) < 0){
847 2277c5d7 2004-03-21 devnull if(chatty9p)
848 2277c5d7 2004-03-21 devnull fprint(2, "write fails: %r\n");
849 2277c5d7 2004-03-21 devnull close(fd);
850 2277c5d7 2004-03-21 devnull return -1;
852 2277c5d7 2004-03-21 devnull if(chatty9p)
853 2277c5d7 2004-03-21 devnull fprint(2, "postfd successful\n");
854 2277c5d7 2004-03-21 devnull return 0;