diff --git a/internal/statesync/reactor.go b/internal/statesync/reactor.go index 04fdd57f6..70b12b7fa 100644 --- a/internal/statesync/reactor.go +++ b/internal/statesync/reactor.go @@ -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)