summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorcinap_lenrek <cinap_lenrek@felloff.net>2020-03-07 15:01:29 +0100
committercinap_lenrek <cinap_lenrek@felloff.net>2020-03-07 15:01:29 +0100
commit8f64e448545a11c1c0e0db8bef34c23d3c0e0ad7 (patch)
tree3541a6dc0d2faeacb8c1ecdb1b2914a6ce02e94c
parentdce28e58e492e5b4448451ddcbe948d9b104d859 (diff)
downloadplan9front-8f64e448545a11c1c0e0db8bef34c23d3c0e0ad7.tar.xz
lib9p: zero out per connection state in Srv template for listensrv()
in case listensrv() is called with a previously active Srv, we have to make sure that per connection state is zeroed out (locks and reference conuts). also, dont assume anything about the Ref structure. there might be implementations that have a spinlock in them.
-rw-r--r--sys/src/lib9p/listen.c23
-rw-r--r--sys/src/lib9p/srv.c4
2 files changed, 19 insertions, 8 deletions
diff --git a/sys/src/lib9p/listen.c b/sys/src/lib9p/listen.c
index 0ba856595..be5290a3b 100644
--- a/sys/src/lib9p/listen.c
+++ b/sys/src/lib9p/listen.c
@@ -15,11 +15,26 @@ _listensrv(Srv *os, char *addr)
{
Srv *s;
- if(_forker == nil)
- sysfatal("no forker");
s = emalloc9p(sizeof *s);
*s = *os;
+
s->addr = estrdup9p(addr);
+ s->infd = s->outfd = s->srvfd = -1;
+ s->fpool = nil;
+ s->rpool = nil;
+ s->msize = 0;
+ s->rbuf = nil;
+ s->wbuf = nil;
+ memset(&s->rlock, 0, sizeof(s->rlock));
+ memset(&s->wlock, 0, sizeof(s->wlock));
+ memset(&s->slock, 0, sizeof(s->slock));
+ memset(&s->sref, 0, sizeof(s->sref));
+ memset(&s->rref, 0, sizeof(s->rref));
+ s->spid = 0;
+ s->free = nil;
+
+ if(_forker == nil)
+ sysfatal("no forker");
_forker(listenproc, s, 0);
}
@@ -56,10 +71,6 @@ listenproc(void *v)
*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);
}
diff --git a/sys/src/lib9p/srv.c b/sys/src/lib9p/srv.c
index 207c88f61..034364de0 100644
--- a/sys/src/lib9p/srv.c
+++ b/sys/src/lib9p/srv.c
@@ -810,8 +810,8 @@ srv(Srv *srv)
fmtinstall('F', fcallfmt);
srv->spid = getpid();
- srv->sref.ref = 0;
- srv->rref.ref = 0;
+ memset(&s->sref, 0, sizeof(s->sref));
+ memset(&s->rref, 0, sizeof(s->rref));
if(srv->fpool == nil)
srv->fpool = allocfidpool(srv->destroyfid);