diff options
Diffstat (limited to 'src/libventi/conn.c')
-rw-r--r-- | src/libventi/conn.c | 36 |
1 files changed, 36 insertions, 0 deletions
diff --git a/src/libventi/conn.c b/src/libventi/conn.c new file mode 100644 index 00000000..3fa6fbe5 --- /dev/null +++ b/src/libventi/conn.c @@ -0,0 +1,36 @@ +#include <u.h> +#include <libc.h> +#include <venti.h> +#include "queue.h" + +VtConn* +vtconn(int infd, int outfd) +{ + VtConn *z; + + z = vtmallocz(sizeof(VtConn)); + z->tagrend.l = &z->lk; + z->rpcfork.l = &z->lk; + z->infd = infd; + z->outfd = outfd; + z->part = packetalloc(); + return z; +} + +void +vtfreeconn(VtConn *z) +{ + vthangup(z); + qlock(&z->lk); + for(;;){ + if(z->readq) + _vtqhangup(z->readq); + else if(z->writeq) + _vtqhangup(z->writeq); + else + break; + rsleep(&z->rpcfork); + } + packetfree(z->part); + vtfree(z); +} |