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 5c8a0421 2004-12-26 devnull closereq(r);
53 2277c5d7 2004-03-21 devnull return nil;
56 2277c5d7 2004-03-21 devnull return r;
60 2277c5d7 2004-03-21 devnull lookupreq(Reqpool *pool, ulong tag)
62 2277c5d7 2004-03-21 devnull if(chatty9p > 1)
63 2277c5d7 2004-03-21 devnull fprint(2, "lookupreq %lud\n", tag);
64 2277c5d7 2004-03-21 devnull return lookupkey(pool->map, tag);
68 2277c5d7 2004-03-21 devnull closereq(Req *r)
72 2277c5d7 2004-03-21 devnull if(r == nil)
75 2277c5d7 2004-03-21 devnull if(chatty9p > 1)
76 2277c5d7 2004-03-21 devnull fprint(2, "closereq %p %ld\n", r, r->ref.ref);
78 2277c5d7 2004-03-21 devnull if(decref(&r->ref) == 0){
79 2277c5d7 2004-03-21 devnull if(r->fid)
80 2277c5d7 2004-03-21 devnull closefid(r->fid);
81 2277c5d7 2004-03-21 devnull if(r->newfid)
82 2277c5d7 2004-03-21 devnull closefid(r->newfid);
83 2277c5d7 2004-03-21 devnull if(r->afid)
84 2277c5d7 2004-03-21 devnull closefid(r->afid);
85 2277c5d7 2004-03-21 devnull if(r->oldreq)
86 2277c5d7 2004-03-21 devnull closereq(r->oldreq);
87 2277c5d7 2004-03-21 devnull for(i=0; i<r->nflush; i++)
88 2277c5d7 2004-03-21 devnull respond(r->flush[i], nil);
89 2277c5d7 2004-03-21 devnull free(r->flush);
90 2277c5d7 2004-03-21 devnull switch(r->ifcall.type){
91 2277c5d7 2004-03-21 devnull case Tstat:
92 2277c5d7 2004-03-21 devnull free(r->ofcall.stat);
93 2277c5d7 2004-03-21 devnull free(r->d.name);
94 2277c5d7 2004-03-21 devnull free(r->d.uid);
95 2277c5d7 2004-03-21 devnull free(r->d.gid);
96 2277c5d7 2004-03-21 devnull free(r->d.muid);
99 2277c5d7 2004-03-21 devnull if(r->pool->destroy)
100 2277c5d7 2004-03-21 devnull r->pool->destroy(r);
101 2277c5d7 2004-03-21 devnull free(r->buf);
102 2277c5d7 2004-03-21 devnull free(r->rbuf);
103 2277c5d7 2004-03-21 devnull free(r);
108 2277c5d7 2004-03-21 devnull removereq(Reqpool *pool, ulong tag)
110 2277c5d7 2004-03-21 devnull if(chatty9p > 1)
111 2277c5d7 2004-03-21 devnull fprint(2, "removereq %lud\n", tag);
112 2277c5d7 2004-03-21 devnull return deletekey(pool->map, tag);