Commit 7aeeee3
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -22,8 +22,10 @@ function main(conf) { | |||
| 22 | 22 | data = null; | |
| 23 | 23 | ||
| 24 | 24 | var reads = 0; | |
| 25 | + var bench_ended = false; | ||
| 25 | 26 | bench.start(); | |
| 26 | 27 | setTimeout(function() { | |
| 28 | + bench_ended = true; | ||
| 27 | 29 | bench.end(reads); | |
| 28 | 30 | try { fs.unlinkSync(filename); } catch (e) {} | |
| 29 | 31 | process.exit(0); | |
@@ -41,7 +43,8 @@ function main(conf) { | |||
| 41 | 43 | throw new Error('wrong number of bytes returned'); | |
| 42 | 44 | ||
| 43 | 45 | reads++; | |
| 44 | - read(); | ||
| 46 | + if (!bench_ended) | ||
| 47 | + read(); | ||
| 45 | 48 | } | |
| 46 | 49 | ||
| 47 | 50 | var cur = +conf.concurrent; | |
0 commit comments