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"
 5 056fe1ba 2003-11-23 devnull 
 6 a09e80f9 2004-05-23 devnull int chattyventi;
 7 a09e80f9 2004-05-23 devnull 
 8 056fe1ba 2003-11-23 devnull VtConn*
 9 056fe1ba 2003-11-23 devnull vtconn(int infd, int outfd)
10 056fe1ba 2003-11-23 devnull {
11 056fe1ba 2003-11-23 devnull 	VtConn *z;
12 056fe1ba 2003-11-23 devnull 
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;
20 056fe1ba 2003-11-23 devnull }
21 056fe1ba 2003-11-23 devnull 
22 056fe1ba 2003-11-23 devnull void
23 056fe1ba 2003-11-23 devnull vtfreeconn(VtConn *z)
24 056fe1ba 2003-11-23 devnull {
25 056fe1ba 2003-11-23 devnull 	vthangup(z);
26 056fe1ba 2003-11-23 devnull 	qlock(&z->lk);
27 056fe1ba 2003-11-23 devnull 	for(;;){
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);
32 056fe1ba 2003-11-23 devnull 		else
33 056fe1ba 2003-11-23 devnull 			break;
34 056fe1ba 2003-11-23 devnull 		rsleep(&z->rpcfork);
35 056fe1ba 2003-11-23 devnull 	}
36 056fe1ba 2003-11-23 devnull 	packetfree(z->part);
37 056fe1ba 2003-11-23 devnull 	vtfree(z);
38 056fe1ba 2003-11-23 devnull }