diff options
author | rsc <devnull@localhost> | 2004-12-28 01:37:18 +0000 |
---|---|---|
committer | rsc <devnull@localhost> | 2004-12-28 01:37:18 +0000 |
commit | 7ffc5208a82cd7339c125956a9702ac08c0ff2f4 (patch) | |
tree | c44cb9750f5f8c77941c9d9090e1058c6f47ebf4 /src/cmd/9pserve.c | |
parent | 96d6b19dcd4f359c3fa8eefcb8615082c840e184 (diff) | |
download | plan9port-7ffc5208a82cd7339c125956a9702ac08c0ff2f4.tar.gz plan9port-7ffc5208a82cd7339c125956a9702ac08c0ff2f4.tar.bz2 plan9port-7ffc5208a82cd7339c125956a9702ac08c0ff2f4.zip |
use threaddaemonize
Diffstat (limited to 'src/cmd/9pserve.c')
-rw-r--r-- | src/cmd/9pserve.c | 22 |
1 files changed, 8 insertions, 14 deletions
diff --git a/src/cmd/9pserve.c b/src/cmd/9pserve.c index b3917a82..6ea58e77 100644 --- a/src/cmd/9pserve.c +++ b/src/cmd/9pserve.c @@ -149,19 +149,8 @@ threadmain(int argc, char **argv) if((afd = announce(addr, adir)) < 0) sysfatal("announce %s: %r", addr); - if(verbose) fprint(2, "9pserve forking\n"); - switch(fork()){ - case -1: - sysfatal("fork: %r"); - case 0: - if(verbose) fprint(2, "running mainproc\n"); - mainproc(nil); - if(verbose) fprint(2, "mainproc finished\n"); - _exits(0); - default: - if(verbose) fprint(2, "9pserve exiting\n"); - _exits(0); - } + threaddaemonize(); + mainproc(nil); } void @@ -220,6 +209,7 @@ listenthread(void *arg) io = ioproc(); USED(arg); + threadsetname("listen %s", adir); for(;;){ c = emalloc(sizeof(Conn)); c->fd = iolisten(io, adir, c->dir); @@ -284,6 +274,7 @@ connthread(void *arg) Ioproc *io; c = arg; + threadsetname("conn %s", c->dir); io = ioproc(); fd = ioaccept(io, c->fd, c->dir); if(fd < 0){ @@ -491,7 +482,7 @@ openfdthread(void *v) c = v; fid = c->fdfid; io = ioproc(); - + threadsetname("openfd %s", c->fdfid); tot = 0; m = nil; if(c->fdmode == OREAD){ @@ -655,6 +646,7 @@ connoutthread(void *arg) c = arg; outq = c->outq; io = ioproc(); + threadsetname("connout %s", c->dir); while((m = recvq(outq)) != nil){ err = m->tx.type+1 != m->rx.type; if(!err && m->isopenfd) @@ -714,6 +706,7 @@ outputthread(void *arg) USED(arg); io = ioproc(); + threadsetname("output"); while((m = recvq(outq)) != nil){ if(verbose > 1) fprint(2, "* <- %F\n", &m->tx); rewritehdr(&m->tx, m->tpkt); @@ -734,6 +727,7 @@ inputthread(void *arg) Msg *m; Ioproc *io; + threadsetname("input"); if(verbose) fprint(2, "input thread\n"); io = ioproc(); USED(arg); |