3 static char *tnames[] = {
19 int messagesize = IOHDRSZ+Maxfdata;
22 xmesg(Session *s, int t)
27 if(0 <= t && t < nelem(tnames) && tnames[t])
28 chat("T%s...", tnames[t]);
35 fprint(2, "xmseg\tsend %F\n", &s->f);
36 n = convS2M(&s->f, s->data, messagesize);
37 if(niwrite(s->fd, s->data, n) != n){
38 clog("xmesg write error on %d: %r\n", s->fd);
42 n = read9pmsg(s->fd, s->data, messagesize);
44 clog("xmesg read error: %r\n");
47 if(convM2S(s->data, n, &s->f) <= 0){
48 clog("xmesg bad convM2S %d %.2x %.2x %.2x %.2x\n",
49 n, ((uchar*)s->data)[0], ((uchar*)s->data)[1],
50 ((uchar*)s->data)[2], ((uchar*)s->data)[3]);
54 fprint(2, "\trecv %F\n", &s->f);
55 if(s->f.tag != s->tag){
56 clog("xmesg tag %d for %d\n", s->f.tag, s->tag);
59 if(s->f.type == Rerror){
61 clog("xmesg clunk: %s", s->f.ename);
62 chat("xmesg %d error %s...", t, s->f.ename);
66 clog("xmesg type mismatch: %d, expected %d\n", s->f.type, t+1);
73 clunkfid(Session *s, Fid *f)
78 s->f.fid = f - s->fids;
79 return xmesg(s, Tclunk);
82 #define UNLINK(p) ((p)->prev->next = (p)->next, (p)->next->prev = (p)->prev)
84 #define LINK(h, p) ((p)->next = (h)->next, (p)->prev = (h), \
85 (h)->next->prev = (p), (h)->next = (p))
87 #define TOFRONT(h, p) ((h)->next != (p) ? (UNLINK(p), LINK(h,p)) : 0)
95 if(s->list.prev == 0){
97 s->list.prev = &s->list;
98 s->list.next = &s->list;
103 fN = &s->fids[nelem(s->fids)];
104 for(f=s->fids; f<fN; f++){
116 for(f=s->list.prev; f!=&s->list; f=f->prev)
124 if(xmesg(s, Tclunk) < 0){
125 clog("clunk failed, no fids?");
131 chat("%ld...", f - s->fids);
132 f->tstale = nfstime + staletime;
137 setfid(Session *s, Fid *f)
140 * TOFRONT(&s->list, f);
142 if(s->list.next != f){
147 f->tstale = nfstime + staletime;
148 s->f.fid = f - s->fids;
152 putfid(Session *s, Fid *f)
154 chat("putfid %ld...", f-s->fids);
155 if(s == 0 || f == 0){
156 clog("putfid(0x%p, 0x%p) %s", s, f, (s ? s->service : "?"));
169 fidtimer(Session *s, long now)
176 while(f != &s->list){
179 if(t->owner && now >= t->tstale)
183 chat("fidtimer %s\n", s->service);