1 2277c5d7 2004-03-21 devnull #include <u.h>
2 2277c5d7 2004-03-21 devnull #include <libc.h>
3 2277c5d7 2004-03-21 devnull #include <auth.h>
4 2277c5d7 2004-03-21 devnull #include <fcall.h>
5 2277c5d7 2004-03-21 devnull #include <thread.h>
6 2277c5d7 2004-03-21 devnull #include <9p.h>
8 2277c5d7 2004-03-21 devnull static void
9 2277c5d7 2004-03-21 devnull increqref(void *v)
15 2277c5d7 2004-03-21 devnull if(chatty9p > 1)
16 2277c5d7 2004-03-21 devnull fprint(2, "increfreq %p %ld\n", r, r->ref.ref);
17 2277c5d7 2004-03-21 devnull incref(&r->ref);
22 2277c5d7 2004-03-21 devnull allocreqpool(void (*destroy)(Req*))
24 2277c5d7 2004-03-21 devnull Reqpool *f;
26 2277c5d7 2004-03-21 devnull f = emalloc9p(sizeof *f);
27 2277c5d7 2004-03-21 devnull f->map = allocmap(increqref);
28 2277c5d7 2004-03-21 devnull f->destroy = destroy;
29 2277c5d7 2004-03-21 devnull return f;
33 2277c5d7 2004-03-21 devnull freereqpool(Reqpool *p)
35 2277c5d7 2004-03-21 devnull freemap(p->map, (void(*)(void*))p->destroy);
40 2277c5d7 2004-03-21 devnull allocreq(Reqpool *pool, ulong tag)
44 2277c5d7 2004-03-21 devnull r = emalloc9p(sizeof *r);
45 2277c5d7 2004-03-21 devnull r->tag = tag;
46 2277c5d7 2004-03-21 devnull r->pool = pool;
48 2277c5d7 2004-03-21 devnull increqref(r);
49 2277c5d7 2004-03-21 devnull increqref(r);
50 2277c5d7 2004-03-21 devnull if(caninsertkey(pool->map, tag, r) == 0){
51 2277c5d7 2004-03-21 devnull closereq(r);
52 2277c5d7 2004-03-21 devnull return nil;
55 2277c5d7 2004-03-21 devnull return r;
59 2277c5d7 2004-03-21 devnull lookupreq(Reqpool *pool, ulong tag)
61 2277c5d7 2004-03-21 devnull if(chatty9p > 1)
62 2277c5d7 2004-03-21 devnull fprint(2, "lookupreq %lud\n", tag);
63 2277c5d7 2004-03-21 devnull return lookupkey(pool->map, tag);
67 2277c5d7 2004-03-21 devnull closereq(Req *r)
71 2277c5d7 2004-03-21 devnull if(r == nil)
74 2277c5d7 2004-03-21 devnull if(chatty9p > 1)
75 2277c5d7 2004-03-21 devnull fprint(2, "closereq %p %ld\n", r, r->ref.ref);
77 2277c5d7 2004-03-21 devnull if(decref(&r->ref) == 0){
78 2277c5d7 2004-03-21 devnull if(r->fid)
79 2277c5d7 2004-03-21 devnull closefid(r->fid);
80 2277c5d7 2004-03-21 devnull if(r->newfid)
81 2277c5d7 2004-03-21 devnull closefid(r->newfid);
82 2277c5d7 2004-03-21 devnull if(r->afid)
83 2277c5d7 2004-03-21 devnull closefid(r->afid);
84 2277c5d7 2004-03-21 devnull if(r->oldreq)
85 2277c5d7 2004-03-21 devnull closereq(r->oldreq);
86 2277c5d7 2004-03-21 devnull for(i=0; i<r->nflush; i++)
87 2277c5d7 2004-03-21 devnull respond(r->flush[i], nil);
88 2277c5d7 2004-03-21 devnull free(r->flush);
89 2277c5d7 2004-03-21 devnull switch(r->ifcall.type){
90 2277c5d7 2004-03-21 devnull case Tstat:
91 2277c5d7 2004-03-21 devnull free(r->ofcall.stat);
92 2277c5d7 2004-03-21 devnull free(r->d.name);
93 2277c5d7 2004-03-21 devnull free(r->d.uid);
94 2277c5d7 2004-03-21 devnull free(r->d.gid);
95 2277c5d7 2004-03-21 devnull free(r->d.muid);
98 2277c5d7 2004-03-21 devnull if(r->pool->destroy)
99 2277c5d7 2004-03-21 devnull r->pool->destroy(r);
100 2277c5d7 2004-03-21 devnull free(r->buf);
101 2277c5d7 2004-03-21 devnull free(r->rbuf);
102 2277c5d7 2004-03-21 devnull free(r);
107 2277c5d7 2004-03-21 devnull removereq(Reqpool *pool, ulong tag)
109 2277c5d7 2004-03-21 devnull if(chatty9p > 1)
110 2277c5d7 2004-03-21 devnull fprint(2, "removereq %lud\n", tag);
111 2277c5d7 2004-03-21 devnull return deletekey(pool->map, tag);