1 b8c14089 2003-11-23 devnull #include <u.h>
2 b8c14089 2003-11-23 devnull #include <libc.h>
3 b8c14089 2003-11-23 devnull #include <bio.h>
4 b8c14089 2003-11-23 devnull #include <regexp.h>
5 b8c14089 2003-11-23 devnull #include <thread.h>
6 b8c14089 2003-11-23 devnull #include <fcall.h>
7 b8c14089 2003-11-23 devnull #include <plumb.h>
8 b8c14089 2003-11-23 devnull #include "plumber.h"
12 32f69c36 2003-12-11 devnull Stack = 32*1024
15 b8c14089 2003-11-23 devnull typedef struct Dirtab Dirtab;
16 b8c14089 2003-11-23 devnull typedef struct Fid Fid;
17 b8c14089 2003-11-23 devnull typedef struct Holdq Holdq;
18 b8c14089 2003-11-23 devnull typedef struct Readreq Readreq;
19 b8c14089 2003-11-23 devnull typedef struct Sendreq Sendreq;
21 b8c14089 2003-11-23 devnull struct Dirtab
23 b8c14089 2003-11-23 devnull char *name;
24 b8c14089 2003-11-23 devnull uchar type;
25 b8c14089 2003-11-23 devnull uint qid;
26 b8c14089 2003-11-23 devnull uint perm;
27 b8c14089 2003-11-23 devnull int nopen; /* #fids open on this port */
28 b8c14089 2003-11-23 devnull Fid *fopen;
29 b8c14089 2003-11-23 devnull Holdq *holdq;
30 b8c14089 2003-11-23 devnull Readreq *readq;
31 b8c14089 2003-11-23 devnull Sendreq *sendq;
34 b8c14089 2003-11-23 devnull struct Fid
37 b8c14089 2003-11-23 devnull int busy;
38 b8c14089 2003-11-23 devnull int open;
39 b8c14089 2003-11-23 devnull int mode;
41 b8c14089 2003-11-23 devnull Dirtab *dir;
42 b8c14089 2003-11-23 devnull long offset; /* zeroed at beginning of each message, read or write */
43 b8c14089 2003-11-23 devnull char *writebuf; /* partial message written so far; offset tells how much */
44 b8c14089 2003-11-23 devnull Fid *next;
45 b8c14089 2003-11-23 devnull Fid *nextopen;
48 b8c14089 2003-11-23 devnull struct Readreq
50 b8c14089 2003-11-23 devnull Fid *fid;
51 b8c14089 2003-11-23 devnull Fcall *fcall;
52 b8c14089 2003-11-23 devnull uchar *buf;
53 b8c14089 2003-11-23 devnull Readreq *next;
56 b8c14089 2003-11-23 devnull struct Sendreq
58 b8c14089 2003-11-23 devnull int nfid; /* number of fids that should receive this message */
59 b8c14089 2003-11-23 devnull int nleft; /* number left that haven't received it */
60 b8c14089 2003-11-23 devnull Fid **fid; /* fid[nfid] */
61 b8c14089 2003-11-23 devnull Plumbmsg *msg;
62 b8c14089 2003-11-23 devnull char *pack; /* plumbpack()ed message */
63 b8c14089 2003-11-23 devnull int npack; /* length of pack */
64 b8c14089 2003-11-23 devnull Sendreq *next;
67 b8c14089 2003-11-23 devnull struct Holdq
69 b8c14089 2003-11-23 devnull Plumbmsg *msg;
70 b8c14089 2003-11-23 devnull Holdq *next;
73 b8c14089 2003-11-23 devnull struct /* needed because incref() doesn't return value */
77 b8c14089 2003-11-23 devnull } rulesref;
81 b8c14089 2003-11-23 devnull NDIR = 50,
82 b8c14089 2003-11-23 devnull Nhash = 16,
84 b8c14089 2003-11-23 devnull Qdir = 0,
85 b8c14089 2003-11-23 devnull Qrules = 1,
86 b8c14089 2003-11-23 devnull Qsend = 2,
87 b8c14089 2003-11-23 devnull Qport = 3,
88 b8c14089 2003-11-23 devnull NQID = Qport
91 b8c14089 2003-11-23 devnull static Dirtab dir[NDIR] =
93 b8c14089 2003-11-23 devnull { ".", QTDIR, Qdir, 0500|DMDIR },
94 b8c14089 2003-11-23 devnull { "rules", QTFILE, Qrules, 0600 },
95 cbeb0b26 2006-04-01 devnull { "send", QTFILE, Qsend, 0200 }
97 b8c14089 2003-11-23 devnull static int ndir = NQID;
99 b8c14089 2003-11-23 devnull static int srvfd;
100 8ad51794 2004-03-25 devnull #define clock plumbclock /* SunOS name clash */
101 b8c14089 2003-11-23 devnull static int clock;
102 b8c14089 2003-11-23 devnull static Fid *fids[Nhash];
103 b8c14089 2003-11-23 devnull static QLock readlock;
104 b8c14089 2003-11-23 devnull static QLock queue;
105 b8c14089 2003-11-23 devnull static int messagesize = 8192+IOHDRSZ; /* good start */
107 b8c14089 2003-11-23 devnull static void fsysproc(void*);
108 b8c14089 2003-11-23 devnull static void fsysrespond(Fcall*, uchar*, char*);
109 b8c14089 2003-11-23 devnull static Fid* newfid(int);
111 b8c14089 2003-11-23 devnull static Fcall* fsysflush(Fcall*, uchar*, Fid*);
112 b8c14089 2003-11-23 devnull static Fcall* fsysversion(Fcall*, uchar*, Fid*);
113 b8c14089 2003-11-23 devnull static Fcall* fsysauth(Fcall*, uchar*, Fid*);
114 b8c14089 2003-11-23 devnull static Fcall* fsysattach(Fcall*, uchar*, Fid*);
115 b8c14089 2003-11-23 devnull static Fcall* fsyswalk(Fcall*, uchar*, Fid*);
116 b8c14089 2003-11-23 devnull static Fcall* fsysopen(Fcall*, uchar*, Fid*);
117 b8c14089 2003-11-23 devnull static Fcall* fsyscreate(Fcall*, uchar*, Fid*);
118 b8c14089 2003-11-23 devnull static Fcall* fsysread(Fcall*, uchar*, Fid*);
119 b8c14089 2003-11-23 devnull static Fcall* fsyswrite(Fcall*, uchar*, Fid*);
120 b8c14089 2003-11-23 devnull static Fcall* fsysclunk(Fcall*, uchar*, Fid*);
121 b8c14089 2003-11-23 devnull static Fcall* fsysremove(Fcall*, uchar*, Fid*);
122 b8c14089 2003-11-23 devnull static Fcall* fsysstat(Fcall*, uchar*, Fid*);
123 b8c14089 2003-11-23 devnull static Fcall* fsyswstat(Fcall*, uchar*, Fid*);
125 be22ae2d 2004-03-26 devnull Fcall* (*fcall[Tmax])(Fcall*, uchar*, Fid*);
127 be22ae2d 2004-03-26 devnull static void
128 be22ae2d 2004-03-26 devnull initfcall(void)
130 be22ae2d 2004-03-26 devnull fcall[Tflush] = fsysflush;
131 be22ae2d 2004-03-26 devnull fcall[Tversion] = fsysversion;
132 be22ae2d 2004-03-26 devnull fcall[Tauth] = fsysauth;
133 be22ae2d 2004-03-26 devnull fcall[Tattach] = fsysattach;
134 be22ae2d 2004-03-26 devnull fcall[Twalk] = fsyswalk;
135 be22ae2d 2004-03-26 devnull fcall[Topen] = fsysopen;
136 be22ae2d 2004-03-26 devnull fcall[Tcreate] = fsyscreate;
137 be22ae2d 2004-03-26 devnull fcall[Tread] = fsysread;
138 be22ae2d 2004-03-26 devnull fcall[Twrite] = fsyswrite;
139 be22ae2d 2004-03-26 devnull fcall[Tclunk] = fsysclunk;
140 be22ae2d 2004-03-26 devnull fcall[Tremove]= fsysremove;
141 be22ae2d 2004-03-26 devnull fcall[Tstat] = fsysstat;
142 be22ae2d 2004-03-26 devnull fcall[Twstat] = fsyswstat;
145 b8c14089 2003-11-23 devnull char Ebadfcall[] = "bad fcall type";
146 b8c14089 2003-11-23 devnull char Eperm[] = "permission denied";
147 b8c14089 2003-11-23 devnull char Enomem[] = "malloc failed for buffer";
148 b8c14089 2003-11-23 devnull char Enotdir[] = "not a directory";
149 b8c14089 2003-11-23 devnull char Enoexist[] = "plumb file does not exist";
150 b8c14089 2003-11-23 devnull char Eisdir[] = "file is a directory";
151 b8c14089 2003-11-23 devnull char Ebadmsg[] = "bad plumb message format";
152 b8c14089 2003-11-23 devnull char Enosuchport[] ="no such plumb port";
153 b8c14089 2003-11-23 devnull char Enoport[] = "couldn't find destination for message";
154 b8c14089 2003-11-23 devnull char Einuse[] = "file already open";
157 b8c14089 2003-11-23 devnull * Add new port. A no-op if port already exists or is the null string
160 b8c14089 2003-11-23 devnull addport(char *port)
164 b8c14089 2003-11-23 devnull if(port == nil)
166 b8c14089 2003-11-23 devnull for(i=NQID; i<ndir; i++)
167 b8c14089 2003-11-23 devnull if(strcmp(port, dir[i].name) == 0)
169 b8c14089 2003-11-23 devnull if(i == NDIR){
170 b8c14089 2003-11-23 devnull fprint(2, "plumb: too many ports; max %d\n", NDIR);
174 b8c14089 2003-11-23 devnull dir[i].name = estrdup(port);
175 b8c14089 2003-11-23 devnull dir[i].qid = i;
176 b8c14089 2003-11-23 devnull dir[i].perm = 0400;
177 b8c14089 2003-11-23 devnull nports++;
178 b8c14089 2003-11-23 devnull ports = erealloc(ports, nports*sizeof(char*));
179 b8c14089 2003-11-23 devnull ports[nports-1] = dir[i].name;
182 b8c14089 2003-11-23 devnull static ulong
183 b8c14089 2003-11-23 devnull getclock(void)
185 32f69c36 2003-12-11 devnull return time(0);
189 b0aecb4b 2019-10-29 crossd startfsys(int foreground)
191 32f69c36 2003-12-11 devnull int p[2];
193 b8c14089 2003-11-23 devnull fmtinstall('F', fcallfmt);
194 b8c14089 2003-11-23 devnull clock = getclock();
195 b8c14089 2003-11-23 devnull if(pipe(p) < 0)
196 b8c14089 2003-11-23 devnull error("can't create pipe: %r");
197 b8c14089 2003-11-23 devnull /* 0 will be server end, 1 will be client end */
198 b8c14089 2003-11-23 devnull srvfd = p[0];
199 7db5826d 2008-04-17 rsc if(post9pservice(p[1], "plumb", nil) < 0)
200 32f69c36 2003-12-11 devnull sysfatal("post9pservice plumb: %r");
201 b8c14089 2003-11-23 devnull close(p[1]);
202 b0aecb4b 2019-10-29 crossd if(foreground)
203 b0aecb4b 2019-10-29 crossd fsysproc(nil);
205 b0aecb4b 2019-10-29 crossd proccreate(fsysproc, nil, Stack);
208 b8c14089 2003-11-23 devnull static void
209 32f69c36 2003-12-11 devnull fsysproc(void *v)
212 b8c14089 2003-11-23 devnull Fcall *t;
214 b8c14089 2003-11-23 devnull uchar *buf;
216 32f69c36 2003-12-11 devnull USED(v);
217 be22ae2d 2004-03-26 devnull initfcall();
218 b8c14089 2003-11-23 devnull t = nil;
219 b8c14089 2003-11-23 devnull for(;;){
220 b8c14089 2003-11-23 devnull buf = malloc(messagesize); /* avoid memset of emalloc */
221 b8c14089 2003-11-23 devnull if(buf == nil)
222 b8c14089 2003-11-23 devnull error("malloc failed: %r");
223 b8c14089 2003-11-23 devnull qlock(&readlock);
224 f9979097 2004-12-26 devnull n = read9pmsg(srvfd, buf, messagesize);
225 b8c14089 2003-11-23 devnull if(n <= 0){
226 b8c14089 2003-11-23 devnull if(n < 0)
227 b8c14089 2003-11-23 devnull error("i/o error on server channel");
228 b8c14089 2003-11-23 devnull threadexitsall("unmounted");
231 f9979097 2004-12-26 devnull * can give false positive (create an extra fsysproc) once in a while,
232 f9979097 2004-12-26 devnull * but no false negatives, so good enough. once we have one extra
233 f9979097 2004-12-26 devnull * we'll never have more.
235 f9979097 2004-12-26 devnull if(readlock.waiting.head == nil) /* no other processes waiting to read; start one */
236 f9979097 2004-12-26 devnull proccreate(fsysproc, nil, Stack);
237 b8c14089 2003-11-23 devnull qunlock(&readlock);
238 b8c14089 2003-11-23 devnull if(t == nil)
239 b8c14089 2003-11-23 devnull t = emalloc(sizeof(Fcall));
240 b8c14089 2003-11-23 devnull if(convM2S(buf, n, t) != n)
241 b8c14089 2003-11-23 devnull error("convert error in convM2S");
242 32f69c36 2003-12-11 devnull if(debug)
243 b8c14089 2003-11-23 devnull fprint(2, "<= %F\n", t);
244 a8763864 2004-07-09 devnull if(fcall[t->type] == 0)
245 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Ebadfcall);
247 b8c14089 2003-11-23 devnull if(t->type==Tversion || t->type==Tauth)
248 b8c14089 2003-11-23 devnull f = nil;
250 b8c14089 2003-11-23 devnull f = newfid(t->fid);
251 b8c14089 2003-11-23 devnull t = (*fcall[t->type])(t, buf, f);
256 b8c14089 2003-11-23 devnull static void
257 b8c14089 2003-11-23 devnull fsysrespond(Fcall *t, uchar *buf, char *err)
261 b8c14089 2003-11-23 devnull if(err){
262 b8c14089 2003-11-23 devnull t->type = Rerror;
263 b8c14089 2003-11-23 devnull t->ename = err;
265 b8c14089 2003-11-23 devnull t->type++;
266 b8c14089 2003-11-23 devnull if(buf == nil)
267 b8c14089 2003-11-23 devnull buf = emalloc(messagesize);
268 b8c14089 2003-11-23 devnull n = convS2M(t, buf, messagesize);
269 b8c14089 2003-11-23 devnull if(n < 0)
270 b8c14089 2003-11-23 devnull error("convert error in convS2M");
271 b8c14089 2003-11-23 devnull if(write(srvfd, buf, n) != n)
272 b8c14089 2003-11-23 devnull error("write error in respond");
273 32f69c36 2003-12-11 devnull if(debug)
274 b8c14089 2003-11-23 devnull fprint(2, "=> %F\n", t);
275 b8c14089 2003-11-23 devnull free(buf);
280 b8c14089 2003-11-23 devnull newfid(int fid)
282 b8c14089 2003-11-23 devnull Fid *f, *ff, **fh;
284 b8c14089 2003-11-23 devnull qlock(&queue);
285 b8c14089 2003-11-23 devnull ff = nil;
286 b8c14089 2003-11-23 devnull fh = &fids[fid&(Nhash-1)];
287 b8c14089 2003-11-23 devnull for(f=*fh; f; f=f->next)
288 b8c14089 2003-11-23 devnull if(f->fid == fid)
289 b8c14089 2003-11-23 devnull goto Return;
290 b8c14089 2003-11-23 devnull else if(ff==nil && !f->busy)
293 b8c14089 2003-11-23 devnull ff->fid = fid;
295 b8c14089 2003-11-23 devnull goto Return;
297 b8c14089 2003-11-23 devnull f = emalloc(sizeof *f);
298 b8c14089 2003-11-23 devnull f->fid = fid;
299 b8c14089 2003-11-23 devnull f->next = *fh;
300 b8c14089 2003-11-23 devnull *fh = f;
302 b8c14089 2003-11-23 devnull qunlock(&queue);
303 b8c14089 2003-11-23 devnull return f;
306 b8c14089 2003-11-23 devnull static uint
307 b8c14089 2003-11-23 devnull dostat(Dirtab *dir, uchar *buf, uint nbuf, uint clock)
311 b8c14089 2003-11-23 devnull d.qid.type = dir->type;
312 b8c14089 2003-11-23 devnull d.qid.path = dir->qid;
313 b8c14089 2003-11-23 devnull d.qid.vers = 0;
314 b8c14089 2003-11-23 devnull d.mode = dir->perm;
315 b8c14089 2003-11-23 devnull d.length = 0; /* would be nice to do better */
316 b8c14089 2003-11-23 devnull d.name = dir->name;
317 b8c14089 2003-11-23 devnull d.uid = user;
318 b8c14089 2003-11-23 devnull d.gid = user;
319 b8c14089 2003-11-23 devnull d.muid = user;
320 b8c14089 2003-11-23 devnull d.atime = clock;
321 b8c14089 2003-11-23 devnull d.mtime = clock;
322 b8c14089 2003-11-23 devnull return convD2M(&d, buf, nbuf);
325 b8c14089 2003-11-23 devnull static void
326 b8c14089 2003-11-23 devnull queuesend(Dirtab *d, Plumbmsg *m)
328 b8c14089 2003-11-23 devnull Sendreq *s, *t;
332 b8c14089 2003-11-23 devnull s = emalloc(sizeof(Sendreq));
333 b8c14089 2003-11-23 devnull s->nfid = d->nopen;
334 b8c14089 2003-11-23 devnull s->nleft = s->nfid;
335 b8c14089 2003-11-23 devnull s->fid = emalloc(s->nfid*sizeof(Fid*));
337 b8c14089 2003-11-23 devnull /* build array of fids open on this channel */
338 b8c14089 2003-11-23 devnull for(f=d->fopen; f!=nil; f=f->nextopen)
339 b8c14089 2003-11-23 devnull s->fid[i++] = f;
340 b8c14089 2003-11-23 devnull s->msg = m;
341 b8c14089 2003-11-23 devnull s->next = nil;
342 b8c14089 2003-11-23 devnull /* link to end of queue; drainqueue() searches in sender order so this implements a FIFO */
343 b8c14089 2003-11-23 devnull for(t=d->sendq; t!=nil; t=t->next)
344 b8c14089 2003-11-23 devnull if(t->next == nil)
346 b8c14089 2003-11-23 devnull if(t == nil)
347 b8c14089 2003-11-23 devnull d->sendq = s;
349 b8c14089 2003-11-23 devnull t->next = s;
352 b8c14089 2003-11-23 devnull static void
353 b8c14089 2003-11-23 devnull queueread(Dirtab *d, Fcall *t, uchar *buf, Fid *f)
355 b8c14089 2003-11-23 devnull Readreq *r;
357 b8c14089 2003-11-23 devnull r = emalloc(sizeof(Readreq));
358 b8c14089 2003-11-23 devnull r->fcall = t;
359 b8c14089 2003-11-23 devnull r->buf = buf;
360 b8c14089 2003-11-23 devnull r->fid = f;
361 b8c14089 2003-11-23 devnull r->next = d->readq;
362 b8c14089 2003-11-23 devnull d->readq = r;
365 b8c14089 2003-11-23 devnull static void
366 b8c14089 2003-11-23 devnull drainqueue(Dirtab *d)
368 b8c14089 2003-11-23 devnull Readreq *r, *nextr, *prevr;
369 b8c14089 2003-11-23 devnull Sendreq *s, *nexts, *prevs;
370 b8c14089 2003-11-23 devnull int i, n;
372 b8c14089 2003-11-23 devnull prevs = nil;
373 b8c14089 2003-11-23 devnull for(s=d->sendq; s!=nil; s=nexts){
374 b8c14089 2003-11-23 devnull nexts = s->next;
375 b8c14089 2003-11-23 devnull for(i=0; i<s->nfid; i++){
376 b8c14089 2003-11-23 devnull prevr = nil;
377 b8c14089 2003-11-23 devnull for(r=d->readq; r!=nil; r=nextr){
378 b8c14089 2003-11-23 devnull nextr = r->next;
379 b8c14089 2003-11-23 devnull if(r->fid == s->fid[i]){
380 b8c14089 2003-11-23 devnull /* pack the message if necessary */
381 b8c14089 2003-11-23 devnull if(s->pack == nil)
382 b8c14089 2003-11-23 devnull s->pack = plumbpack(s->msg, &s->npack);
383 b8c14089 2003-11-23 devnull /* exchange the stuff... */
384 b8c14089 2003-11-23 devnull r->fcall->data = s->pack+r->fid->offset;
385 b8c14089 2003-11-23 devnull n = s->npack - r->fid->offset;
386 b8c14089 2003-11-23 devnull if(n > messagesize-IOHDRSZ)
387 b8c14089 2003-11-23 devnull n = messagesize-IOHDRSZ;
388 b8c14089 2003-11-23 devnull if(n > r->fcall->count)
389 b8c14089 2003-11-23 devnull n = r->fcall->count;
390 b8c14089 2003-11-23 devnull r->fcall->count = n;
391 b8c14089 2003-11-23 devnull fsysrespond(r->fcall, r->buf, nil);
392 b8c14089 2003-11-23 devnull r->fid->offset += n;
393 b8c14089 2003-11-23 devnull if(r->fid->offset >= s->npack){
394 b8c14089 2003-11-23 devnull /* message transferred; delete this fid from send queue */
395 b8c14089 2003-11-23 devnull r->fid->offset = 0;
396 b8c14089 2003-11-23 devnull s->fid[i] = nil;
397 b8c14089 2003-11-23 devnull s->nleft--;
399 b8c14089 2003-11-23 devnull /* delete read request from queue */
400 b8c14089 2003-11-23 devnull if(prevr)
401 b8c14089 2003-11-23 devnull prevr->next = r->next;
403 b8c14089 2003-11-23 devnull d->readq = r->next;
404 b8c14089 2003-11-23 devnull free(r->fcall);
405 b8c14089 2003-11-23 devnull free(r);
408 b8c14089 2003-11-23 devnull prevr = r;
411 b8c14089 2003-11-23 devnull /* if no fids left, delete this send from queue */
412 b8c14089 2003-11-23 devnull if(s->nleft == 0){
413 b8c14089 2003-11-23 devnull free(s->fid);
414 b8c14089 2003-11-23 devnull plumbfree(s->msg);
415 b8c14089 2003-11-23 devnull free(s->pack);
416 b8c14089 2003-11-23 devnull if(prevs)
417 b8c14089 2003-11-23 devnull prevs->next = s->next;
419 b8c14089 2003-11-23 devnull d->sendq = s->next;
420 b8c14089 2003-11-23 devnull free(s);
422 b8c14089 2003-11-23 devnull prevs = s;
426 b8c14089 2003-11-23 devnull /* can't flush a send because they are always answered synchronously */
427 b8c14089 2003-11-23 devnull static void
428 b8c14089 2003-11-23 devnull flushqueue(Dirtab *d, int oldtag)
430 b8c14089 2003-11-23 devnull Readreq *r, *prevr;
432 b8c14089 2003-11-23 devnull prevr = nil;
433 b8c14089 2003-11-23 devnull for(r=d->readq; r!=nil; r=r->next){
434 b8c14089 2003-11-23 devnull if(oldtag == r->fcall->tag){
435 b8c14089 2003-11-23 devnull /* delete read request from queue */
436 b8c14089 2003-11-23 devnull if(prevr)
437 b8c14089 2003-11-23 devnull prevr->next = r->next;
439 b8c14089 2003-11-23 devnull d->readq = r->next;
440 b8c14089 2003-11-23 devnull free(r->fcall);
441 b8c14089 2003-11-23 devnull free(r->buf);
442 b8c14089 2003-11-23 devnull free(r);
445 b8c14089 2003-11-23 devnull prevr = r;
449 b8c14089 2003-11-23 devnull /* remove messages awaiting delivery to now-closing fid */
450 b8c14089 2003-11-23 devnull static void
451 b8c14089 2003-11-23 devnull removesenders(Dirtab *d, Fid *fid)
453 b8c14089 2003-11-23 devnull Sendreq *s, *nexts, *prevs;
456 b8c14089 2003-11-23 devnull prevs = nil;
457 b8c14089 2003-11-23 devnull for(s=d->sendq; s!=nil; s=nexts){
458 b8c14089 2003-11-23 devnull nexts = s->next;
459 b8c14089 2003-11-23 devnull for(i=0; i<s->nfid; i++)
460 b8c14089 2003-11-23 devnull if(fid == s->fid[i]){
461 b8c14089 2003-11-23 devnull /* delete this fid from send queue */
462 b8c14089 2003-11-23 devnull s->fid[i] = nil;
463 b8c14089 2003-11-23 devnull s->nleft--;
466 b8c14089 2003-11-23 devnull /* if no fids left, delete this send from queue */
467 b8c14089 2003-11-23 devnull if(s->nleft == 0){
468 b8c14089 2003-11-23 devnull free(s->fid);
469 b8c14089 2003-11-23 devnull plumbfree(s->msg);
470 b8c14089 2003-11-23 devnull free(s->pack);
471 b8c14089 2003-11-23 devnull if(prevs)
472 b8c14089 2003-11-23 devnull prevs->next = s->next;
474 b8c14089 2003-11-23 devnull d->sendq = s->next;
475 b8c14089 2003-11-23 devnull free(s);
477 b8c14089 2003-11-23 devnull prevs = s;
481 b8c14089 2003-11-23 devnull static void
482 b8c14089 2003-11-23 devnull hold(Plumbmsg *m, Dirtab *d)
484 b8c14089 2003-11-23 devnull Holdq *h, *q;
486 b8c14089 2003-11-23 devnull h = emalloc(sizeof(Holdq));
487 b8c14089 2003-11-23 devnull h->msg = m;
488 b8c14089 2003-11-23 devnull /* add to end of queue */
489 b8c14089 2003-11-23 devnull if(d->holdq == nil)
490 b8c14089 2003-11-23 devnull d->holdq = h;
492 b8c14089 2003-11-23 devnull for(q=d->holdq; q->next!=nil; q=q->next)
494 b8c14089 2003-11-23 devnull q->next = h;
498 b8c14089 2003-11-23 devnull static void
499 b8c14089 2003-11-23 devnull queueheld(Dirtab *d)
501 b8c14089 2003-11-23 devnull Holdq *h;
503 b8c14089 2003-11-23 devnull while(d->holdq != nil){
504 b8c14089 2003-11-23 devnull h = d->holdq;
505 b8c14089 2003-11-23 devnull d->holdq = h->next;
506 b8c14089 2003-11-23 devnull queuesend(d, h->msg);
507 b8c14089 2003-11-23 devnull /* no need to drain queue because we know no-one is reading yet */
508 b8c14089 2003-11-23 devnull free(h);
512 b8c14089 2003-11-23 devnull static void
513 b8c14089 2003-11-23 devnull dispose(Fcall *t, uchar *buf, Plumbmsg *m, Ruleset *rs, Exec *e)
516 b8c14089 2003-11-23 devnull char *err;
518 b8c14089 2003-11-23 devnull qlock(&queue);
519 b8c14089 2003-11-23 devnull err = nil;
520 b8c14089 2003-11-23 devnull if(m->dst==nil || m->dst[0]=='\0'){
521 b8c14089 2003-11-23 devnull err = Enoport;
522 b8c14089 2003-11-23 devnull if(rs != nil)
523 b8c14089 2003-11-23 devnull err = startup(rs, e);
524 b8c14089 2003-11-23 devnull plumbfree(m);
526 b8c14089 2003-11-23 devnull for(i=NQID; i<ndir; i++)
527 b8c14089 2003-11-23 devnull if(strcmp(m->dst, dir[i].name) == 0){
528 b8c14089 2003-11-23 devnull if(dir[i].nopen == 0){
529 b8c14089 2003-11-23 devnull err = startup(rs, e);
530 b8c14089 2003-11-23 devnull if(e!=nil && e->holdforclient)
531 b8c14089 2003-11-23 devnull hold(m, &dir[i]);
533 b8c14089 2003-11-23 devnull plumbfree(m);
535 b8c14089 2003-11-23 devnull queuesend(&dir[i], m);
536 b8c14089 2003-11-23 devnull drainqueue(&dir[i]);
540 b8c14089 2003-11-23 devnull freeexec(e);
541 b8c14089 2003-11-23 devnull qunlock(&queue);
542 b8c14089 2003-11-23 devnull fsysrespond(t, buf, err);
543 b8c14089 2003-11-23 devnull free(t);
546 b8c14089 2003-11-23 devnull static Fcall*
547 32f69c36 2003-12-11 devnull fsysversion(Fcall *t, uchar *buf, Fid *fid)
549 32f69c36 2003-12-11 devnull USED(fid);
551 b8c14089 2003-11-23 devnull if(t->msize < 256){
552 b8c14089 2003-11-23 devnull fsysrespond(t, buf, "version: message size too small");
553 b8c14089 2003-11-23 devnull return t;
555 b8c14089 2003-11-23 devnull if(t->msize < messagesize)
556 b8c14089 2003-11-23 devnull messagesize = t->msize;
557 b8c14089 2003-11-23 devnull t->msize = messagesize;
558 b8c14089 2003-11-23 devnull if(strncmp(t->version, "9P2000", 6) != 0){
559 b8c14089 2003-11-23 devnull fsysrespond(t, buf, "unrecognized 9P version");
560 b8c14089 2003-11-23 devnull return t;
562 b8c14089 2003-11-23 devnull t->version = "9P2000";
563 b8c14089 2003-11-23 devnull fsysrespond(t, buf, nil);
564 b8c14089 2003-11-23 devnull return t;
567 b8c14089 2003-11-23 devnull static Fcall*
568 32f69c36 2003-12-11 devnull fsysauth(Fcall *t, uchar *buf, Fid *fid)
570 32f69c36 2003-12-11 devnull USED(fid);
571 b8c14089 2003-11-23 devnull fsysrespond(t, buf, "plumber: authentication not required");
572 b8c14089 2003-11-23 devnull return t;
575 b8c14089 2003-11-23 devnull static Fcall*
576 b8c14089 2003-11-23 devnull fsysattach(Fcall *t, uchar *buf, Fid *f)
578 b8c14089 2003-11-23 devnull Fcall out;
581 b8c14089 2003-11-23 devnull if(strcmp(t->uname, user) != 0){
582 b8c14089 2003-11-23 devnull fsysrespond(&out, buf, Eperm);
583 b8c14089 2003-11-23 devnull return t;
586 b8c14089 2003-11-23 devnull f->busy = 1;
587 b8c14089 2003-11-23 devnull f->open = 0;
588 b8c14089 2003-11-23 devnull f->qid.type = QTDIR;
589 b8c14089 2003-11-23 devnull f->qid.path = Qdir;
590 b8c14089 2003-11-23 devnull f->qid.vers = 0;
591 b8c14089 2003-11-23 devnull f->dir = dir;
592 b8c14089 2003-11-23 devnull memset(&out, 0, sizeof(Fcall));
593 b8c14089 2003-11-23 devnull out.type = t->type;
594 b8c14089 2003-11-23 devnull out.tag = t->tag;
595 b8c14089 2003-11-23 devnull out.fid = f->fid;
596 b8c14089 2003-11-23 devnull out.qid = f->qid;
597 b8c14089 2003-11-23 devnull fsysrespond(&out, buf, nil);
598 b8c14089 2003-11-23 devnull return t;
601 b8c14089 2003-11-23 devnull static Fcall*
602 32f69c36 2003-12-11 devnull fsysflush(Fcall *t, uchar *buf, Fid *fid)
606 32f69c36 2003-12-11 devnull USED(fid);
607 b8c14089 2003-11-23 devnull qlock(&queue);
608 b8c14089 2003-11-23 devnull for(i=NQID; i<ndir; i++)
609 b8c14089 2003-11-23 devnull flushqueue(&dir[i], t->oldtag);
610 b8c14089 2003-11-23 devnull qunlock(&queue);
611 b8c14089 2003-11-23 devnull fsysrespond(t, buf, nil);
612 b8c14089 2003-11-23 devnull return t;
615 b8c14089 2003-11-23 devnull static Fcall*
616 b8c14089 2003-11-23 devnull fsyswalk(Fcall *t, uchar *buf, Fid *f)
618 b8c14089 2003-11-23 devnull Fcall out;
619 b8c14089 2003-11-23 devnull Fid *nf;
620 b8c14089 2003-11-23 devnull ulong path;
621 b8c14089 2003-11-23 devnull Dirtab *d, *dir;
624 b8c14089 2003-11-23 devnull uchar type;
625 b8c14089 2003-11-23 devnull char *err;
627 b8c14089 2003-11-23 devnull if(f->open){
628 b8c14089 2003-11-23 devnull fsysrespond(t, buf, "clone of an open fid");
629 b8c14089 2003-11-23 devnull return t;
632 b8c14089 2003-11-23 devnull nf = nil;
633 b8c14089 2003-11-23 devnull if(t->fid != t->newfid){
634 b8c14089 2003-11-23 devnull nf = newfid(t->newfid);
635 b8c14089 2003-11-23 devnull if(nf->busy){
636 b8c14089 2003-11-23 devnull fsysrespond(t, buf, "clone to a busy fid");
637 b8c14089 2003-11-23 devnull return t;
639 b8c14089 2003-11-23 devnull nf->busy = 1;
640 b8c14089 2003-11-23 devnull nf->open = 0;
641 b8c14089 2003-11-23 devnull nf->dir = f->dir;
642 b8c14089 2003-11-23 devnull nf->qid = f->qid;
643 b8c14089 2003-11-23 devnull f = nf; /* walk f */
646 b8c14089 2003-11-23 devnull out.nwqid = 0;
647 b8c14089 2003-11-23 devnull err = nil;
648 b8c14089 2003-11-23 devnull dir = f->dir;
649 b8c14089 2003-11-23 devnull q = f->qid;
651 b8c14089 2003-11-23 devnull if(t->nwname > 0){
652 b8c14089 2003-11-23 devnull for(i=0; i<t->nwname; i++){
653 b8c14089 2003-11-23 devnull if((q.type & QTDIR) == 0){
654 b8c14089 2003-11-23 devnull err = Enotdir;
657 b8c14089 2003-11-23 devnull if(strcmp(t->wname[i], "..") == 0){
658 b8c14089 2003-11-23 devnull type = QTDIR;
659 b8c14089 2003-11-23 devnull path = Qdir;
661 b8c14089 2003-11-23 devnull q.type = type;
662 b8c14089 2003-11-23 devnull q.vers = 0;
663 b8c14089 2003-11-23 devnull q.path = path;
664 b8c14089 2003-11-23 devnull out.wqid[out.nwqid++] = q;
665 b8c14089 2003-11-23 devnull continue;
667 b8c14089 2003-11-23 devnull d = dir;
668 b8c14089 2003-11-23 devnull d++; /* skip '.' */
669 b8c14089 2003-11-23 devnull for(; d->name; d++)
670 b8c14089 2003-11-23 devnull if(strcmp(t->wname[i], d->name) == 0){
671 b8c14089 2003-11-23 devnull type = d->type;
672 b8c14089 2003-11-23 devnull path = d->qid;
673 b8c14089 2003-11-23 devnull dir = d;
674 b8c14089 2003-11-23 devnull goto Accept;
676 b8c14089 2003-11-23 devnull err = Enoexist;
681 b8c14089 2003-11-23 devnull out.type = t->type;
682 b8c14089 2003-11-23 devnull out.tag = t->tag;
683 b8c14089 2003-11-23 devnull if(err!=nil || out.nwqid<t->nwname){
685 b8c14089 2003-11-23 devnull nf->busy = 0;
686 b8c14089 2003-11-23 devnull }else if(out.nwqid == t->nwname){
687 b8c14089 2003-11-23 devnull f->qid = q;
688 b8c14089 2003-11-23 devnull f->dir = dir;
691 b8c14089 2003-11-23 devnull fsysrespond(&out, buf, err);
692 b8c14089 2003-11-23 devnull return t;
695 b8c14089 2003-11-23 devnull static Fcall*
696 b8c14089 2003-11-23 devnull fsysopen(Fcall *t, uchar *buf, Fid *f)
698 b8c14089 2003-11-23 devnull int m, clearrules, mode;
700 b8c14089 2003-11-23 devnull clearrules = 0;
701 b8c14089 2003-11-23 devnull if(t->mode & OTRUNC){
702 b8c14089 2003-11-23 devnull if(f->qid.path != Qrules)
703 b8c14089 2003-11-23 devnull goto Deny;
704 b8c14089 2003-11-23 devnull clearrules = 1;
706 b8c14089 2003-11-23 devnull /* can't truncate anything, so just disregard */
707 b8c14089 2003-11-23 devnull mode = t->mode & ~(OTRUNC|OCEXEC);
708 b8c14089 2003-11-23 devnull /* can't execute or remove anything */
709 b8c14089 2003-11-23 devnull if(mode==OEXEC || (mode&ORCLOSE))
710 b8c14089 2003-11-23 devnull goto Deny;
711 b8c14089 2003-11-23 devnull switch(mode){
712 b8c14089 2003-11-23 devnull default:
713 b8c14089 2003-11-23 devnull goto Deny;
714 b8c14089 2003-11-23 devnull case OREAD:
715 b8c14089 2003-11-23 devnull m = 0400;
717 b8c14089 2003-11-23 devnull case OWRITE:
718 b8c14089 2003-11-23 devnull m = 0200;
720 b8c14089 2003-11-23 devnull case ORDWR:
721 b8c14089 2003-11-23 devnull m = 0600;
724 b8c14089 2003-11-23 devnull if(((f->dir->perm&~(DMDIR|DMAPPEND))&m) != m)
725 b8c14089 2003-11-23 devnull goto Deny;
726 b8c14089 2003-11-23 devnull if(f->qid.path==Qrules && (mode==OWRITE || mode==ORDWR)){
727 32f69c36 2003-12-11 devnull lock(&rulesref.lk);
728 b8c14089 2003-11-23 devnull if(rulesref.ref++ != 0){
729 b8c14089 2003-11-23 devnull rulesref.ref--;
730 32f69c36 2003-12-11 devnull unlock(&rulesref.lk);
731 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Einuse);
732 b8c14089 2003-11-23 devnull return t;
734 32f69c36 2003-12-11 devnull unlock(&rulesref.lk);
736 b8c14089 2003-11-23 devnull if(clearrules){
737 b8c14089 2003-11-23 devnull writerules(nil, 0);
738 b8c14089 2003-11-23 devnull rules[0] = nil;
740 b8c14089 2003-11-23 devnull t->qid = f->qid;
741 b8c14089 2003-11-23 devnull t->iounit = 0;
742 b8c14089 2003-11-23 devnull qlock(&queue);
743 b8c14089 2003-11-23 devnull f->mode = mode;
744 b8c14089 2003-11-23 devnull f->open = 1;
745 b8c14089 2003-11-23 devnull f->dir->nopen++;
746 b8c14089 2003-11-23 devnull f->nextopen = f->dir->fopen;
747 b8c14089 2003-11-23 devnull f->dir->fopen = f;
748 b8c14089 2003-11-23 devnull queueheld(f->dir);
749 b8c14089 2003-11-23 devnull qunlock(&queue);
750 b8c14089 2003-11-23 devnull fsysrespond(t, buf, nil);
751 b8c14089 2003-11-23 devnull return t;
754 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Eperm);
755 b8c14089 2003-11-23 devnull return t;
758 b8c14089 2003-11-23 devnull static Fcall*
759 32f69c36 2003-12-11 devnull fsyscreate(Fcall *t, uchar *buf, Fid *fid)
761 32f69c36 2003-12-11 devnull USED(fid);
762 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Eperm);
763 b8c14089 2003-11-23 devnull return t;
766 b8c14089 2003-11-23 devnull static Fcall*
767 b8c14089 2003-11-23 devnull fsysreadrules(Fcall *t, uchar *buf)
769 b8c14089 2003-11-23 devnull char *p;
772 b8c14089 2003-11-23 devnull p = printrules();
773 b8c14089 2003-11-23 devnull n = strlen(p);
774 b8c14089 2003-11-23 devnull t->data = p;
775 b8c14089 2003-11-23 devnull if(t->offset >= n)
776 b8c14089 2003-11-23 devnull t->count = 0;
778 b8c14089 2003-11-23 devnull t->data = p+t->offset;
779 b8c14089 2003-11-23 devnull if(t->offset+t->count > n)
780 b8c14089 2003-11-23 devnull t->count = n-t->offset;
782 b8c14089 2003-11-23 devnull fsysrespond(t, buf, nil);
783 b8c14089 2003-11-23 devnull free(p);
784 b8c14089 2003-11-23 devnull return t;
787 b8c14089 2003-11-23 devnull static Fcall*
788 b8c14089 2003-11-23 devnull fsysread(Fcall *t, uchar *buf, Fid *f)
790 b8c14089 2003-11-23 devnull uchar *b;
791 b8c14089 2003-11-23 devnull int i, n, o, e;
792 b8c14089 2003-11-23 devnull uint len;
793 b8c14089 2003-11-23 devnull Dirtab *d;
794 b8c14089 2003-11-23 devnull uint clock;
796 b8c14089 2003-11-23 devnull if(f->qid.path != Qdir){
797 b8c14089 2003-11-23 devnull if(f->qid.path == Qrules)
798 b8c14089 2003-11-23 devnull return fsysreadrules(t, buf);
799 b8c14089 2003-11-23 devnull /* read from port */
800 b8c14089 2003-11-23 devnull if(f->qid.path < NQID){
801 b8c14089 2003-11-23 devnull fsysrespond(t, buf, "internal error: unknown read port");
802 b8c14089 2003-11-23 devnull return t;
804 b8c14089 2003-11-23 devnull qlock(&queue);
805 b8c14089 2003-11-23 devnull queueread(f->dir, t, buf, f);
806 b8c14089 2003-11-23 devnull drainqueue(f->dir);
807 b8c14089 2003-11-23 devnull qunlock(&queue);
808 b8c14089 2003-11-23 devnull return nil;
810 b8c14089 2003-11-23 devnull o = t->offset;
811 b8c14089 2003-11-23 devnull e = t->offset+t->count;
812 b8c14089 2003-11-23 devnull clock = getclock();
813 b8c14089 2003-11-23 devnull b = malloc(messagesize-IOHDRSZ);
814 b8c14089 2003-11-23 devnull if(b == nil){
815 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Enomem);
816 b8c14089 2003-11-23 devnull return t;
819 b8c14089 2003-11-23 devnull d = dir;
820 b8c14089 2003-11-23 devnull d++; /* first entry is '.' */
821 b8c14089 2003-11-23 devnull for(i=0; d->name!=nil && i<e; i+=len){
822 b8c14089 2003-11-23 devnull len = dostat(d, b+n, messagesize-IOHDRSZ-n, clock);
823 b8c14089 2003-11-23 devnull if(len <= BIT16SZ)
825 b8c14089 2003-11-23 devnull if(i >= o)
826 b8c14089 2003-11-23 devnull n += len;
829 b8c14089 2003-11-23 devnull t->data = (char*)b;
830 b8c14089 2003-11-23 devnull t->count = n;
831 b8c14089 2003-11-23 devnull fsysrespond(t, buf, nil);
832 b8c14089 2003-11-23 devnull free(b);
833 b8c14089 2003-11-23 devnull return t;
836 b8c14089 2003-11-23 devnull static Fcall*
837 b8c14089 2003-11-23 devnull fsyswrite(Fcall *t, uchar *buf, Fid *f)
839 b8c14089 2003-11-23 devnull Plumbmsg *m;
840 b8c14089 2003-11-23 devnull int i, n;
841 b8c14089 2003-11-23 devnull long count;
842 b8c14089 2003-11-23 devnull char *data;
843 b8c14089 2003-11-23 devnull Exec *e;
845 b8c14089 2003-11-23 devnull switch((int)f->qid.path){
846 b8c14089 2003-11-23 devnull case Qdir:
847 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Eisdir);
848 b8c14089 2003-11-23 devnull return t;
849 b8c14089 2003-11-23 devnull case Qrules:
850 b8c14089 2003-11-23 devnull clock = getclock();
851 b8c14089 2003-11-23 devnull fsysrespond(t, buf, writerules(t->data, t->count));
852 b8c14089 2003-11-23 devnull return t;
853 b8c14089 2003-11-23 devnull case Qsend:
854 b8c14089 2003-11-23 devnull if(f->offset == 0){
855 b8c14089 2003-11-23 devnull data = t->data;
856 b8c14089 2003-11-23 devnull count = t->count;
858 b8c14089 2003-11-23 devnull /* partial message already assembled */
859 b8c14089 2003-11-23 devnull f->writebuf = erealloc(f->writebuf, f->offset + t->count);
860 b8c14089 2003-11-23 devnull memmove(f->writebuf+f->offset, t->data, t->count);
861 b8c14089 2003-11-23 devnull data = f->writebuf;
862 b8c14089 2003-11-23 devnull count = f->offset+t->count;
864 b8c14089 2003-11-23 devnull m = plumbunpackpartial(data, count, &n);
865 b8c14089 2003-11-23 devnull if(m == nil){
866 b8c14089 2003-11-23 devnull if(n == 0){
867 b8c14089 2003-11-23 devnull f->offset = 0;
868 b8c14089 2003-11-23 devnull free(f->writebuf);
869 b8c14089 2003-11-23 devnull f->writebuf = nil;
870 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Ebadmsg);
871 b8c14089 2003-11-23 devnull return t;
873 b8c14089 2003-11-23 devnull /* can read more... */
874 b8c14089 2003-11-23 devnull if(f->offset == 0){
875 b8c14089 2003-11-23 devnull f->writebuf = emalloc(t->count);
876 b8c14089 2003-11-23 devnull memmove(f->writebuf, t->data, t->count);
878 b8c14089 2003-11-23 devnull /* else buffer has already been grown */
879 b8c14089 2003-11-23 devnull f->offset += t->count;
880 b8c14089 2003-11-23 devnull fsysrespond(t, buf, nil);
881 b8c14089 2003-11-23 devnull return t;
883 b8c14089 2003-11-23 devnull /* release partial buffer */
884 b8c14089 2003-11-23 devnull f->offset = 0;
885 b8c14089 2003-11-23 devnull free(f->writebuf);
886 b8c14089 2003-11-23 devnull f->writebuf = nil;
887 b8c14089 2003-11-23 devnull for(i=0; rules[i]; i++)
888 b8c14089 2003-11-23 devnull if((e=matchruleset(m, rules[i])) != nil){
889 b8c14089 2003-11-23 devnull dispose(t, buf, m, rules[i], e);
890 b8c14089 2003-11-23 devnull return nil;
892 b8c14089 2003-11-23 devnull if(m->dst != nil){
893 b8c14089 2003-11-23 devnull dispose(t, buf, m, nil, nil);
894 b8c14089 2003-11-23 devnull return nil;
896 b8c14089 2003-11-23 devnull fsysrespond(t, buf, "no matching plumb rule");
897 b8c14089 2003-11-23 devnull return t;
899 b8c14089 2003-11-23 devnull fsysrespond(t, buf, "internal error: write to unknown file");
900 b8c14089 2003-11-23 devnull return t;
903 b8c14089 2003-11-23 devnull static Fcall*
904 b8c14089 2003-11-23 devnull fsysstat(Fcall *t, uchar *buf, Fid *f)
906 b8c14089 2003-11-23 devnull t->stat = emalloc(messagesize-IOHDRSZ);
907 b8c14089 2003-11-23 devnull t->nstat = dostat(f->dir, t->stat, messagesize-IOHDRSZ, clock);
908 b8c14089 2003-11-23 devnull fsysrespond(t, buf, nil);
909 b8c14089 2003-11-23 devnull free(t->stat);
910 b8c14089 2003-11-23 devnull t->stat = nil;
911 b8c14089 2003-11-23 devnull return t;
914 b8c14089 2003-11-23 devnull static Fcall*
915 32f69c36 2003-12-11 devnull fsyswstat(Fcall *t, uchar *buf, Fid *fid)
917 32f69c36 2003-12-11 devnull USED(fid);
918 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Eperm);
919 b8c14089 2003-11-23 devnull return t;
922 b8c14089 2003-11-23 devnull static Fcall*
923 32f69c36 2003-12-11 devnull fsysremove(Fcall *t, uchar *buf, Fid *fid)
925 32f69c36 2003-12-11 devnull USED(fid);
926 b8c14089 2003-11-23 devnull fsysrespond(t, buf, Eperm);
927 b8c14089 2003-11-23 devnull return t;
930 b8c14089 2003-11-23 devnull static Fcall*
931 b8c14089 2003-11-23 devnull fsysclunk(Fcall *t, uchar *buf, Fid *f)
933 b8c14089 2003-11-23 devnull Fid *prev, *p;
934 b8c14089 2003-11-23 devnull Dirtab *d;
936 b8c14089 2003-11-23 devnull qlock(&queue);
937 b8c14089 2003-11-23 devnull if(f->open){
938 b8c14089 2003-11-23 devnull d = f->dir;
939 b8c14089 2003-11-23 devnull d->nopen--;
940 b8c14089 2003-11-23 devnull if(d->qid==Qrules && (f->mode==OWRITE || f->mode==ORDWR)){
942 b8c14089 2003-11-23 devnull * just to be sure last rule is parsed; error messages will be lost, though,
943 b8c14089 2003-11-23 devnull * unless last write ended with a blank line
945 b8c14089 2003-11-23 devnull writerules(nil, 0);
946 32f69c36 2003-12-11 devnull lock(&rulesref.lk);
947 b8c14089 2003-11-23 devnull rulesref.ref--;
948 32f69c36 2003-12-11 devnull unlock(&rulesref.lk);
950 b8c14089 2003-11-23 devnull prev = nil;
951 b8c14089 2003-11-23 devnull for(p=d->fopen; p; p=p->nextopen){
952 b8c14089 2003-11-23 devnull if(p == f){
953 b8c14089 2003-11-23 devnull if(prev)
954 b8c14089 2003-11-23 devnull prev->nextopen = f->nextopen;
956 b8c14089 2003-11-23 devnull d->fopen = f->nextopen;
957 b8c14089 2003-11-23 devnull removesenders(d, f);
960 b8c14089 2003-11-23 devnull prev = p;
963 b8c14089 2003-11-23 devnull f->busy = 0;
964 b8c14089 2003-11-23 devnull f->open = 0;
965 b8c14089 2003-11-23 devnull f->offset = 0;
966 b8c14089 2003-11-23 devnull if(f->writebuf != nil){
967 b8c14089 2003-11-23 devnull free(f->writebuf);
968 b8c14089 2003-11-23 devnull f->writebuf = nil;
970 b8c14089 2003-11-23 devnull qunlock(&queue);
971 b8c14089 2003-11-23 devnull fsysrespond(t, buf, nil);
972 b8c14089 2003-11-23 devnull return t;
