return error on failed consensus param send

This commit is contained in:
William Banfield
2021-10-01 16:21:39 -04:00
parent d8d913fe42
commit 8c6db2cae9

View File

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