From 28eacd75c21cad930ff3a1aa9b601cf6b10415be Mon Sep 17 00:00:00 2001 From: William Banfield Date: Thu, 30 Sep 2021 13:42:54 -0400 Subject: [PATCH] revert close ch order change --- internal/statesync/reactor.go | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) 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 } } }