From f8cebbc5afe98c75de3cfafeb098ac5c2c34215d Mon Sep 17 00:00:00 2001 From: William Banfield Date: Wed, 29 Sep 2021 16:56:06 -0400 Subject: [PATCH] remove syncer done --- internal/statesync/reactor.go | 2 -- internal/statesync/syncer.go | 4 ---- 2 files changed, 6 deletions(-) diff --git a/internal/statesync/reactor.go b/internal/statesync/reactor.go index c084a1936..6a1b484cb 100644 --- a/internal/statesync/reactor.go +++ b/internal/statesync/reactor.go @@ -249,8 +249,6 @@ func (r *Reactor) OnStop() { if r.syncer != nil { r.syncer.Close() - - <-r.syncer.Done() } // Close closeCh to signal to all spawned goroutines to gracefully exit. All diff --git a/internal/statesync/syncer.go b/internal/statesync/syncer.go index 5369024d0..3f77b14a4 100644 --- a/internal/statesync/syncer.go +++ b/internal/statesync/syncer.go @@ -373,10 +373,6 @@ func (s *syncer) Close() { close(s.closeCh) } -func (s *syncer) Done() <-chan struct{} { - return s.closeCh -} - // offerSnapshot offers a snapshot to the app. It returns various errors depending on the app's // response, or nil if the snapshot was accepted. func (s *syncer) offerSnapshot(ctx context.Context, snapshot *snapshot) error {