106 lines
1.7 KiB
C
106 lines
1.7 KiB
C
#include <u.h>
|
|
#include <lib9.h>
|
|
#include <auth.h>
|
|
#include <9P2000.h>
|
|
#include <thread.h>
|
|
#include <9p.h>
|
|
|
|
static void listenproc(void*);
|
|
static void srvproc(void*);
|
|
static void srvfree(Srv *);
|
|
static char *getremotesys(char*);
|
|
|
|
void
|
|
_listensrv(Srv *os, char *addr)
|
|
{
|
|
Srv *s;
|
|
|
|
if(_forker == nil)
|
|
sysfatal("no forker");
|
|
s = emalloc9p(sizeof *s);
|
|
*s = *os;
|
|
s->addr = estrdup9p(addr);
|
|
_forker(listenproc, s, 0);
|
|
}
|
|
|
|
static void
|
|
listenproc(void *v)
|
|
{
|
|
char ndir[NETPATHLEN], dir[NETPATHLEN];
|
|
int ctl, data, nctl;
|
|
Srv *os, *s;
|
|
|
|
os = v;
|
|
ctl = announce(os->addr, dir);
|
|
if(ctl < 0){
|
|
fprint(2, "%s: announce %s: %r", argv0, os->addr);
|
|
return;
|
|
}
|
|
|
|
for(;;){
|
|
nctl = listen(dir, ndir);
|
|
if(nctl < 0){
|
|
fprint(2, "%s: listen %s: %r", argv0, os->addr);
|
|
break;
|
|
}
|
|
|
|
data = accept(ctl, ndir);
|
|
if(data < 0){
|
|
fprint(2, "%s: accept %s: %r\n", argv0, ndir);
|
|
continue;
|
|
}
|
|
|
|
s = emalloc9p(sizeof *s);
|
|
*s = *os;
|
|
s->addr = getremotesys(ndir);
|
|
s->infd = s->outfd = data;
|
|
s->fpool = nil;
|
|
s->rpool = nil;
|
|
s->rbuf = nil;
|
|
s->wbuf = nil;
|
|
s->free = srvfree;
|
|
_forker(srvproc, s, 0);
|
|
}
|
|
free(os->addr);
|
|
free(os);
|
|
}
|
|
|
|
static void
|
|
srvproc(void *v)
|
|
{
|
|
srv((Srv*)v);
|
|
}
|
|
|
|
static void
|
|
srvfree(Srv *s)
|
|
{
|
|
sys_close(s->infd);
|
|
free(s->addr);
|
|
free(s);
|
|
}
|
|
|
|
static char*
|
|
getremotesys(char *ndir)
|
|
{
|
|
char buf[128], *serv, *sys;
|
|
int fd, n;
|
|
|
|
snprint(buf, sizeof buf, "%s/remote", ndir);
|
|
sys = nil;
|
|
fd = sys_open(buf, OREAD);
|
|
if(fd >= 0){
|
|
n = jehanne_read(fd, buf, sizeof(buf)-1);
|
|
if(n>0){
|
|
buf[n-1] = 0;
|
|
serv = strchr(buf, '!');
|
|
if(serv)
|
|
*serv = 0;
|
|
sys = estrdup9p(buf);
|
|
}
|
|
sys_close(fd);
|
|
}
|
|
if(sys == nil)
|
|
sys = estrdup9p("unknown");
|
|
return sys;
|
|
}
|