1 056fe1ba 2003-11-23 devnull #include <u.h>
2 056fe1ba 2003-11-23 devnull #include <libc.h>
3 056fe1ba 2003-11-23 devnull #include <venti.h>
4 056fe1ba 2003-11-23 devnull #include "queue.h"
6 a09e80f9 2004-05-23 devnull int chattyventi;
9 056fe1ba 2003-11-23 devnull vtconn(int infd, int outfd)
11 056fe1ba 2003-11-23 devnull VtConn *z;
13 056fe1ba 2003-11-23 devnull z = vtmallocz(sizeof(VtConn));
14 056fe1ba 2003-11-23 devnull z->tagrend.l = &z->lk;
15 056fe1ba 2003-11-23 devnull z->rpcfork.l = &z->lk;
16 056fe1ba 2003-11-23 devnull z->infd = infd;
17 056fe1ba 2003-11-23 devnull z->outfd = outfd;
18 056fe1ba 2003-11-23 devnull z->part = packetalloc();
19 056fe1ba 2003-11-23 devnull return z;
23 056fe1ba 2003-11-23 devnull vtfreeconn(VtConn *z)
25 056fe1ba 2003-11-23 devnull vthangup(z);
26 056fe1ba 2003-11-23 devnull qlock(&z->lk);
28 056fe1ba 2003-11-23 devnull if(z->readq)
29 056fe1ba 2003-11-23 devnull _vtqhangup(z->readq);
30 056fe1ba 2003-11-23 devnull else if(z->writeq)
31 056fe1ba 2003-11-23 devnull _vtqhangup(z->writeq);
34 056fe1ba 2003-11-23 devnull rsleep(&z->rpcfork);
36 056fe1ba 2003-11-23 devnull packetfree(z->part);
37 056fe1ba 2003-11-23 devnull vtfree(z);