Merge pull request #67 from roybabayov/royb/timer_usage

fix send timeout timer.reset usage
v3io · Mar 17, 2021 · 5ff4fe2 · 5ff4fe2
2 parents de4731c + b358655
commit 5ff4fe2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/httpblaster/worker/worker_base.go b/httpblaster/worker/worker_base.go
@@ -133,6 +133,9 @@ func (w *WorkerBase) send(req *fasthttp.Request, resp *fasthttp.Response,
 		w.ch_duration <- end.Sub(start)
 	}()
 
+	if !w.timer.Stop() {
+		<-w.timer.C
+	}
 	w.timer.Reset(timeout)
 	select {
 	case duration := <-w.ch_duration: