Blob


1 #include <u.h>
2 #include <libc.h>
3 #include <venti.h>
4 #include "queue.h"
6 int chattyventi;
8 VtConn*
9 vtconn(int infd, int outfd)
10 {
11 VtConn *z;
12 NetConnInfo *nci;
14 z = vtmallocz(sizeof(VtConn));
15 z->tagrend.l = &z->lk;
16 z->rpcfork.l = &z->lk;
17 z->infd = infd;
18 z->outfd = outfd;
19 z->part = packetalloc();
20 nci = getnetconninfo(nil, infd);
21 if(nci == nil)
22 snprint(z->addr, sizeof z->addr, "/dev/fd/%d", infd);
23 else{
24 strecpy(z->addr, z->addr+sizeof z->addr, nci->raddr);
25 freenetconninfo(nci);
26 }
27 return z;
28 }
30 void
31 vtfreeconn(VtConn *z)
32 {
33 vthangup(z);
34 qlock(&z->lk);
35 for(;;){
36 if(z->readq)
37 _vtqhangup(z->readq);
38 else if(z->writeq)
39 _vtqhangup(z->writeq);
40 else
41 break;
42 rsleep(&z->rpcfork);
43 }
44 packetfree(z->part);
45 vtfree(z);
46 }