diff options
| author | Russ Cox <rsc@swtch.com> | 2008-07-03 22:37:48 -0400 |
|---|---|---|
| committer | Russ Cox <rsc@swtch.com> | 2008-07-03 22:37:48 -0400 |
| commit | d4bf606d29304006a85a35a8f09d38bf1529d2af (patch) | |
| tree | 893a37ad39c0ebeb71e578a5cae2b5ef35a74018 /src/cmd/venti/srv | |
| parent | 304ab920ad0ac280b9a3e8efcd91f3552b8496d3 (diff) | |
| download | plan9port-d4bf606d29304006a85a35a8f09d38bf1529d2af.tar.gz plan9port-d4bf606d29304006a85a35a8f09d38bf1529d2af.tar.bz2 plan9port-d4bf606d29304006a85a35a8f09d38bf1529d2af.zip | |
venti/wrarena: add timing output, fix sync
Diffstat (limited to 'src/cmd/venti/srv')
| -rw-r--r-- | src/cmd/venti/srv/wrarena.c | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/cmd/venti/srv/wrarena.c b/src/cmd/venti/srv/wrarena.c index cbd65127..9308ca88 100644 --- a/src/cmd/venti/srv/wrarena.c +++ b/src/cmd/venti/srv/wrarena.c @@ -173,7 +173,7 @@ threadmain(int argc, char *argv[]) file = argv[0]; } - fmtinstall('V', vtscorefmt); + ventifmtinstall(); statsinit(); @@ -206,19 +206,21 @@ threadmain(int argc, char *argv[]) sysfatal("vtconnect: %r"); } + print("%T starting to send data\n"); c = chancreate(sizeof(ZClump), 0); for(i=0; i<12; i++) vtproc(vtsendthread, nil); rdarena(arena, offset); - if(vtsync(z) < 0) - sysfatal("executing sync: %r"); - memset(&zerocl, 0, sizeof zerocl); for(i=0; i<12; i++) send(c, &zerocl); + if(vtsync(z) < 0) + sysfatal("executing sync: %r"); if(z){ vthangup(z); } + print("%T sent all data\n"); + threadexitsall(0); } |