diff --git a/node/consensus/master/consensus_frames.go b/node/consensus/master/consensus_frames.go index 3389f0a..f5263f6 100644 --- a/node/consensus/master/consensus_frames.go +++ b/node/consensus/master/consensus_frames.go @@ -102,6 +102,10 @@ func (e *MasterClockConsensusEngine) collect( }, }, ) + if err != nil { + cc.Close() + continue + } for msg, err := syncClient.Recv(); msg != nil && err == nil; msg, err = syncClient.Recv() {