o5r/plan9port
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

venti/wrarena: add timing output, fix sync

Browse source
This commit is contained in:
Russ Cox 2008-07-03 22:37:48 -04:00
parent 304ab920ad
commit d4bf606d29
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/cmd/venti/srv/wrarena.c
View file

@ -173,7 +173,7 @@ threadmain(int argc, char *argv[])
file = argv[0]; file = argv[0];
} }
fmtinstall('V', vtscorefmt); ventifmtinstall();
statsinit(); statsinit();
@ -206,19 +206,21 @@ threadmain(int argc, char *argv[])
sysfatal("vtconnect: %r"); sysfatal("vtconnect: %r");
} }
print("%T starting to send data\n");
c = chancreate(sizeof(ZClump), 0); c = chancreate(sizeof(ZClump), 0);
for(i=0; i<12; i++) for(i=0; i<12; i++)
vtproc(vtsendthread, nil); vtproc(vtsendthread, nil);
rdarena(arena, offset); rdarena(arena, offset);
if(vtsync(z) < 0)
sysfatal("executing sync: %r");
memset(&zerocl, 0, sizeof zerocl); memset(&zerocl, 0, sizeof zerocl);
for(i=0; i<12; i++) for(i=0; i<12; i++)
send(c, &zerocl); send(c, &zerocl);
if(vtsync(z) < 0)
sysfatal("executing sync: %r");
if(z){ if(z){
vthangup(z); vthangup(z);
} }
print("%T sent all data\n");
threadexitsall(0); threadexitsall(0);
} }