From c3240333096e3cb7a7b487930e73a3eb3189fcc6 Mon Sep 17 00:00:00 2001 From: jay tseng Date: Fri, 11 Mar 2022 17:22:03 -0500 Subject: [PATCH] rollback change --- internal/consensus/reactor.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/internal/consensus/reactor.go b/internal/consensus/reactor.go index a1c37495e..720dc0fa7 100644 --- a/internal/consensus/reactor.go +++ b/internal/consensus/reactor.go @@ -2,6 +2,7 @@ package consensus import ( "context" + "errors" "fmt" "runtime/debug" "sync" @@ -1395,6 +1396,10 @@ func (r *Reactor) processVoteSetBitsCh(ctx context.Context) { envelope := iter.Envelope() if err := r.handleMessage(ctx, r.voteSetBitsCh.ID, envelope); err != nil { + if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) { + return + } + r.logger.Error("failed to process message", "ch_id", r.voteSetBitsCh.ID, "envelope", envelope, "err", err) if serr := r.voteSetBitsCh.SendError(ctx, p2p.PeerError{ NodeID: envelope.From,