commit 4544da52005bf0af3bb05a73f4e02ce35117aae0 from: David du Colombier <0intro@gmail.com> via: Russ Cox date: Tue Nov 08 14:02:31 2011 UTC libventi: add functions reconn and redial for use with fossil R=rsc CC=plan9port.codebot http://codereview.appspot.com/5325046 commit - 36c242dd868672ae9c6705622ef1e7dbb84dbbac commit + 4544da52005bf0af3bb05a73f4e02ce35117aae0 blob - 2861feeec8d68b82f3536852615cf8255bd593df blob + 632746db6e936ca53a16962961414de2e69caba3 --- include/venti.h +++ include/venti.h @@ -335,7 +335,9 @@ struct VtConn }; VtConn* vtconn(int infd, int outfd); +int vtreconn(VtConn*, int, int); VtConn* vtdial(char*); +int vtredial(VtConn*, char *); void vtfreeconn(VtConn*); int vtsend(VtConn*, Packet*); Packet* vtrecv(VtConn*); blob - 293777c22dbb693ecfbe3692f90215b7922879c0 blob + ea597de3a7fc0cb0a64b806d6824bbd211480017 --- man/man3/venti-conn.3 +++ man/man3/venti-conn.3 @@ -28,9 +28,15 @@ typedef struct VtConn { VtConn* vtconn(int infd, int outfd) .PP .B +int vtreconn(VtConn *z, int infd, int outfd) +.PP +.B VtConn* vtdial(char *addr) .PP .B +int vtredial(VtConn *z, char *addr) +.PP +.B int vtversion(VtConn *z) .PP .B blob - e488c6db6a2c05803e56e1bbe114d4e8f751d25f blob + 2a8f67b9647c862ae6842fa7beaae9b8dbf2ca49 --- src/libventi/conn.c +++ src/libventi/conn.c @@ -27,6 +27,28 @@ vtconn(int infd, int outfd) return z; } +int +vtreconn(VtConn *z, int infd, int outfd) +{ + NetConnInfo *nci; + + z->state = VtStateAlloc; + if(z->infd >= 0) + close(z->infd); + z->infd = infd; + if(z->outfd >= 0) + close(z->outfd); + z->outfd = outfd; + nci = getnetconninfo(nil, infd); + if(nci == nil) + snprint(z->addr, sizeof z->addr, "/dev/fd/%d", infd); + else{ + strecpy(z->addr, z->addr+sizeof z->addr, nci->raddr); + freenetconninfo(nci); + } + return 0; +} + void vtfreeconn(VtConn *z) { blob - 060b93f61f867eade669b59b3839b198c3123230 blob + 0048247329056ec5db0570b1bccb71ef52d3a366 --- src/libventi/dial.c +++ src/libventi/dial.c @@ -23,3 +23,21 @@ vtdial(char *addr) strecpy(z->addr, z->addr+sizeof z->addr, na); return z; } + +int +vtredial(VtConn *z, char *addr) +{ + char *na; + int fd; + + if(addr == nil) + addr = getenv("venti"); + if(addr == nil) + addr = "$venti"; + + na = netmkaddr(addr, "tcp", "venti"); + if((fd = dial(na, nil, nil, nil)) < 0) + return fd; + + return vtreconn(z, fd, fd); +}