statesync: improve rare p2p race condition

This commit is contained in:
William Banfield
2021-10-01 16:11:14 -04:00
parent 177850a2c9
commit d8d913fe42

View File

@@ -779,7 +779,7 @@ func (r *Reactor) handleParamsMessage(envelope p2p.Envelope) error {
if sp, ok := r.stateProvider.(*stateProviderP2P); ok {
select {
case sp.paramsRecvCh <- cp:
default:
case <-time.After(time.Second): // Wait for the p2p stateprovider to be ready to receive the response.
}
} else {
r.Logger.Debug("received unexpected params response; using RPC state provider", "peer", envelope.From)