1 d3df3087 2003-12-06 devnull #include <u.h>
2 d3df3087 2003-12-06 devnull #include <libc.h>
3 d3df3087 2003-12-06 devnull #include <fcall.h>
4 d3df3087 2003-12-06 devnull #include <thread.h>
5 32f69c36 2003-12-11 devnull #include <errno.h>
9 d3df3087 2003-12-06 devnull STACK = 32768,
10 d3df3087 2003-12-06 devnull NHASH = 31,
11 d3df3087 2003-12-06 devnull MAXMSG = 64, /* per connection */
14 d3df3087 2003-12-06 devnull typedef struct Hash Hash;
15 d3df3087 2003-12-06 devnull typedef struct Fid Fid;
16 d3df3087 2003-12-06 devnull typedef struct Msg Msg;
17 d3df3087 2003-12-06 devnull typedef struct Conn Conn;
18 d3df3087 2003-12-06 devnull typedef struct Queue Queue;
20 d3df3087 2003-12-06 devnull struct Hash
22 d3df3087 2003-12-06 devnull Hash *next;
27 d3df3087 2003-12-06 devnull struct Fid
31 d3df3087 2003-12-06 devnull int cfid;
32 21e626de 2004-12-28 devnull int openfd;
33 215993f8 2005-09-13 devnull int isdir;
34 d3df3087 2003-12-06 devnull Fid *next;
37 d3df3087 2003-12-06 devnull struct Msg
40 d3df3087 2003-12-06 devnull int internal;
42 d3df3087 2003-12-06 devnull int ctag;
44 32f69c36 2003-12-11 devnull int isopenfd;
45 d3df3087 2003-12-06 devnull Fcall tx;
46 d3df3087 2003-12-06 devnull Fcall rx;
47 d3df3087 2003-12-06 devnull Fid *fid;
48 d3df3087 2003-12-06 devnull Fid *newfid;
49 d3df3087 2003-12-06 devnull Fid *afid;
50 d3df3087 2003-12-06 devnull Msg *oldm;
51 d3df3087 2003-12-06 devnull Msg *next;
52 d3df3087 2003-12-06 devnull uchar *tpkt;
53 d3df3087 2003-12-06 devnull uchar *rpkt;
56 d3df3087 2003-12-06 devnull struct Conn
59 32f69c36 2003-12-11 devnull int fdmode;
60 32f69c36 2003-12-11 devnull Fid *fdfid;
61 d3df3087 2003-12-06 devnull int nmsg;
62 d3df3087 2003-12-06 devnull int nfid;
63 d3df3087 2003-12-06 devnull Channel *inc;
64 d3df3087 2003-12-06 devnull Channel *internal;
65 d3df3087 2003-12-06 devnull int inputstalled;
66 d3df3087 2003-12-06 devnull char dir[40];
67 d3df3087 2003-12-06 devnull Hash *tag[NHASH];
68 d3df3087 2003-12-06 devnull Hash *fid[NHASH];
69 d3df3087 2003-12-06 devnull Queue *outq;
70 d3df3087 2003-12-06 devnull Queue *inq;
71 215993f8 2005-09-13 devnull int dotu;
74 5c84c448 2005-03-21 devnull char *xaname;
75 d3df3087 2003-12-06 devnull char *addr;
77 d3df3087 2003-12-06 devnull char adir[40];
78 d3df3087 2003-12-06 devnull int isunix;
79 d3df3087 2003-12-06 devnull Queue *outq;
80 d3df3087 2003-12-06 devnull Queue *inq;
81 05b7f431 2004-03-02 devnull int verbose = 0;
82 e2a1725d 2005-01-04 devnull int logging = 0;
83 5a8e63b2 2004-02-29 devnull int msize = 8192;
84 34e8254f 2005-07-27 devnull u32int xafid = NOFID;
85 5c84c448 2005-03-21 devnull int attached;
86 5c84c448 2005-03-21 devnull int versioned;
87 215993f8 2005-09-13 devnull int dotu;
89 d3df3087 2003-12-06 devnull void *gethash(Hash**, uint);
90 d3df3087 2003-12-06 devnull int puthash(Hash**, uint, void*);
91 d3df3087 2003-12-06 devnull int delhash(Hash**, uint, void*);
92 215993f8 2005-09-13 devnull Msg *mread9p(Ioproc*, int, int);
93 ceb04770 2003-12-09 devnull int mwrite9p(Ioproc*, int, uchar*);
94 ceb04770 2003-12-09 devnull uchar *read9ppkt(Ioproc*, int);
95 d3df3087 2003-12-06 devnull int write9ppkt(int, uchar*);
96 e2a1725d 2005-01-04 devnull Msg *msgnew(int);
97 d3df3087 2003-12-06 devnull void msgput(Msg*);
98 e2a1725d 2005-01-04 devnull void msgclear(Msg*);
99 d3df3087 2003-12-06 devnull Msg *msgget(int);
100 e2a1725d 2005-01-04 devnull void msgincref(Msg*);
101 d3df3087 2003-12-06 devnull Fid *fidnew(int);
102 d3df3087 2003-12-06 devnull void fidput(Fid*);
103 d3df3087 2003-12-06 devnull void *emalloc(int);
104 d3df3087 2003-12-06 devnull void *erealloc(void*, int);
105 ceb04770 2003-12-09 devnull Queue *qalloc(void);
106 d3df3087 2003-12-06 devnull int sendq(Queue*, void*);
107 d3df3087 2003-12-06 devnull void *recvq(Queue*);
108 d3df3087 2003-12-06 devnull void connthread(void*);
109 ceb04770 2003-12-09 devnull void connoutthread(void*);
110 d3df3087 2003-12-06 devnull void listenthread(void*);
111 ceb04770 2003-12-09 devnull void outputthread(void*);
112 ceb04770 2003-12-09 devnull void inputthread(void*);
113 d3df3087 2003-12-06 devnull void rewritehdr(Fcall*, uchar*);
114 215993f8 2005-09-13 devnull void repack(Fcall*, uchar**, int);
115 d3df3087 2003-12-06 devnull int tlisten(char*, char*);
116 d3df3087 2003-12-06 devnull int taccept(int, char*);
117 ceb04770 2003-12-09 devnull int iolisten(Ioproc*, char*, char*);
118 ceb04770 2003-12-09 devnull int ioaccept(Ioproc*, int, char*);
119 32f69c36 2003-12-11 devnull int iorecvfd(Ioproc*, int);
120 32f69c36 2003-12-11 devnull int iosendfd(Ioproc*, int, int);
121 32f69c36 2003-12-11 devnull void mainproc(void*);
122 32f69c36 2003-12-11 devnull int ignorepipe(void*, char*);
123 e2a1725d 2005-01-04 devnull int timefmt(Fmt*);
124 5c84c448 2005-03-21 devnull void dorootstat(void);
125 215993f8 2005-09-13 devnull int stripudirread(Msg*);
126 16c1defa 2005-11-12 devnull int cvtustat(Fcall*, uchar**, int);
129 d3df3087 2003-12-06 devnull usage(void)
131 5c84c448 2005-03-21 devnull fprint(2, "usage: 9pserve [-lv] [-A aname afid] [-M msize] address\n");
132 d3df3087 2003-12-06 devnull fprint(2, "\treads/writes 9P messages on stdin/stdout\n");
133 38c10d1a 2005-01-17 devnull threadexitsall("usage");
136 ceb04770 2003-12-09 devnull uchar vbuf[128];
137 32f69c36 2003-12-11 devnull extern int _threaddebuglevel;
139 d3df3087 2003-12-06 devnull threadmain(int argc, char **argv)
141 3a6f92ee 2005-03-18 devnull char *file, *x;
144 3a6f92ee 2005-03-18 devnull x = getenv("verbose9pserve");
146 3a6f92ee 2005-03-18 devnull verbose = atoi(x);
147 5c84c448 2005-03-21 devnull fprint(2, "verbose9pserve %s => %d\n", x, verbose);
149 d3df3087 2003-12-06 devnull ARGBEGIN{
150 d3df3087 2003-12-06 devnull default:
151 d3df3087 2003-12-06 devnull usage();
152 5c84c448 2005-03-21 devnull case 'A':
153 5c84c448 2005-03-21 devnull attached = 1;
154 5c84c448 2005-03-21 devnull xaname = EARGF(usage());
155 5c84c448 2005-03-21 devnull xafid = atoi(EARGF(usage()));
157 5c84c448 2005-03-21 devnull case 'M':
158 5c84c448 2005-03-21 devnull versioned = 1;
159 5c84c448 2005-03-21 devnull msize = atoi(EARGF(usage()));
161 ceb04770 2003-12-09 devnull case 'v':
162 ceb04770 2003-12-09 devnull verbose++;
164 d3df3087 2003-12-06 devnull case 'u':
165 5c84c448 2005-03-21 devnull isunix++;
167 e2a1725d 2005-01-04 devnull case 'l':
168 e2a1725d 2005-01-04 devnull logging++;
172 5c84c448 2005-03-21 devnull if(attached && !versioned){
173 5c84c448 2005-03-21 devnull fprint(2, "-A must be used with -M\n");
174 5c84c448 2005-03-21 devnull usage();
177 d3df3087 2003-12-06 devnull if(argc != 1)
178 d3df3087 2003-12-06 devnull usage();
179 ceb04770 2003-12-09 devnull addr = argv[0];
181 e2a1725d 2005-01-04 devnull fmtinstall('T', timefmt);
183 d3df3087 2003-12-06 devnull if((afd = announce(addr, adir)) < 0)
184 d3df3087 2003-12-06 devnull sysfatal("announce %s: %r", addr);
185 e2a1725d 2005-01-04 devnull if(logging){
186 e2a1725d 2005-01-04 devnull if(strncmp(addr, "unix!", 5) == 0)
187 e2a1725d 2005-01-04 devnull addr += 5;
188 e2a1725d 2005-01-04 devnull file = smprint("%s.log", addr);
189 e2a1725d 2005-01-04 devnull if(file == nil)
190 e2a1725d 2005-01-04 devnull sysfatal("smprint log: %r");
191 e2a1725d 2005-01-04 devnull if((fd = create(file, OWRITE, 0666)) < 0)
192 e2a1725d 2005-01-04 devnull sysfatal("create %s: %r", file);
193 e2a1725d 2005-01-04 devnull dup(fd, 2);
194 e2a1725d 2005-01-04 devnull if(fd > 2)
195 e2a1725d 2005-01-04 devnull close(fd);
197 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T 9pserve running\n");
198 e2a1725d 2005-01-04 devnull proccreate(mainproc, nil, STACK);
202 32f69c36 2003-12-11 devnull mainproc(void *v)
204 c91bd328 2004-03-05 devnull int n, nn;
205 32f69c36 2003-12-11 devnull Fcall f;
206 32f69c36 2003-12-11 devnull USED(v);
208 32f69c36 2003-12-11 devnull atnotify(ignorepipe, 1);
209 ceb04770 2003-12-09 devnull fmtinstall('D', dirfmt);
210 ceb04770 2003-12-09 devnull fmtinstall('M', dirmodefmt);
211 ceb04770 2003-12-09 devnull fmtinstall('F', fcallfmt);
212 ceb04770 2003-12-09 devnull fmtinstall('H', encodefmt);
214 ceb04770 2003-12-09 devnull outq = qalloc();
215 ceb04770 2003-12-09 devnull inq = qalloc();
217 5c84c448 2005-03-21 devnull if(!versioned){
218 5c84c448 2005-03-21 devnull f.type = Tversion;
219 215993f8 2005-09-13 devnull f.version = "9P2000.u";
220 5c84c448 2005-03-21 devnull f.msize = msize;
221 5c84c448 2005-03-21 devnull f.tag = NOTAG;
222 5c84c448 2005-03-21 devnull n = convS2M(&f, vbuf, sizeof vbuf);
223 9e2f1d9b 2005-11-21 devnull if(n <= BIT16SZ)
224 9e2f1d9b 2005-11-21 devnull sysfatal("convS2M conversion error");
225 5c84c448 2005-03-21 devnull if(verbose > 1) fprint(2, "%T * <- %F\n", &f);
226 5c84c448 2005-03-21 devnull nn = write(1, vbuf, n);
227 5c84c448 2005-03-21 devnull if(n != nn)
228 5c84c448 2005-03-21 devnull sysfatal("error writing Tversion: %r\n");
229 5c84c448 2005-03-21 devnull n = read9pmsg(0, vbuf, sizeof vbuf);
230 5c84c448 2005-03-21 devnull if(convM2S(vbuf, n, &f) != n)
231 5c84c448 2005-03-21 devnull sysfatal("convM2S failure");
232 5c84c448 2005-03-21 devnull if(f.msize < msize)
233 5c84c448 2005-03-21 devnull msize = f.msize;
234 5c84c448 2005-03-21 devnull if(verbose > 1) fprint(2, "%T * -> %F\n", &f);
235 215993f8 2005-09-13 devnull dotu = strncmp(f.version, "9P2000.u", 8) == 0;
238 32f69c36 2003-12-11 devnull threadcreate(inputthread, nil, STACK);
239 32f69c36 2003-12-11 devnull threadcreate(outputthread, nil, STACK);
241 5c84c448 2005-03-21 devnull // if(rootfid)
242 5c84c448 2005-03-21 devnull // dorootstat();
244 ceb04770 2003-12-09 devnull threadcreate(listenthread, nil, STACK);
245 32f69c36 2003-12-11 devnull threadexits(0);
249 32f69c36 2003-12-11 devnull ignorepipe(void *v, char *s)
251 32f69c36 2003-12-11 devnull USED(v);
252 32f69c36 2003-12-11 devnull if(strcmp(s, "sys: write on closed pipe") == 0)
253 32f69c36 2003-12-11 devnull return 1;
254 c042e61e 2005-03-18 devnull if(strcmp(s, "sys: tstp") == 0)
255 c042e61e 2005-03-18 devnull return 1;
256 c042e61e 2005-03-18 devnull fprint(2, "9pserve %s: %T note: %s\n", addr, s);
257 32f69c36 2003-12-11 devnull return 0;
261 d3df3087 2003-12-06 devnull listenthread(void *arg)
263 d3df3087 2003-12-06 devnull Conn *c;
264 ceb04770 2003-12-09 devnull Ioproc *io;
266 ceb04770 2003-12-09 devnull io = ioproc();
267 d3df3087 2003-12-06 devnull USED(arg);
268 7ffc5208 2004-12-28 devnull threadsetname("listen %s", adir);
269 d3df3087 2003-12-06 devnull for(;;){
270 ceb04770 2003-12-09 devnull c = emalloc(sizeof(Conn));
271 ceb04770 2003-12-09 devnull c->fd = iolisten(io, adir, c->dir);
272 d3df3087 2003-12-06 devnull if(c->fd < 0){
273 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T listen: %r\n");
274 d3df3087 2003-12-06 devnull close(afd);
275 d3df3087 2003-12-06 devnull free(c);
278 32f69c36 2003-12-11 devnull c->inc = chancreate(sizeof(void*), 0);
279 32f69c36 2003-12-11 devnull c->internal = chancreate(sizeof(void*), 0);
280 32f69c36 2003-12-11 devnull c->inq = qalloc();
281 32f69c36 2003-12-11 devnull c->outq = qalloc();
282 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T incoming call on %s\n", c->dir);
283 d3df3087 2003-12-06 devnull threadcreate(connthread, c, STACK);
288 32f69c36 2003-12-11 devnull send9pmsg(Msg *m)
290 d3df3087 2003-12-06 devnull int n, nn;
292 215993f8 2005-09-13 devnull n = sizeS2Mu(&m->rx, m->c->dotu);
293 d3df3087 2003-12-06 devnull m->rpkt = emalloc(n);
294 215993f8 2005-09-13 devnull nn = convS2Mu(&m->rx, m->rpkt, n, m->c->dotu);
295 9e2f1d9b 2005-11-21 devnull if(nn <= BIT16SZ)
296 9e2f1d9b 2005-11-21 devnull sysfatal("convS2Mu conversion error");
297 d3df3087 2003-12-06 devnull if(nn != n)
298 9e2f1d9b 2005-11-21 devnull sysfatal("sizeS2Mu and convS2Mu disagree");
299 d3df3087 2003-12-06 devnull sendq(m->c->outq, m);
303 ceb04770 2003-12-09 devnull sendomsg(Msg *m)
305 ceb04770 2003-12-09 devnull int n, nn;
307 215993f8 2005-09-13 devnull n = sizeS2Mu(&m->tx, m->c->dotu);
308 ceb04770 2003-12-09 devnull m->tpkt = emalloc(n);
309 215993f8 2005-09-13 devnull nn = convS2Mu(&m->tx, m->tpkt, n, m->c->dotu);
310 9e2f1d9b 2005-11-21 devnull if(nn <= BIT16SZ)
311 9e2f1d9b 2005-11-21 devnull sysfatal("convS2Mu conversion error");
312 ceb04770 2003-12-09 devnull if(nn != n)
313 9e2f1d9b 2005-11-21 devnull sysfatal("sizeS2Mu and convS2Mu disagree");
314 ceb04770 2003-12-09 devnull sendq(outq, m);
318 ceb04770 2003-12-09 devnull err(Msg *m, char *ename)
320 ceb04770 2003-12-09 devnull m->rx.type = Rerror;
321 ceb04770 2003-12-09 devnull m->rx.ename = ename;
322 ceb04770 2003-12-09 devnull m->rx.tag = m->tx.tag;
323 32f69c36 2003-12-11 devnull send9pmsg(m);
327 5c84c448 2005-03-21 devnull estrdup(char *s)
329 5c84c448 2005-03-21 devnull char *t;
331 5c84c448 2005-03-21 devnull t = emalloc(strlen(s)+1);
332 5c84c448 2005-03-21 devnull strcpy(t, s);
333 5c84c448 2005-03-21 devnull return t;
337 d3df3087 2003-12-06 devnull connthread(void *arg)
339 d3df3087 2003-12-06 devnull int i, fd;
340 d3df3087 2003-12-06 devnull Conn *c;
341 05b7f431 2004-03-02 devnull Hash *h, *hnext;
342 05b7f431 2004-03-02 devnull Msg *m, *om, *mm;
344 ceb04770 2003-12-09 devnull Ioproc *io;
346 d3df3087 2003-12-06 devnull c = arg;
347 7ffc5208 2004-12-28 devnull threadsetname("conn %s", c->dir);
348 ceb04770 2003-12-09 devnull io = ioproc();
349 ceb04770 2003-12-09 devnull fd = ioaccept(io, c->fd, c->dir);
350 d3df3087 2003-12-06 devnull if(fd < 0){
351 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T accept %s: %r\n", c->dir);
352 d3df3087 2003-12-06 devnull goto out;
354 d3df3087 2003-12-06 devnull close(c->fd);
355 d3df3087 2003-12-06 devnull c->fd = fd;
356 ceb04770 2003-12-09 devnull threadcreate(connoutthread, c, STACK);
357 215993f8 2005-09-13 devnull while((m = mread9p(io, c->fd, c->dotu)) != nil){
358 e2a1725d 2005-01-04 devnull if(verbose > 1) fprint(2, "%T fd#%d -> %F\n", c->fd, &m->tx);
359 d3df3087 2003-12-06 devnull m->c = c;
360 ceb04770 2003-12-09 devnull m->ctag = m->tx.tag;
361 d3df3087 2003-12-06 devnull c->nmsg++;
362 e2a1725d 2005-01-04 devnull if(verbose > 1) fprint(2, "%T fd#%d: new msg %p\n", c->fd, m);
363 d3df3087 2003-12-06 devnull if(puthash(c->tag, m->tx.tag, m) < 0){
364 d3df3087 2003-12-06 devnull err(m, "duplicate tag");
365 d3df3087 2003-12-06 devnull continue;
367 e2a1725d 2005-01-04 devnull msgincref(m);
368 d3df3087 2003-12-06 devnull switch(m->tx.type){
369 ceb04770 2003-12-09 devnull case Tversion:
370 ceb04770 2003-12-09 devnull m->rx.tag = m->tx.tag;
371 ceb04770 2003-12-09 devnull m->rx.msize = m->tx.msize;
372 5a8e63b2 2004-02-29 devnull if(m->rx.msize > msize)
373 5a8e63b2 2004-02-29 devnull m->rx.msize = msize;
374 ceb04770 2003-12-09 devnull m->rx.version = "9P2000";
375 215993f8 2005-09-13 devnull c->dotu = 0;
376 215993f8 2005-09-13 devnull if(dotu && strncmp(m->tx.version, "9P2000.u", 8) == 0){
377 215993f8 2005-09-13 devnull m->rx.version = "9P2000.u";
378 215993f8 2005-09-13 devnull c->dotu = 1;
380 ceb04770 2003-12-09 devnull m->rx.type = Rversion;
381 32f69c36 2003-12-11 devnull send9pmsg(m);
382 ceb04770 2003-12-09 devnull continue;
383 d3df3087 2003-12-06 devnull case Tflush:
384 d3df3087 2003-12-06 devnull if((m->oldm = gethash(c->tag, m->tx.oldtag)) == nil){
385 ceb04770 2003-12-09 devnull m->rx.tag = m->tx.tag;
386 ceb04770 2003-12-09 devnull m->rx.type = Rflush;
387 32f69c36 2003-12-11 devnull send9pmsg(m);
388 d3df3087 2003-12-06 devnull continue;
390 e2a1725d 2005-01-04 devnull msgincref(m->oldm);
392 d3df3087 2003-12-06 devnull case Tattach:
393 ceb04770 2003-12-09 devnull m->afid = nil;
394 ceb04770 2003-12-09 devnull if(m->tx.afid != NOFID
395 ceb04770 2003-12-09 devnull && (m->afid = gethash(c->fid, m->tx.afid)) == nil){
396 ceb04770 2003-12-09 devnull err(m, "unknown fid");
397 ceb04770 2003-12-09 devnull continue;
399 3a6f92ee 2005-03-18 devnull if(m->afid)
400 3a6f92ee 2005-03-18 devnull m->afid->ref++;
401 d3df3087 2003-12-06 devnull m->fid = fidnew(m->tx.fid);
402 d3df3087 2003-12-06 devnull if(puthash(c->fid, m->tx.fid, m->fid) < 0){
403 d3df3087 2003-12-06 devnull err(m, "duplicate fid");
404 d3df3087 2003-12-06 devnull continue;
406 d3df3087 2003-12-06 devnull m->fid->ref++;
407 5c84c448 2005-03-21 devnull if(attached && m->afid==nil){
408 5c84c448 2005-03-21 devnull if(m->tx.aname[0] && strcmp(xaname, m->tx.aname) != 0){
409 5c84c448 2005-03-21 devnull err(m, "invalid attach name");
410 5c84c448 2005-03-21 devnull continue;
412 5c84c448 2005-03-21 devnull m->tx.afid = xafid;
413 5c84c448 2005-03-21 devnull m->tx.aname = xaname;
414 5c84c448 2005-03-21 devnull m->tx.uname = estrdup(m->tx.uname);
415 215993f8 2005-09-13 devnull repack(&m->tx, &m->tpkt, c->dotu);
416 5c84c448 2005-03-21 devnull free(m->tx.uname);
417 5c84c448 2005-03-21 devnull m->tx.uname = "XXX";
420 d3df3087 2003-12-06 devnull case Twalk:
421 d3df3087 2003-12-06 devnull if((m->fid = gethash(c->fid, m->tx.fid)) == nil){
422 d3df3087 2003-12-06 devnull err(m, "unknown fid");
423 d3df3087 2003-12-06 devnull continue;
425 ceb04770 2003-12-09 devnull m->fid->ref++;
426 d3df3087 2003-12-06 devnull if(m->tx.newfid == m->tx.fid){
427 d3df3087 2003-12-06 devnull m->fid->ref++;
428 d3df3087 2003-12-06 devnull m->newfid = m->fid;
430 d3df3087 2003-12-06 devnull m->newfid = fidnew(m->tx.newfid);
431 d3df3087 2003-12-06 devnull if(puthash(c->fid, m->tx.newfid, m->newfid) < 0){
432 d3df3087 2003-12-06 devnull err(m, "duplicate fid");
433 d3df3087 2003-12-06 devnull continue;
435 d3df3087 2003-12-06 devnull m->newfid->ref++;
438 d3df3087 2003-12-06 devnull case Tauth:
439 5c84c448 2005-03-21 devnull if(attached){
440 5c84c448 2005-03-21 devnull err(m, "authentication not required");
441 5c84c448 2005-03-21 devnull continue;
443 ceb04770 2003-12-09 devnull m->afid = fidnew(m->tx.afid);
444 ceb04770 2003-12-09 devnull if(puthash(c->fid, m->tx.afid, m->afid) < 0){
445 d3df3087 2003-12-06 devnull err(m, "duplicate fid");
446 d3df3087 2003-12-06 devnull continue;
448 ceb04770 2003-12-09 devnull m->afid->ref++;
450 32f69c36 2003-12-11 devnull case Topenfd:
451 49588d5d 2003-12-17 devnull if(m->tx.mode&~(OTRUNC|3)){
452 49588d5d 2003-12-17 devnull err(m, "bad openfd mode");
453 32f69c36 2003-12-11 devnull continue;
455 32f69c36 2003-12-11 devnull m->isopenfd = 1;
456 32f69c36 2003-12-11 devnull m->tx.type = Topen;
457 32f69c36 2003-12-11 devnull m->tpkt[4] = Topen;
458 32f69c36 2003-12-11 devnull /* fall through */
459 ceb04770 2003-12-09 devnull case Tcreate:
460 d3df3087 2003-12-06 devnull case Topen:
461 d3df3087 2003-12-06 devnull case Tclunk:
462 d3df3087 2003-12-06 devnull case Tread:
463 d3df3087 2003-12-06 devnull case Twrite:
464 ceb04770 2003-12-09 devnull case Tremove:
465 d3df3087 2003-12-06 devnull case Tstat:
466 d3df3087 2003-12-06 devnull case Twstat:
467 d3df3087 2003-12-06 devnull if((m->fid = gethash(c->fid, m->tx.fid)) == nil){
468 d3df3087 2003-12-06 devnull err(m, "unknown fid");
469 d3df3087 2003-12-06 devnull continue;
471 d3df3087 2003-12-06 devnull m->fid->ref++;
472 215993f8 2005-09-13 devnull if(m->tx.type==Twstat && dotu && !c->dotu){
473 16c1defa 2005-11-12 devnull if(cvtustat(&m->tx, &m->tpkt, 1) < 0){
474 215993f8 2005-09-13 devnull err(m, "cannot convert stat buffer");
475 215993f8 2005-09-13 devnull continue;
481 d3df3087 2003-12-06 devnull /* have everything - translate and send */
482 d3df3087 2003-12-06 devnull m->c = c;
483 d3df3087 2003-12-06 devnull m->ctag = m->tx.tag;
484 d3df3087 2003-12-06 devnull m->tx.tag = m->tag;
485 d3df3087 2003-12-06 devnull if(m->fid)
486 d3df3087 2003-12-06 devnull m->tx.fid = m->fid->fid;
487 d3df3087 2003-12-06 devnull if(m->newfid)
488 d3df3087 2003-12-06 devnull m->tx.newfid = m->newfid->fid;
489 d3df3087 2003-12-06 devnull if(m->afid)
490 d3df3087 2003-12-06 devnull m->tx.afid = m->afid->fid;
491 d3df3087 2003-12-06 devnull if(m->oldm)
492 d3df3087 2003-12-06 devnull m->tx.oldtag = m->oldm->tag;
493 ceb04770 2003-12-09 devnull /* reference passes to outq */
494 d3df3087 2003-12-06 devnull sendq(outq, m);
495 d3df3087 2003-12-06 devnull while(c->nmsg >= MAXMSG){
496 d3df3087 2003-12-06 devnull c->inputstalled = 1;
497 d3df3087 2003-12-06 devnull recvp(c->inc);
501 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T fd#%d eof; flushing conn\n", c->fd);
503 05b7f431 2004-03-02 devnull /* flush the output queue */
504 05b7f431 2004-03-02 devnull sendq(c->outq, nil);
505 05b7f431 2004-03-02 devnull while(c->outq != nil)
506 05b7f431 2004-03-02 devnull yield();
508 d3df3087 2003-12-06 devnull /* flush all outstanding messages */
509 d3df3087 2003-12-06 devnull for(i=0; i<NHASH; i++){
510 05b7f431 2004-03-02 devnull for(h=c->tag[i]; h; h=hnext){
511 d3df3087 2003-12-06 devnull om = h->v;
512 e2a1725d 2005-01-04 devnull m = msgnew(0);
513 d3df3087 2003-12-06 devnull m->internal = 1;
514 d3df3087 2003-12-06 devnull m->c = c;
515 32f69c36 2003-12-11 devnull c->nmsg++;
516 d3df3087 2003-12-06 devnull m->tx.type = Tflush;
517 d3df3087 2003-12-06 devnull m->tx.tag = m->tag;
518 d3df3087 2003-12-06 devnull m->tx.oldtag = om->tag;
519 d3df3087 2003-12-06 devnull m->oldm = om;
520 e2a1725d 2005-01-04 devnull msgincref(om);
521 e2a1725d 2005-01-04 devnull msgincref(m); /* for outq */
522 ceb04770 2003-12-09 devnull sendomsg(m);
523 05b7f431 2004-03-02 devnull mm = recvp(c->internal);
524 05b7f431 2004-03-02 devnull assert(mm == m);
525 32f69c36 2003-12-11 devnull msgput(m); /* got from recvp */
526 32f69c36 2003-12-11 devnull msgput(m); /* got from msgnew */
527 32f69c36 2003-12-11 devnull msgput(om); /* got from hash table */
528 05b7f431 2004-03-02 devnull hnext = h->next;
529 05b7f431 2004-03-02 devnull free(h);
533 d3df3087 2003-12-06 devnull /* clunk all outstanding fids */
534 d3df3087 2003-12-06 devnull for(i=0; i<NHASH; i++){
535 05b7f431 2004-03-02 devnull for(h=c->fid[i]; h; h=hnext){
536 d3df3087 2003-12-06 devnull f = h->v;
537 e2a1725d 2005-01-04 devnull m = msgnew(0);
538 d3df3087 2003-12-06 devnull m->internal = 1;
539 d3df3087 2003-12-06 devnull m->c = c;
540 32f69c36 2003-12-11 devnull c->nmsg++;
541 d3df3087 2003-12-06 devnull m->tx.type = Tclunk;
542 d3df3087 2003-12-06 devnull m->tx.tag = m->tag;
543 d3df3087 2003-12-06 devnull m->tx.fid = f->fid;
544 d3df3087 2003-12-06 devnull m->fid = f;
545 d3df3087 2003-12-06 devnull f->ref++;
546 e2a1725d 2005-01-04 devnull msgincref(m);
547 ceb04770 2003-12-09 devnull sendomsg(m);
548 05b7f431 2004-03-02 devnull mm = recvp(c->internal);
549 05b7f431 2004-03-02 devnull assert(mm == m);
550 e2a1725d 2005-01-04 devnull msgclear(m);
551 32f69c36 2003-12-11 devnull msgput(m); /* got from recvp */
552 32f69c36 2003-12-11 devnull msgput(m); /* got from msgnew */
553 32f69c36 2003-12-11 devnull fidput(f); /* got from hash table */
554 05b7f431 2004-03-02 devnull hnext = h->next;
555 05b7f431 2004-03-02 devnull free(h);
560 e2a1725d 2005-01-04 devnull closeioproc(io);
561 d3df3087 2003-12-06 devnull assert(c->nmsg == 0);
562 d3df3087 2003-12-06 devnull assert(c->nfid == 0);
563 d3df3087 2003-12-06 devnull close(c->fd);
564 32f69c36 2003-12-11 devnull chanfree(c->internal);
565 32f69c36 2003-12-11 devnull c->internal = 0;
566 32f69c36 2003-12-11 devnull chanfree(c->inc);
567 32f69c36 2003-12-11 devnull c->inc = 0;
568 32f69c36 2003-12-11 devnull free(c->inq);
569 32f69c36 2003-12-11 devnull c->inq = 0;
570 d3df3087 2003-12-06 devnull free(c);
573 32f69c36 2003-12-11 devnull static void
574 32f69c36 2003-12-11 devnull openfdthread(void *v)
576 32f69c36 2003-12-11 devnull Conn *c;
577 32f69c36 2003-12-11 devnull Fid *fid;
580 32f69c36 2003-12-11 devnull vlong tot;
581 32f69c36 2003-12-11 devnull Ioproc *io;
582 32f69c36 2003-12-11 devnull char buf[1024];
585 32f69c36 2003-12-11 devnull fid = c->fdfid;
586 32f69c36 2003-12-11 devnull io = ioproc();
587 7ffc5208 2004-12-28 devnull threadsetname("openfd %s", c->fdfid);
588 32f69c36 2003-12-11 devnull tot = 0;
589 05b7f431 2004-03-02 devnull m = nil;
590 32f69c36 2003-12-11 devnull if(c->fdmode == OREAD){
591 32f69c36 2003-12-11 devnull for(;;){
592 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T tread...");
593 e2a1725d 2005-01-04 devnull m = msgnew(0);
594 32f69c36 2003-12-11 devnull m->internal = 1;
595 32f69c36 2003-12-11 devnull m->c = c;
596 32f69c36 2003-12-11 devnull m->tx.type = Tread;
597 5a8e63b2 2004-02-29 devnull m->tx.count = msize - IOHDRSZ;
598 32f69c36 2003-12-11 devnull m->tx.fid = fid->fid;
599 32f69c36 2003-12-11 devnull m->tx.tag = m->tag;
600 32f69c36 2003-12-11 devnull m->tx.offset = tot;
601 32f69c36 2003-12-11 devnull m->fid = fid;
602 32f69c36 2003-12-11 devnull fid->ref++;
603 e2a1725d 2005-01-04 devnull msgincref(m);
604 32f69c36 2003-12-11 devnull sendomsg(m);
605 32f69c36 2003-12-11 devnull recvp(c->internal);
606 49588d5d 2003-12-17 devnull if(m->rx.type == Rerror){
607 e2a1725d 2005-01-04 devnull // fprint(2, "%T read error: %s\n", m->rx.ename);
610 32f69c36 2003-12-11 devnull if(m->rx.count == 0)
612 32f69c36 2003-12-11 devnull tot += m->rx.count;
613 49588d5d 2003-12-17 devnull if(iowrite(io, c->fd, m->rx.data, m->rx.count) != m->rx.count){
614 e2a1725d 2005-01-04 devnull // fprint(2, "%T pipe write error: %r\n");
617 32f69c36 2003-12-11 devnull msgput(m);
618 32f69c36 2003-12-11 devnull msgput(m);
619 05b7f431 2004-03-02 devnull m = nil;
622 32f69c36 2003-12-11 devnull for(;;){
623 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T twrite...");
624 5a8e63b2 2004-02-29 devnull n = sizeof buf;
625 5a8e63b2 2004-02-29 devnull if(n > msize)
626 5a8e63b2 2004-02-29 devnull n = msize;
627 5a8e63b2 2004-02-29 devnull if((n=ioread(io, c->fd, buf, n)) <= 0){
628 49588d5d 2003-12-17 devnull if(n < 0)
629 e2a1725d 2005-01-04 devnull fprint(2, "%T pipe read error: %r\n");
632 e2a1725d 2005-01-04 devnull m = msgnew(0);
633 32f69c36 2003-12-11 devnull m->internal = 1;
634 32f69c36 2003-12-11 devnull m->c = c;
635 32f69c36 2003-12-11 devnull m->tx.type = Twrite;
636 32f69c36 2003-12-11 devnull m->tx.fid = fid->fid;
637 32f69c36 2003-12-11 devnull m->tx.data = buf;
638 32f69c36 2003-12-11 devnull m->tx.count = n;
639 32f69c36 2003-12-11 devnull m->tx.tag = m->tag;
640 32f69c36 2003-12-11 devnull m->tx.offset = tot;
641 32f69c36 2003-12-11 devnull m->fid = fid;
642 32f69c36 2003-12-11 devnull fid->ref++;
643 e2a1725d 2005-01-04 devnull msgincref(m);
644 32f69c36 2003-12-11 devnull sendomsg(m);
645 32f69c36 2003-12-11 devnull recvp(c->internal);
646 49588d5d 2003-12-17 devnull if(m->rx.type == Rerror){
647 e2a1725d 2005-01-04 devnull // fprint(2, "%T write error: %s\n", m->rx.ename);
649 05b7f431 2004-03-02 devnull tot += n;
650 32f69c36 2003-12-11 devnull msgput(m);
651 32f69c36 2003-12-11 devnull msgput(m);
652 05b7f431 2004-03-02 devnull m = nil;
655 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T eof on %d fid %d\n", c->fd, fid->fid);
656 32f69c36 2003-12-11 devnull close(c->fd);
657 32f69c36 2003-12-11 devnull closeioproc(io);
659 32f69c36 2003-12-11 devnull msgput(m);
660 32f69c36 2003-12-11 devnull msgput(m);
662 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T eof on %d fid %d ref %d\n", c->fd, fid->fid, fid->ref);
663 21e626de 2004-12-28 devnull if(--fid->openfd == 0){
664 e2a1725d 2005-01-04 devnull m = msgnew(0);
665 49588d5d 2003-12-17 devnull m->internal = 1;
666 49588d5d 2003-12-17 devnull m->c = c;
667 49588d5d 2003-12-17 devnull m->tx.type = Tclunk;
668 05b7f431 2004-03-02 devnull m->tx.tag = m->tag;
669 49588d5d 2003-12-17 devnull m->tx.fid = fid->fid;
670 49588d5d 2003-12-17 devnull m->fid = fid;
671 49588d5d 2003-12-17 devnull fid->ref++;
672 e2a1725d 2005-01-04 devnull msgincref(m);
673 49588d5d 2003-12-17 devnull sendomsg(m);
674 49588d5d 2003-12-17 devnull recvp(c->internal);
675 49588d5d 2003-12-17 devnull msgput(m);
676 49588d5d 2003-12-17 devnull msgput(m);
678 32f69c36 2003-12-11 devnull fidput(fid);
679 32f69c36 2003-12-11 devnull c->fdfid = nil;
680 32f69c36 2003-12-11 devnull chanfree(c->internal);
681 32f69c36 2003-12-11 devnull c->internal = 0;
682 32f69c36 2003-12-11 devnull free(c);
686 32f69c36 2003-12-11 devnull xopenfd(Msg *m)
688 32f69c36 2003-12-11 devnull char errs[ERRMAX];
689 32f69c36 2003-12-11 devnull int n, p[2];
690 32f69c36 2003-12-11 devnull Conn *nc;
692 32f69c36 2003-12-11 devnull if(pipe(p) < 0){
693 32f69c36 2003-12-11 devnull rerrstr(errs, sizeof errs);
694 32f69c36 2003-12-11 devnull err(m, errs);
695 21e626de 2004-12-28 devnull /* XXX return here? */
697 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T xopen pipe %d %d...", p[0], p[1]);
699 32f69c36 2003-12-11 devnull /* now we're committed. */
701 32f69c36 2003-12-11 devnull /* a new connection for this fid */
702 32f69c36 2003-12-11 devnull nc = emalloc(sizeof(Conn));
703 32f69c36 2003-12-11 devnull nc->internal = chancreate(sizeof(void*), 0);
705 32f69c36 2003-12-11 devnull /* a ref for us */
706 32f69c36 2003-12-11 devnull nc->fdfid = m->fid;
707 32f69c36 2003-12-11 devnull m->fid->ref++;
708 21e626de 2004-12-28 devnull nc->fdfid->openfd++;
709 32f69c36 2003-12-11 devnull nc->fdmode = m->tx.mode;
710 32f69c36 2003-12-11 devnull nc->fd = p[0];
712 32f69c36 2003-12-11 devnull /* a thread to tend the pipe */
713 32f69c36 2003-12-11 devnull threadcreate(openfdthread, nc, STACK);
715 49588d5d 2003-12-17 devnull /* if mode is ORDWR, that openfdthread will write; start a reader */
716 49588d5d 2003-12-17 devnull if((m->tx.mode&3) == ORDWR){
717 49588d5d 2003-12-17 devnull nc = emalloc(sizeof(Conn));
718 49588d5d 2003-12-17 devnull nc->internal = chancreate(sizeof(void*), 0);
719 49588d5d 2003-12-17 devnull nc->fdfid = m->fid;
720 49588d5d 2003-12-17 devnull m->fid->ref++;
721 21e626de 2004-12-28 devnull nc->fdfid->openfd++;
722 49588d5d 2003-12-17 devnull nc->fdmode = OREAD;
723 49588d5d 2003-12-17 devnull nc->fd = dup(p[0], -1);
724 49588d5d 2003-12-17 devnull threadcreate(openfdthread, nc, STACK);
727 49588d5d 2003-12-17 devnull /* steal fid from other connection */
728 49588d5d 2003-12-17 devnull if(delhash(m->c->fid, m->fid->cfid, m->fid) == 0)
729 49588d5d 2003-12-17 devnull fidput(m->fid);
731 32f69c36 2003-12-11 devnull /* rewrite as Ropenfd */
732 32f69c36 2003-12-11 devnull m->rx.type = Ropenfd;
733 32f69c36 2003-12-11 devnull n = GBIT32(m->rpkt);
734 32f69c36 2003-12-11 devnull m->rpkt = erealloc(m->rpkt, n+4);
735 32f69c36 2003-12-11 devnull PBIT32(m->rpkt+n, p[1]);
737 32f69c36 2003-12-11 devnull PBIT32(m->rpkt, n);
738 32f69c36 2003-12-11 devnull m->rpkt[4] = Ropenfd;
739 32f69c36 2003-12-11 devnull m->rx.unixfd = p[1];
740 32f69c36 2003-12-11 devnull return 0;
744 d3df3087 2003-12-06 devnull connoutthread(void *arg)
746 215993f8 2005-09-13 devnull char *ename;
747 d3df3087 2003-12-06 devnull int err;
748 d3df3087 2003-12-06 devnull Conn *c;
749 05b7f431 2004-03-02 devnull Queue *outq;
750 d3df3087 2003-12-06 devnull Msg *m, *om;
751 ceb04770 2003-12-09 devnull Ioproc *io;
753 d3df3087 2003-12-06 devnull c = arg;
754 05b7f431 2004-03-02 devnull outq = c->outq;
755 ceb04770 2003-12-09 devnull io = ioproc();
756 7ffc5208 2004-12-28 devnull threadsetname("connout %s", c->dir);
757 05b7f431 2004-03-02 devnull while((m = recvq(outq)) != nil){
758 d3df3087 2003-12-06 devnull err = m->tx.type+1 != m->rx.type;
759 32f69c36 2003-12-11 devnull if(!err && m->isopenfd)
760 32f69c36 2003-12-11 devnull if(xopenfd(m) < 0)
761 32f69c36 2003-12-11 devnull continue;
762 d3df3087 2003-12-06 devnull switch(m->tx.type){
763 d3df3087 2003-12-06 devnull case Tflush:
764 d3df3087 2003-12-06 devnull om = m->oldm;
766 ceb04770 2003-12-09 devnull if(delhash(om->c->tag, om->ctag, om) == 0)
767 ceb04770 2003-12-09 devnull msgput(om);
769 d3df3087 2003-12-06 devnull case Tclunk:
770 ceb04770 2003-12-09 devnull case Tremove:
771 ceb04770 2003-12-09 devnull if(m->fid)
772 ceb04770 2003-12-09 devnull if(delhash(m->c->fid, m->fid->cfid, m->fid) == 0)
773 ceb04770 2003-12-09 devnull fidput(m->fid);
775 d3df3087 2003-12-06 devnull case Tauth:
776 ceb04770 2003-12-09 devnull if(err && m->afid){
777 80568494 2005-02-11 devnull if(verbose) fprint(2, "%T auth error\n");
778 ceb04770 2003-12-09 devnull if(delhash(m->c->fid, m->afid->cfid, m->afid) == 0)
779 80568494 2005-02-11 devnull fidput(m->afid);
782 d3df3087 2003-12-06 devnull case Tattach:
783 ceb04770 2003-12-09 devnull if(err && m->fid)
784 d3df3087 2003-12-06 devnull if(delhash(m->c->fid, m->fid->cfid, m->fid) == 0)
785 d3df3087 2003-12-06 devnull fidput(m->fid);
787 d3df3087 2003-12-06 devnull case Twalk:
788 5c84c448 2005-03-21 devnull if(err || m->rx.nwqid < m->tx.nwname)
789 5c84c448 2005-03-21 devnull if(m->tx.fid != m->tx.newfid && m->newfid)
790 d3df3087 2003-12-06 devnull if(delhash(m->c->fid, m->newfid->cfid, m->newfid) == 0)
791 d3df3087 2003-12-06 devnull fidput(m->newfid);
793 215993f8 2005-09-13 devnull case Tread:
794 215993f8 2005-09-13 devnull if(!err && m->fid->isdir && dotu && !m->c->dotu)
795 215993f8 2005-09-13 devnull stripudirread(m);
797 215993f8 2005-09-13 devnull case Tstat:
798 215993f8 2005-09-13 devnull if(!err && dotu && !m->c->dotu)
799 16c1defa 2005-11-12 devnull cvtustat(&m->rx, &m->rpkt, 0);
801 215993f8 2005-09-13 devnull case Topen:
802 215993f8 2005-09-13 devnull case Tcreate:
803 215993f8 2005-09-13 devnull m->fid->isdir = (m->rx.qid.type & QTDIR);
806 215993f8 2005-09-13 devnull if(m->rx.type==Rerror && dotu && !c->dotu){
807 215993f8 2005-09-13 devnull ename = estrdup(m->rx.ename);
808 215993f8 2005-09-13 devnull m->rx.ename = ename;
809 215993f8 2005-09-13 devnull repack(&m->rx, &m->rpkt, c->dotu);
810 215993f8 2005-09-13 devnull free(ename);
811 16c1defa 2005-11-12 devnull m->rx.ename = "XXX";
813 d3df3087 2003-12-06 devnull if(delhash(m->c->tag, m->ctag, m) == 0)
814 d3df3087 2003-12-06 devnull msgput(m);
815 e2a1725d 2005-01-04 devnull if(verbose > 1) fprint(2, "%T fd#%d <- %F\n", c->fd, &m->rx);
816 ceb04770 2003-12-09 devnull rewritehdr(&m->rx, m->rpkt);
817 ceb04770 2003-12-09 devnull if(mwrite9p(io, c->fd, m->rpkt) < 0)
818 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T write error: %r\n");
819 d3df3087 2003-12-06 devnull msgput(m);
820 d3df3087 2003-12-06 devnull if(c->inputstalled && c->nmsg < MAXMSG)
821 d3df3087 2003-12-06 devnull nbsendp(c->inc, 0);
823 ceb04770 2003-12-09 devnull closeioproc(io);
824 05b7f431 2004-03-02 devnull free(outq);
825 05b7f431 2004-03-02 devnull c->outq = nil;
829 d3df3087 2003-12-06 devnull outputthread(void *arg)
832 ceb04770 2003-12-09 devnull Ioproc *io;
834 d3df3087 2003-12-06 devnull USED(arg);
835 ceb04770 2003-12-09 devnull io = ioproc();
836 7ffc5208 2004-12-28 devnull threadsetname("output");
837 d3df3087 2003-12-06 devnull while((m = recvq(outq)) != nil){
838 e2a1725d 2005-01-04 devnull if(verbose > 1) fprint(2, "%T * <- %F\n", &m->tx);
839 ceb04770 2003-12-09 devnull rewritehdr(&m->tx, m->tpkt);
840 ceb04770 2003-12-09 devnull if(mwrite9p(io, 1, m->tpkt) < 0)
841 d3df3087 2003-12-06 devnull sysfatal("output error: %r");
842 d3df3087 2003-12-06 devnull msgput(m);
844 ceb04770 2003-12-09 devnull closeioproc(io);
845 e2a1725d 2005-01-04 devnull fprint(2, "%T output eof\n");
846 32f69c36 2003-12-11 devnull threadexitsall(0);
850 d3df3087 2003-12-06 devnull inputthread(void *arg)
852 d3df3087 2003-12-06 devnull uchar *pkt;
853 d3df3087 2003-12-06 devnull int n, nn, tag;
855 ceb04770 2003-12-09 devnull Ioproc *io;
857 7ffc5208 2004-12-28 devnull threadsetname("input");
858 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T input thread\n");
859 ceb04770 2003-12-09 devnull io = ioproc();
860 ceb04770 2003-12-09 devnull USED(arg);
861 ceb04770 2003-12-09 devnull while((pkt = read9ppkt(io, 0)) != nil){
862 d3df3087 2003-12-06 devnull n = GBIT32(pkt);
863 d3df3087 2003-12-06 devnull if(n < 7){
864 e2a1725d 2005-01-04 devnull fprint(2, "%T short 9P packet from server\n");
865 d3df3087 2003-12-06 devnull free(pkt);
866 d3df3087 2003-12-06 devnull continue;
868 e2a1725d 2005-01-04 devnull if(verbose > 2) fprint(2, "%T read %.*H\n", n, pkt);
869 d3df3087 2003-12-06 devnull tag = GBIT16(pkt+5);
870 d3df3087 2003-12-06 devnull if((m = msgget(tag)) == nil){
871 e2a1725d 2005-01-04 devnull fprint(2, "%T unexpected 9P response tag %d\n", tag);
872 d3df3087 2003-12-06 devnull free(pkt);
873 d3df3087 2003-12-06 devnull continue;
875 215993f8 2005-09-13 devnull if((nn = convM2Su(pkt, n, &m->rx, dotu)) != n){
876 e2a1725d 2005-01-04 devnull fprint(2, "%T bad packet - convM2S %d but %d\n", nn, n);
877 d3df3087 2003-12-06 devnull free(pkt);
878 d3df3087 2003-12-06 devnull msgput(m);
879 d3df3087 2003-12-06 devnull continue;
881 e2a1725d 2005-01-04 devnull if(verbose > 1) fprint(2, "%T * -> %F%s\n", &m->rx,
882 05b7f431 2004-03-02 devnull m->internal ? " (internal)" : "");
883 d3df3087 2003-12-06 devnull m->rpkt = pkt;
884 d3df3087 2003-12-06 devnull m->rx.tag = m->ctag;
885 ceb04770 2003-12-09 devnull if(m->internal)
886 05b7f431 2004-03-02 devnull sendp(m->c->internal, m);
887 05b7f431 2004-03-02 devnull else if(m->c->outq)
888 ceb04770 2003-12-09 devnull sendq(m->c->outq, m);
890 05b7f431 2004-03-02 devnull msgput(m);
892 ceb04770 2003-12-09 devnull closeioproc(io);
893 e2a1725d 2005-01-04 devnull //fprint(2, "%T input eof\n");
894 32f69c36 2003-12-11 devnull threadexitsall(0);
898 d3df3087 2003-12-06 devnull gethash(Hash **ht, uint n)
900 d3df3087 2003-12-06 devnull Hash *h;
902 d3df3087 2003-12-06 devnull for(h=ht[n%NHASH]; h; h=h->next)
903 d3df3087 2003-12-06 devnull if(h->n == n)
904 d3df3087 2003-12-06 devnull return h->v;
905 d3df3087 2003-12-06 devnull return nil;
909 d3df3087 2003-12-06 devnull delhash(Hash **ht, uint n, void *v)
911 d3df3087 2003-12-06 devnull Hash *h, **l;
913 d3df3087 2003-12-06 devnull for(l=&ht[n%NHASH]; h=*l; l=&h->next)
914 d3df3087 2003-12-06 devnull if(h->n == n){
915 ceb04770 2003-12-09 devnull if(h->v != v){
916 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T delhash %d got %p want %p\n", n, h->v, v);
917 ceb04770 2003-12-09 devnull return -1;
919 d3df3087 2003-12-06 devnull *l = h->next;
920 d3df3087 2003-12-06 devnull free(h);
921 d3df3087 2003-12-06 devnull return 0;
923 d3df3087 2003-12-06 devnull return -1;
927 d3df3087 2003-12-06 devnull puthash(Hash **ht, uint n, void *v)
929 d3df3087 2003-12-06 devnull Hash *h;
931 d3df3087 2003-12-06 devnull if(gethash(ht, n))
932 d3df3087 2003-12-06 devnull return -1;
933 d3df3087 2003-12-06 devnull h = emalloc(sizeof(Hash));
934 d3df3087 2003-12-06 devnull h->next = ht[n%NHASH];
935 d3df3087 2003-12-06 devnull h->n = n;
936 d3df3087 2003-12-06 devnull h->v = v;
937 d3df3087 2003-12-06 devnull ht[n%NHASH] = h;
938 d3df3087 2003-12-06 devnull return 0;
941 d3df3087 2003-12-06 devnull Fid **fidtab;
942 d3df3087 2003-12-06 devnull int nfidtab;
943 d3df3087 2003-12-06 devnull Fid *freefid;
946 d3df3087 2003-12-06 devnull fidnew(int cfid)
950 d3df3087 2003-12-06 devnull if(freefid == nil){
951 ceb04770 2003-12-09 devnull fidtab = erealloc(fidtab, (nfidtab+1)*sizeof(fidtab[0]));
952 5c84c448 2005-03-21 devnull if(nfidtab == xafid){
953 5c84c448 2005-03-21 devnull fidtab[nfidtab++] = nil;
954 5c84c448 2005-03-21 devnull fidtab = erealloc(fidtab, (nfidtab+1)*sizeof(fidtab[0]));
956 d3df3087 2003-12-06 devnull fidtab[nfidtab] = emalloc(sizeof(Fid));
957 ceb04770 2003-12-09 devnull freefid = fidtab[nfidtab];
958 ceb04770 2003-12-09 devnull freefid->fid = nfidtab++;
960 d3df3087 2003-12-06 devnull f = freefid;
961 d3df3087 2003-12-06 devnull freefid = f->next;
962 ceb04770 2003-12-09 devnull f->cfid = cfid;
963 d3df3087 2003-12-06 devnull f->ref = 1;
964 215993f8 2005-09-13 devnull f->isdir = -1;
965 d3df3087 2003-12-06 devnull return f;
969 d3df3087 2003-12-06 devnull fidput(Fid *f)
971 ceb04770 2003-12-09 devnull if(f == nil)
973 d3df3087 2003-12-06 devnull assert(f->ref > 0);
974 d3df3087 2003-12-06 devnull if(--f->ref > 0)
976 d3df3087 2003-12-06 devnull f->next = freefid;
977 d3df3087 2003-12-06 devnull f->cfid = -1;
978 d3df3087 2003-12-06 devnull freefid = f;
981 d3df3087 2003-12-06 devnull Msg **msgtab;
982 d3df3087 2003-12-06 devnull int nmsgtab;
983 16c1defa 2005-11-12 devnull int nmsg;
984 d3df3087 2003-12-06 devnull Msg *freemsg;
987 e2a1725d 2005-01-04 devnull msgincref(Msg *m)
989 e2a1725d 2005-01-04 devnull if(verbose > 1) fprint(2, "%T msgincref @0x%lux %p tag %d/%d ref %d=>%d\n",
990 e2a1725d 2005-01-04 devnull getcallerpc(&m), m, m->tag, m->ctag, m->ref, m->ref+1);
991 e2a1725d 2005-01-04 devnull m->ref++;
995 e2a1725d 2005-01-04 devnull msgnew(int x)
999 d3df3087 2003-12-06 devnull if(freemsg == nil){
1000 ceb04770 2003-12-09 devnull msgtab = erealloc(msgtab, (nmsgtab+1)*sizeof(msgtab[0]));
1001 d3df3087 2003-12-06 devnull msgtab[nmsgtab] = emalloc(sizeof(Msg));
1002 ceb04770 2003-12-09 devnull freemsg = msgtab[nmsgtab];
1003 ceb04770 2003-12-09 devnull freemsg->tag = nmsgtab++;
1005 d3df3087 2003-12-06 devnull m = freemsg;
1006 d3df3087 2003-12-06 devnull freemsg = m->next;
1007 d3df3087 2003-12-06 devnull m->ref = 1;
1008 e2a1725d 2005-01-04 devnull if(verbose > 1) fprint(2, "%T msgnew @0x%lux %p tag %d ref %d\n",
1009 e2a1725d 2005-01-04 devnull getcallerpc(&x), m, m->tag, m->ref);
1010 16c1defa 2005-11-12 devnull nmsg++;
1011 d3df3087 2003-12-06 devnull return m;
1015 e2a1725d 2005-01-04 devnull * Clear data associated with connections, so that
1016 e2a1725d 2005-01-04 devnull * if all msgs have been msgcleared, the connection
1017 e2a1725d 2005-01-04 devnull * can be freed. Note that this does *not* free the tpkt
1018 e2a1725d 2005-01-04 devnull * and rpkt; they are freed in msgput with the msg itself.
1019 e2a1725d 2005-01-04 devnull * The io write thread might still be holding a ref to msg
1020 e2a1725d 2005-01-04 devnull * even once the connection has finished with it.
1023 e2a1725d 2005-01-04 devnull msgclear(Msg *m)
1025 e2a1725d 2005-01-04 devnull if(m->c){
1026 e2a1725d 2005-01-04 devnull m->c->nmsg--;
1027 e2a1725d 2005-01-04 devnull m->c = nil;
1029 e2a1725d 2005-01-04 devnull if(m->oldm){
1030 e2a1725d 2005-01-04 devnull msgput(m->oldm);
1031 e2a1725d 2005-01-04 devnull m->oldm = nil;
1033 e2a1725d 2005-01-04 devnull if(m->fid){
1034 e2a1725d 2005-01-04 devnull fidput(m->fid);
1035 e2a1725d 2005-01-04 devnull m->fid = nil;
1037 e2a1725d 2005-01-04 devnull if(m->afid){
1038 e2a1725d 2005-01-04 devnull fidput(m->afid);
1039 e2a1725d 2005-01-04 devnull m->afid = nil;
1041 e2a1725d 2005-01-04 devnull if(m->newfid){
1042 e2a1725d 2005-01-04 devnull fidput(m->newfid);
1043 e2a1725d 2005-01-04 devnull m->newfid = nil;
1045 e2a1725d 2005-01-04 devnull if(m->rx.type == Ropenfd && m->rx.unixfd >= 0){
1046 e2a1725d 2005-01-04 devnull close(m->rx.unixfd);
1047 e2a1725d 2005-01-04 devnull m->rx.unixfd = -1;
1052 d3df3087 2003-12-06 devnull msgput(Msg *m)
1054 05b7f431 2004-03-02 devnull if(m == nil)
1055 05b7f431 2004-03-02 devnull return;
1057 e2a1725d 2005-01-04 devnull if(verbose > 1) fprint(2, "%T msgput 0x%lux %p tag %d/%d ref %d\n",
1058 e2a1725d 2005-01-04 devnull getcallerpc(&m), m, m->tag, m->ctag, m->ref);
1059 d3df3087 2003-12-06 devnull assert(m->ref > 0);
1060 d3df3087 2003-12-06 devnull if(--m->ref > 0)
1061 d3df3087 2003-12-06 devnull return;
1062 16c1defa 2005-11-12 devnull nmsg--;
1063 e2a1725d 2005-01-04 devnull msgclear(m);
1064 e2a1725d 2005-01-04 devnull if(m->tpkt){
1065 e2a1725d 2005-01-04 devnull free(m->tpkt);
1066 e2a1725d 2005-01-04 devnull m->tpkt = nil;
1068 e2a1725d 2005-01-04 devnull if(m->rpkt){
1069 e2a1725d 2005-01-04 devnull free(m->rpkt);
1070 e2a1725d 2005-01-04 devnull m->rpkt = nil;
1072 32f69c36 2003-12-11 devnull m->isopenfd = 0;
1073 32f69c36 2003-12-11 devnull m->internal = 0;
1074 d3df3087 2003-12-06 devnull m->next = freemsg;
1075 d3df3087 2003-12-06 devnull freemsg = m;
1079 ceb04770 2003-12-09 devnull msgget(int n)
1081 ceb04770 2003-12-09 devnull Msg *m;
1083 ceb04770 2003-12-09 devnull if(n < 0 || n >= nmsgtab)
1084 ceb04770 2003-12-09 devnull return nil;
1085 ceb04770 2003-12-09 devnull m = msgtab[n];
1086 ceb04770 2003-12-09 devnull if(m->ref == 0)
1087 ceb04770 2003-12-09 devnull return nil;
1088 e2a1725d 2005-01-04 devnull if(verbose) fprint(2, "%T msgget %d = %p\n", n, m);
1089 e2a1725d 2005-01-04 devnull msgincref(m);
1090 ceb04770 2003-12-09 devnull return m;
1095 d3df3087 2003-12-06 devnull emalloc(int n)
1097 d3df3087 2003-12-06 devnull void *v;
1099 d3df3087 2003-12-06 devnull v = mallocz(n, 1);
1100 ceb04770 2003-12-09 devnull if(v == nil){
1101 ceb04770 2003-12-09 devnull abort();
1102 ceb04770 2003-12-09 devnull sysfatal("out of memory allocating %d", n);
1104 d3df3087 2003-12-06 devnull return v;
1108 d3df3087 2003-12-06 devnull erealloc(void *v, int n)
1110 d3df3087 2003-12-06 devnull v = realloc(v, n);
1111 ceb04770 2003-12-09 devnull if(v == nil){
1112 ceb04770 2003-12-09 devnull abort();
1113 ceb04770 2003-12-09 devnull sysfatal("out of memory reallocating %d", n);
1115 d3df3087 2003-12-06 devnull return v;
1118 d3df3087 2003-12-06 devnull typedef struct Qel Qel;
1119 d3df3087 2003-12-06 devnull struct Qel
1121 d3df3087 2003-12-06 devnull Qel *next;
1122 d3df3087 2003-12-06 devnull void *p;
1125 d3df3087 2003-12-06 devnull struct Queue
1127 d3df3087 2003-12-06 devnull int hungup;
1128 d3df3087 2003-12-06 devnull QLock lk;
1129 d3df3087 2003-12-06 devnull Rendez r;
1130 d3df3087 2003-12-06 devnull Qel *head;
1131 d3df3087 2003-12-06 devnull Qel *tail;
1135 d3df3087 2003-12-06 devnull qalloc(void)
1137 d3df3087 2003-12-06 devnull Queue *q;
1139 d3df3087 2003-12-06 devnull q = mallocz(sizeof(Queue), 1);
1140 d3df3087 2003-12-06 devnull if(q == nil)
1141 d3df3087 2003-12-06 devnull return nil;
1142 d3df3087 2003-12-06 devnull q->r.l = &q->lk;
1143 d3df3087 2003-12-06 devnull return q;
1147 d3df3087 2003-12-06 devnull sendq(Queue *q, void *p)
1149 d3df3087 2003-12-06 devnull Qel *e;
1151 d3df3087 2003-12-06 devnull e = emalloc(sizeof(Qel));
1152 d3df3087 2003-12-06 devnull qlock(&q->lk);
1153 d3df3087 2003-12-06 devnull if(q->hungup){
1154 16c1defa 2005-11-12 devnull free(e);
1155 d3df3087 2003-12-06 devnull werrstr("hungup queue");
1156 d3df3087 2003-12-06 devnull qunlock(&q->lk);
1157 d3df3087 2003-12-06 devnull return -1;
1159 d3df3087 2003-12-06 devnull e->p = p;
1160 d3df3087 2003-12-06 devnull e->next = nil;
1161 d3df3087 2003-12-06 devnull if(q->head == nil)
1162 d3df3087 2003-12-06 devnull q->head = e;
1164 d3df3087 2003-12-06 devnull q->tail->next = e;
1165 d3df3087 2003-12-06 devnull q->tail = e;
1166 d3df3087 2003-12-06 devnull rwakeup(&q->r);
1167 d3df3087 2003-12-06 devnull qunlock(&q->lk);
1168 d3df3087 2003-12-06 devnull return 0;
1172 d3df3087 2003-12-06 devnull recvq(Queue *q)
1174 d3df3087 2003-12-06 devnull void *p;
1175 d3df3087 2003-12-06 devnull Qel *e;
1177 d3df3087 2003-12-06 devnull qlock(&q->lk);
1178 d3df3087 2003-12-06 devnull while(q->head == nil && !q->hungup)
1179 d3df3087 2003-12-06 devnull rsleep(&q->r);
1180 d3df3087 2003-12-06 devnull if(q->hungup){
1181 d3df3087 2003-12-06 devnull qunlock(&q->lk);
1182 d3df3087 2003-12-06 devnull return nil;
1184 d3df3087 2003-12-06 devnull e = q->head;
1185 d3df3087 2003-12-06 devnull q->head = e->next;
1186 d3df3087 2003-12-06 devnull qunlock(&q->lk);
1187 d3df3087 2003-12-06 devnull p = e->p;
1188 d3df3087 2003-12-06 devnull free(e);
1189 d3df3087 2003-12-06 devnull return p;
1193 ceb04770 2003-12-09 devnull read9ppkt(Ioproc *io, int fd)
1195 ceb04770 2003-12-09 devnull uchar buf[4], *pkt;
1196 ceb04770 2003-12-09 devnull int n, nn;
1198 ceb04770 2003-12-09 devnull n = ioreadn(io, fd, buf, 4);
1199 ceb04770 2003-12-09 devnull if(n != 4)
1200 ceb04770 2003-12-09 devnull return nil;
1201 ceb04770 2003-12-09 devnull n = GBIT32(buf);
1202 ceb04770 2003-12-09 devnull pkt = emalloc(n);
1203 ceb04770 2003-12-09 devnull PBIT32(pkt, n);
1204 ceb04770 2003-12-09 devnull nn = ioreadn(io, fd, pkt+4, n-4);
1205 ceb04770 2003-12-09 devnull if(nn != n-4){
1206 ceb04770 2003-12-09 devnull free(pkt);
1207 ceb04770 2003-12-09 devnull return nil;
1209 32f69c36 2003-12-11 devnull /* would do this if we ever got one of these, but we only generate them
1210 32f69c36 2003-12-11 devnull if(pkt[4] == Ropenfd){
1211 32f69c36 2003-12-11 devnull newfd = iorecvfd(io, fd);
1212 32f69c36 2003-12-11 devnull PBIT32(pkt+n-4, newfd);
1215 ceb04770 2003-12-09 devnull return pkt;
1219 215993f8 2005-09-13 devnull mread9p(Ioproc *io, int fd, int dotu)
1221 ceb04770 2003-12-09 devnull int n, nn;
1222 ceb04770 2003-12-09 devnull uchar *pkt;
1223 ceb04770 2003-12-09 devnull Msg *m;
1225 ceb04770 2003-12-09 devnull if((pkt = read9ppkt(io, fd)) == nil)
1226 ceb04770 2003-12-09 devnull return nil;
1228 e2a1725d 2005-01-04 devnull m = msgnew(0);
1229 ceb04770 2003-12-09 devnull m->tpkt = pkt;
1230 ceb04770 2003-12-09 devnull n = GBIT32(pkt);
1231 215993f8 2005-09-13 devnull nn = convM2Su(pkt, n, &m->tx, dotu);
1232 ceb04770 2003-12-09 devnull if(nn != n){
1233 e2a1725d 2005-01-04 devnull fprint(2, "%T read bad packet from %d\n", fd);
1234 ceb04770 2003-12-09 devnull return nil;
1236 ceb04770 2003-12-09 devnull return m;
1240 ceb04770 2003-12-09 devnull mwrite9p(Ioproc *io, int fd, uchar *pkt)
1242 32f69c36 2003-12-11 devnull int n, nfd;
1244 ceb04770 2003-12-09 devnull n = GBIT32(pkt);
1245 e2a1725d 2005-01-04 devnull if(verbose > 2) fprint(2, "%T write %d %d %.*H\n", fd, n, n, pkt);
1246 bb426e77 2005-01-06 devnull if(verbose > 1) fprint(2, "%T before iowrite\n");
1247 ceb04770 2003-12-09 devnull if(iowrite(io, fd, pkt, n) != n){
1248 e2a1725d 2005-01-04 devnull fprint(2, "%T write error: %r\n");
1249 ceb04770 2003-12-09 devnull return -1;
1251 bb426e77 2005-01-06 devnull if(verbose > 1) fprint(2, "%T after iowrite\n");
1252 32f69c36 2003-12-11 devnull if(pkt[4] == Ropenfd){
1253 32f69c36 2003-12-11 devnull nfd = GBIT32(pkt+n-4);
1254 32f69c36 2003-12-11 devnull if(iosendfd(io, fd, nfd) < 0){
1255 e2a1725d 2005-01-04 devnull fprint(2, "%T send fd error: %r\n");
1256 32f69c36 2003-12-11 devnull return -1;
1259 ceb04770 2003-12-09 devnull return 0;
1263 ceb04770 2003-12-09 devnull restring(uchar *pkt, int pn, char *s)
1267 ceb04770 2003-12-09 devnull if(s < (char*)pkt || s >= (char*)pkt+pn)
1268 ceb04770 2003-12-09 devnull return;
1270 ceb04770 2003-12-09 devnull n = strlen(s);
1271 ceb04770 2003-12-09 devnull memmove(s+1, s, n);
1272 ceb04770 2003-12-09 devnull PBIT16((uchar*)s-1, n);
1276 215993f8 2005-09-13 devnull repack(Fcall *f, uchar **ppkt, int dotu)
1278 5c84c448 2005-03-21 devnull uint n, nn;
1279 5c84c448 2005-03-21 devnull uchar *pkt;
1281 5c84c448 2005-03-21 devnull pkt = *ppkt;
1282 5c84c448 2005-03-21 devnull n = GBIT32(pkt);
1283 215993f8 2005-09-13 devnull nn = sizeS2Mu(f, dotu);
1284 5c84c448 2005-03-21 devnull if(nn > n){
1285 5c84c448 2005-03-21 devnull free(pkt);
1286 5c84c448 2005-03-21 devnull pkt = emalloc(nn);
1287 5c84c448 2005-03-21 devnull *ppkt = pkt;
1289 9e2f1d9b 2005-11-21 devnull n = convS2Mu(f, pkt, nn, dotu);
1290 9e2f1d9b 2005-11-21 devnull if(n <= BIT16SZ)
1291 9e2f1d9b 2005-11-21 devnull sysfatal("convS2M conversion error");
1292 9e2f1d9b 2005-11-21 devnull if(n != nn)
1293 9e2f1d9b 2005-11-21 devnull sysfatal("convS2Mu and sizeS2Mu disagree");
1297 ceb04770 2003-12-09 devnull rewritehdr(Fcall *f, uchar *pkt)
1299 ceb04770 2003-12-09 devnull int i, n;
1301 ceb04770 2003-12-09 devnull n = GBIT32(pkt);
1302 ceb04770 2003-12-09 devnull PBIT16(pkt+5, f->tag);
1303 ceb04770 2003-12-09 devnull switch(f->type){
1304 ceb04770 2003-12-09 devnull case Tversion:
1305 ceb04770 2003-12-09 devnull case Rversion:
1306 ceb04770 2003-12-09 devnull restring(pkt, n, f->version);
1308 ceb04770 2003-12-09 devnull case Tauth:
1309 ceb04770 2003-12-09 devnull PBIT32(pkt+7, f->afid);
1310 ceb04770 2003-12-09 devnull restring(pkt, n, f->uname);
1311 ceb04770 2003-12-09 devnull restring(pkt, n, f->aname);
1313 ceb04770 2003-12-09 devnull case Tflush:
1314 ceb04770 2003-12-09 devnull PBIT16(pkt+7, f->oldtag);
1316 ceb04770 2003-12-09 devnull case Tattach:
1317 ceb04770 2003-12-09 devnull restring(pkt, n, f->uname);
1318 ceb04770 2003-12-09 devnull restring(pkt, n, f->aname);
1319 ceb04770 2003-12-09 devnull PBIT32(pkt+7, f->fid);
1320 ceb04770 2003-12-09 devnull PBIT32(pkt+11, f->afid);
1322 ceb04770 2003-12-09 devnull case Twalk:
1323 ceb04770 2003-12-09 devnull PBIT32(pkt+7, f->fid);
1324 ceb04770 2003-12-09 devnull PBIT32(pkt+11, f->newfid);
1325 ceb04770 2003-12-09 devnull for(i=0; i<f->nwname; i++)
1326 ceb04770 2003-12-09 devnull restring(pkt, n, f->wname[i]);
1328 ceb04770 2003-12-09 devnull case Tcreate:
1329 ceb04770 2003-12-09 devnull restring(pkt, n, f->name);
1330 ceb04770 2003-12-09 devnull /* fall through */
1331 ceb04770 2003-12-09 devnull case Topen:
1332 ceb04770 2003-12-09 devnull case Tread:
1333 ceb04770 2003-12-09 devnull case Twrite:
1334 ceb04770 2003-12-09 devnull case Tclunk:
1335 ceb04770 2003-12-09 devnull case Tremove:
1336 ceb04770 2003-12-09 devnull case Tstat:
1337 ceb04770 2003-12-09 devnull case Twstat:
1338 ceb04770 2003-12-09 devnull PBIT32(pkt+7, f->fid);
1340 ceb04770 2003-12-09 devnull case Rerror:
1341 ceb04770 2003-12-09 devnull restring(pkt, n, f->ename);
1346 32f69c36 2003-12-11 devnull static long
1347 ceb04770 2003-12-09 devnull _iolisten(va_list *arg)
1349 ceb04770 2003-12-09 devnull char *a, *b;
1351 ceb04770 2003-12-09 devnull a = va_arg(*arg, char*);
1352 ceb04770 2003-12-09 devnull b = va_arg(*arg, char*);
1353 ceb04770 2003-12-09 devnull return listen(a, b);
1357 ceb04770 2003-12-09 devnull iolisten(Ioproc *io, char *a, char *b)
1359 ceb04770 2003-12-09 devnull return iocall(io, _iolisten, a, b);
1362 ceb04770 2003-12-09 devnull static long
1363 ceb04770 2003-12-09 devnull _ioaccept(va_list *arg)
1365 ceb04770 2003-12-09 devnull int fd;
1366 ceb04770 2003-12-09 devnull char *dir;
1368 ceb04770 2003-12-09 devnull fd = va_arg(*arg, int);
1369 ceb04770 2003-12-09 devnull dir = va_arg(*arg, char*);
1370 ceb04770 2003-12-09 devnull return accept(fd, dir);
1374 ceb04770 2003-12-09 devnull ioaccept(Ioproc *io, int fd, char *dir)
1376 ceb04770 2003-12-09 devnull return iocall(io, _ioaccept, fd, dir);
1380 e2a1725d 2005-01-04 devnull timefmt(Fmt *fmt)
1382 e2a1725d 2005-01-04 devnull static char *mon[] = { "Jan", "Feb", "Mar", "Apr", "May", "Jun",
1383 e2a1725d 2005-01-04 devnull "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" };
1384 bb426e77 2005-01-06 devnull vlong ns;
1386 bb426e77 2005-01-06 devnull ns = nsec();
1387 e2a1725d 2005-01-04 devnull tm = *localtime(time(0));
1388 bb426e77 2005-01-06 devnull return fmtprint(fmt, "%s %2d %02d:%02d:%02d.%03d",
1389 bb426e77 2005-01-06 devnull mon[tm.mon], tm.mday, tm.hour, tm.min, tm.sec,
1390 bb426e77 2005-01-06 devnull (int)(ns%1000000000)/1000000);
1394 16c1defa 2005-11-12 devnull cvtustat(Fcall *f, uchar **fpkt, int tounix)
1397 23e7c657 2005-09-13 devnull uchar *buf;
1398 215993f8 2005-09-13 devnull char *str;
1399 215993f8 2005-09-13 devnull Dir dir;
1401 215993f8 2005-09-13 devnull str = emalloc(f->nstat);
1402 16c1defa 2005-11-12 devnull n = convM2Du(f->stat, f->nstat, &dir, str, !tounix);
1403 16c1defa 2005-11-12 devnull if(n <= BIT16SZ){
1404 16c1defa 2005-11-12 devnull free(str);
1405 215993f8 2005-09-13 devnull return -1;
1408 16c1defa 2005-11-12 devnull n = sizeD2Mu(&dir, tounix);
1409 16c1defa 2005-11-12 devnull buf = emalloc(n);
1410 9e2f1d9b 2005-11-21 devnull if(convD2Mu(&dir, buf, n, tounix) != n)
1411 9e2f1d9b 2005-11-21 devnull sysfatal("convD2Mu conversion error");
1412 215993f8 2005-09-13 devnull f->nstat = n;
1413 215993f8 2005-09-13 devnull f->stat = buf;
1415 215993f8 2005-09-13 devnull repack(f, fpkt, dotu);
1416 215993f8 2005-09-13 devnull free(buf);
1417 16c1defa 2005-11-12 devnull f->stat = nil; /* is this okay ??? */
1418 215993f8 2005-09-13 devnull free(str);
1420 215993f8 2005-09-13 devnull return 0;
1424 215993f8 2005-09-13 devnull stripudirread(Msg* msg)
1426 23e7c657 2005-09-13 devnull char *str;
1427 215993f8 2005-09-13 devnull int i, m, n, nn;
1428 23e7c657 2005-09-13 devnull uchar *buf;
1430 215993f8 2005-09-13 devnull Fcall* rx;
1432 215993f8 2005-09-13 devnull buf = nil;
1433 215993f8 2005-09-13 devnull str = nil;
1434 215993f8 2005-09-13 devnull rx = &msg->rx;
1436 215993f8 2005-09-13 devnull nn = 0;
1437 215993f8 2005-09-13 devnull for(i = 0; i < rx->count; i += m){
1438 215993f8 2005-09-13 devnull m = BIT16SZ + GBIT16(&rx->data[i]);
1439 54705b4a 2005-09-13 devnull if(statchecku((uchar*)&rx->data[i], m, 1) < 0)
1440 215993f8 2005-09-13 devnull return -1;
1441 215993f8 2005-09-13 devnull if(nn < m)
1442 215993f8 2005-09-13 devnull nn = m;
1446 215993f8 2005-09-13 devnull str = emalloc(nn);
1447 215993f8 2005-09-13 devnull buf = emalloc(rx->count);
1449 215993f8 2005-09-13 devnull nn = 0;
1450 215993f8 2005-09-13 devnull for(i = 0; i < rx->count; i += m){
1451 215993f8 2005-09-13 devnull m = BIT16SZ + GBIT16(&rx->data[i]);
1452 54705b4a 2005-09-13 devnull if(convM2Du((uchar*)&rx->data[i], m, &d, str, 1) != m){
1453 215993f8 2005-09-13 devnull free(buf);
1454 215993f8 2005-09-13 devnull free(str);
1455 215993f8 2005-09-13 devnull return -1;
1458 215993f8 2005-09-13 devnull n = convD2M(&d, &buf[nn], rx->count - nn);
1459 215993f8 2005-09-13 devnull if(n <= BIT16SZ){
1460 215993f8 2005-09-13 devnull free(buf);
1461 215993f8 2005-09-13 devnull free(str);
1462 215993f8 2005-09-13 devnull return -1;
1465 215993f8 2005-09-13 devnull nn += n;
1468 215993f8 2005-09-13 devnull rx->count = nn;
1469 54705b4a 2005-09-13 devnull rx->data = (char*)buf;
1471 215993f8 2005-09-13 devnull repack(&msg->rx, &msg->rpkt, 0);
1472 215993f8 2005-09-13 devnull free(str);
1473 215993f8 2005-09-13 devnull free(buf);
1474 16c1defa 2005-11-12 devnull rx->data = nil; /* is this okay ??? */
1476 215993f8 2005-09-13 devnull return 0;
