Avoid repeatedly unlocking and locking Throttler on start

wtsi-hgi · Feb 6, 2024 · 43cb9df · 43cb9df
1 parent af84b03
commit 43cb9df
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/reindex/throttle.go b/reindex/throttle.go
@@ -60,9 +60,7 @@ func (t *Throttler) Start() {
 	defer t.Unlock()
 
 	if t.started {
-		t.Unlock()
-		t.Stop()
-		t.Lock()
+		t.stop()
 	}
 
 	t.requestedStop = make(chan struct{})
@@ -150,6 +148,10 @@ func (t *Throttler) Stop() {
 	t.Lock()
 	defer t.Unlock()
 
+	t.stop()
+}
+
+func (t *Throttler) stop() {
 	if t.stopped {
 		return
 	}