benchmark: check for and fix multiple end()

PR-URL: #31624 Reviewed-By: Matteo Collina <[email protected]> Reviewed-By: James M Snell <[email protected]> Reviewed-By: Luigi Pinca <[email protected]>

Author: mscdex

benchmark/common.js

@@ -33,6 +33,7 @@ function Benchmark(fn, configs, options){
 this._time=[0,0];
 // Used to make sure a benchmark only start a timer once
 this._started=false;
+this._ended=false;
 
 // this._run will use fork() to create a new process for each configuration
 // combination.
@@ -197,6 +198,9 @@ Benchmark.prototype.end = function(operations){
 if(!this._started){
 thrownewError('called end without start');
 }
+if(this._ended){
+thrownewError('called end multiple times');
+}
 if(typeofoperations!=='number'){
 thrownewError('called end() without specifying operation count');
 }
@@ -210,6 +214,7 @@ Benchmark.prototype.end = function(operations){
 elapsed[1]=1;
 }
 
+this._ended=true;
 consttime=elapsed[0]+elapsed[1]/1e9;
 constrate=operations/time;
 this.report(rate,elapsed);

benchmark/streams/writable-manywrites.js

@@ -35,8 +35,10 @@ function main({n, sync, writev, callback }){
 letk=0;
 functionrun(){
 while(k++<n&&s.write(b,cb));
-if(k>=n)
+if(k>=n){
 bench.end(n);
+s.removeListener('drain',run);
+}
 }
 s.on('drain',run);
 run();