mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-08-28 03:46:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

revert close ch order change

Browse Source
This commit is contained in:
William Banfield
2021-09-30 13:42:54 -04:00
parent e28bf9b659
commit 28eacd75c2
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/statesync/reactor.go
+3 -7
View File
@@ -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
}
}
}