From 8c6db2cae9758b31d517973b65757edbb3d28f7e Mon Sep 17 00:00:00 2001 From: William Banfield Date: Fri, 1 Oct 2021 16:21:39 -0400 Subject: [PATCH] return error on failed consensus param send --- internal/statesync/reactor.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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)