Healing fix

AccumulateNetwork · Sep 23, 2024 · 698f0a4 · 698f0a4
1 parent 782ad6e
commit 698f0a4
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/tools/cmd/debug/heal_common.go b/tools/cmd/debug/heal_common.go
@@ -101,6 +101,10 @@ func (h *healer) Reset() {
 }
 
 func (h *healer) heal(args []string) {
+	// Wait must be called after cancel (so the defer must happen first)
+	wg := new(sync.WaitGroup)
+	defer wg.Wait()
+
 	ctx := cmdutil.ContextForMainProcess(context.Background())
 	ctx, cancel, _ := api.ContextWithBatchData(ctx)
 	defer cancel()
@@ -177,9 +181,6 @@ func (h *healer) heal(args []string) {
 		},
 	}
 
-	wg := new(sync.WaitGroup)
-	defer wg.Wait()
-
 	h.submit = make(chan []messaging.Message)
 	wg.Add(1)
 	go h.submitLoop(wg)