diff --git a/internal/statesync/reactor.go b/internal/statesync/reactor.go index d224fb6f5..abfa973b5 100644 --- a/internal/statesync/reactor.go +++ b/internal/statesync/reactor.go @@ -869,6 +869,7 @@ func (r *Reactor) processCh(ch *p2p.Channel, chName string) { Err: err, } } + case <-r.closeCh: r.Logger.Debug(fmt.Sprintf("stopped listening on %s channel; closing...", chName)) return