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