8 enum { STACK = 32768 };
15 int blocksize, seed, randpct;
16 int doread, dowrite, packets, permute;
17 vlong totalbytes, cur;
28 fprint(2, "usage: randtest [-q] [-h host] [-s seed] [-b blocksize] [-p randpct] [-n totalbytes] [-M maxblocks] [-P] [-r] [-w]\n");
29 threadexitsall("usage");
33 wr(char *buf, char *buf2)
35 uchar score[VtScoreSize], score2[VtScoreSize];
39 memset(&ds, 0, sizeof ds);
41 sha1((uchar*)buf, blocksize, score, &ds);
42 if(vtwrite(z, score2, VtDataType, (uchar*)buf, blocksize) < 0)
43 sysfatal("vtwrite %V at %,lld: %r", score, cur);
44 if(doublecheck && memcmp(score, score2, VtScoreSize) != 0)
45 sysfatal("score mismatch! %V %V", score, score2);
54 while((p = recvp(cw)) != nil){
61 rd(char *buf, char *buf2)
63 uchar score[VtScoreSize];
66 memset(&ds, 0, sizeof ds);
67 sha1((uchar*)buf, blocksize, score, &ds);
68 if(vtread(z, score, VtDataType, (uchar*)buf2, blocksize) < 0)
69 sysfatal("vtread %V at %,lld: %r", score, cur);
70 if(memcmp(buf, buf2, blocksize) != 0)
71 sysfatal("bad data read! %V", score);
79 buf2 = vtmalloc(blocksize);
81 while((p = recvp(cr)) != nil){
90 run(void (*fn)(char*, char*), Channel *c)
95 buf2 = vtmalloc(blocksize);
96 buf = vtmalloc(blocksize);
98 packets = totalbytes/blocksize;
100 maxpackets = packets;
101 order = vtmalloc(packets*sizeof order[0]);
102 for(i=0; i<packets; i++)
105 for(i=1; i<packets; i++){
112 for(i=0; i<packets && i<maxpackets; i++){
113 memmove(buf, template, blocksize);
114 *(uint*)buf = order[i];
117 buf = vtmalloc(blocksize);
125 #define TWID64 ((u64int)~(u64int)0)
135 n = strtoul(s, &es, 0);
136 if(*es == 'k' || *es == 'K'){
139 }else if(*es == 'm' || *es == 'M'){
142 }else if(*es == 'g' || *es == 'G'){
145 }else if(*es == 't' || *es == 'T'){
155 threadmain(int argc, char *argv[])
167 totalbytes = 1*1024*1024*1024;
168 fmtinstall('V', vtscorefmt);
169 fmtinstall('F', vtfcallfmt);
173 blocksize = unittoull(EARGF(usage()));
176 host = EARGF(usage());
179 maxpackets = unittoull(EARGF(usage()));
182 multi = atoi(EARGF(usage()));
185 totalbytes = unittoull(EARGF(usage()));
188 randpct = atoi(EARGF(usage()));
195 ventidoublechecksha1 = 0;
198 seed = atoi(EARGF(usage()));
213 if(doread==0 && dowrite==0){
220 sysfatal("could not connect to server: %r");
222 sysfatal("vtconnect: %r");
225 cr = chancreate(sizeof(void*), 0);
226 cw = chancreate(sizeof(void*), 0);
227 for(i=0; i<multi; i++){
228 proccreate(wrthread, nil, STACK);
229 proccreate(rdthread, nil, STACK);
233 template = vtmalloc(blocksize);
235 max = (256*randpct)/100;
238 for(i=0; i<blocksize; i++)
239 template[i] = xxxlrand()%max;
243 for(i=0; i<multi; i++)
245 t = (nsec() - t0)/1.e9;
246 print("write: %lld bytes / %.3f seconds = %.6f MB/s\n",
247 totalbytes, t, (double)totalbytes/1e6/t);
252 for(i=0; i<multi; i++)
254 t = (nsec() - t0)/1.e9;
255 print("read: %lld bytes / %.3f seconds = %.6f MB/s\n",
256 totalbytes, t, (double)totalbytes/1e6/t);
264 * D. P. Mitchell & J. A. Reeds
269 #define MASK 0x7fffffffL
274 #define NORM (1.0/(1.0+MASK))
276 static ulong rng_vec[LEN];
277 static ulong* rng_tap = rng_vec;
278 static ulong* rng_feed = 0;
287 rng_feed = rng_vec+LEN-TAP;
295 * Initialize by x[n+1] = 48271 * x[n] mod (2**31 - 1)
297 for(i = -20; i < LEN; i++) {
320 if(rng_tap < rng_vec) {
328 if(rng_feed < rng_vec)
330 x = (*rng_feed + *rng_tap) & MASK;