<?xml version="1.0" encoding="utf-8"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
"
http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv=Content-Type content="text/html; charset=utf8">
<title>/usr/web/sources/contrib/vsrinivas/vtrc.c - Plan 9 from Bell Labs</title>
<!-- THIS FILE IS AUTOMATICALLY GENERATED. -->
<!-- EDIT sources.tr INSTEAD. -->
</meta>
</head>
<body>
<p style="margin-top: 0; margin-bottom: 0.17in"></p>
<p style="line-height: 1.2em; margin-left: 1.00in; text-indent: 0.00in; margin-right: 1.00in; margin-top: 0; margin-bottom: 0; text-align: center;">
<span style="font-size: 10pt"><a href="/plan9/">Plan 9 from Bell Labs</a>’s /usr/web/sources/contrib/vsrinivas/vtrc.c</span></p>
<p style="margin-top: 0; margin-bottom: 0.17in"></p>
<p style="margin-top: 0; margin-bottom: 0.17in"></p>
<center><font size=-1>
Copyright © 2009 Alcatel-Lucent.<br />
Distributed under the
<a href="/plan9/license.html">Lucent Public License version 1.02</a>.
<br />
<a href="/plan9/download.html">Download the Plan 9 distribution.</a>
</font>
</center>
<p style="margin-top: 0; margin-bottom: 0.17in"></p>
<table width="100%" cellspacing=0 border=0><tr><td align="center">
<table cellspacing=0 cellpadding=5 bgcolor="#eeeeff"><tr><td align="left">
<pre>
<!-- END HEADER -->
/*
* Reconnecting Venti proxy
*
* Proxies requests to a remove Venti; if the connection to a remove server
* fails, it keeps retrying the request till a connection can be reestablished
*
* Usage:
* vtrc -a listenaddress -h hostventi [-v]
* vtrc listens on listenaddress, proxying connections to hostventi
*
* based on Russ Cox's venti/ro.c
*/
#include <u.h>
#include <libc.h>
#include <venti.h>
#include <libsec.h>
#include <avl.h>
#ifndef _UNISTD_H_
#pragma varargck type "F" VtFcall*
#pragma varargck type "T" void
#endif
char *za = nil;
VtConn *z =nil;
int verbose;
QLock vtconnlock;
enum
{
STACK = 4096
};
/* called with the vtconnlock held */
void try_reconnect(void) {
if (z != nil)
vtfreeconn(z);
z = vtdial(za);
if (z != nil)
vtconnect(z);
}
void
usage(void)
{
fprint(2, "usage: vtrc [-v] [-a address] [-h address]\n");
exits("usage");
}
void
readthread(void *v)
{
char err[ERRMAX];
VtReq *r;
uchar *buf;
int n = -1;
r = v;
buf = vtmalloc(r->tx.count);
qlock(&vtconnlock); for (;;) {
n = -1;
if (z != nil)
n = vtread(z, r->tx.score, r->tx.blocktype, buf, r->tx.count);
if (n < 0)
try_reconnect();
else
break;
} qunlock(&vtconnlock);
r->rx.data = packetforeign(buf, n, free, buf);
vtrespond(r);
}
void
writethread(void *v) {
VtReq *r;
int n = -1;
r = v;
packetsha1(r->tx.data, r->rx.score);
qlock(&vtconnlock); for (;;) {
n = -1;
if (z != nil)
n = vtwritepacket(z, r->rx.score, r->tx.blocktype, r->tx.data);
if (n < 0)
try_reconnect();
else
break;
} qunlock(&vtconnlock);
vtrespond(r);
}
VtSrv *srv;
void
coreproc(void *v) {
VtReq *r1;
while((r1 = vtgetreq(srv)) != nil){
r1->rx.msgtype = r1->tx.msgtype+1;
if(verbose)
fprint(2, "<- %F\n", &r1->tx);
switch(r1->tx.msgtype){
case VtTping:
vtrespond(r1);
break;
case VtTgoodbye:
vtrespond(r1);
break;
case VtTread:
proccreate(readthread, r1, 16384);
continue;
case VtTwrite:
proccreate(writethread, r1, 16384);
continue;
case VtTsync:
vtrespond(r1);
break;
}
if(verbose)
fprint(2, "-> %F\n", &r1->rx);
}
}
void
threadmain(int argc, char **argv)
{
char *address, *ventiaddress;
fmtinstall('F', vtfcallfmt);
fmtinstall('V', vtscorefmt);
address = "tcp!*!venti";
ventiaddress = nil;
ARGBEGIN{
case 'v':
verbose++;
break;
case 'a':
address = EARGF(usage());
break;
case 'h':
ventiaddress = EARGF(usage());
break;
default:
usage();
}ARGEND
if((z = vtdial(ventiaddress)) == nil)
sysfatal("vtdial %s: %r", ventiaddress);
if(vtconnect(z) < 0)
sysfatal("vtconnect: %r");
za = ventiaddress;
if (za == nil)
sysfatal("no remote address");
srv = vtlisten(address);
if(srv == nil)
sysfatal("vtlisten %s: %r", address);
print("vtrc: Ice Nine, Baby\n");
rfork(RFNOTEG);
proccreate(coreproc, nil, 4096*16);
exits(nil);
}
<!-- BEGIN TAIL -->
</pre>
</td></tr></table>
</td></tr></table>
<p style="margin-top: 0; margin-bottom: 0.17in"></p>
<p style="line-height: 1.2em; margin-left: 1.00in; text-indent: 0.00in; margin-right: 1.00in; margin-top: 0; margin-bottom: 0; text-align: center;">
<span style="font-size: 10pt"></span></p>
<p style="margin-top: 0; margin-bottom: 0.50in"></p>
<p style="margin-top: 0; margin-bottom: 0.33in"></p>
<center><table border="0"><tr>
<td valign="middle"><a href="
http://www.alcatel-lucent.com/"><img border="0" src="/plan9/img/logo_ft.gif" alt="Bell Labs" />
</a></td>
<td valign="middle"><a href="
http://www.opensource.org"><img border="0" alt="OSI certified" src="/plan9/img/osi-certified-60x50.gif" />
</a></td>
<td><img style="padding-right: 45px;" alt="Powered by Plan 9" src="/plan9/img/power36.gif" />
</td>
</tr></table></center>
<p style="margin-top: 0; margin-bottom: 0.17in"></p>
<center>
<span style="font-size: 10pt">(<a href="/plan9/">Return to Plan 9 Home Page</a>)</span>
</center>
<p style="margin-top: 0; margin-bottom: 0.17in"></p>
<center><font size=-1>
<span style="font-size: 10pt"><a href="
http://www.lucent.com/copyright.html">Copyright</a></span>
<span style="font-size: 10pt">© 2009 Alcatel-Lucent.</span>
<span style="font-size: 10pt">All Rights Reserved.</span>
<br />
<span style="font-size: 10pt">Comments to</span>
<span style="font-size: 10pt"><a href="mailto:
[email protected]">
[email protected]</a>.</span>
</font></center>
</body>
</html>