diff options
author | rsc <devnull@localhost> | 2003-11-23 18:19:58 +0000 |
---|---|---|
committer | rsc <devnull@localhost> | 2003-11-23 18:19:58 +0000 |
commit | 056fe1ba7fa0b70f871dfb9005b24eb8e4cc230b (patch) | |
tree | 9ad42f31c3bc124cf6617cf9eb41dd525eccce83 /src/libventi/conn.c | |
parent | 9df487d720a59bf8cb0dc4ccffc30ad8eb48256a (diff) | |
download | plan9port-056fe1ba7fa0b70f871dfb9005b24eb8e4cc230b.tar.gz plan9port-056fe1ba7fa0b70f871dfb9005b24eb8e4cc230b.tar.bz2 plan9port-056fe1ba7fa0b70f871dfb9005b24eb8e4cc230b.zip |
new venti library.
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); +} |