gemini: aviod deadlock when consumers no longer consume the pump

scylladb · Jul 8, 2019 · 80290db · 80290db
1 parent f9e0f0f
commit 80290db
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/cmd/gemini/pump.go b/cmd/gemini/pump.go
@@ -42,8 +42,7 @@ func (p *Pump) Start(d time.Duration, postFunc func()) {
 			case <-timer.C:
 				p.logger.Info("Test run completed. Exiting.")
 				return
-			default:
-				p.ch <- newHeartBeat()
+			case p.ch <- newHeartBeat():
 			}
 		}
 	}()