Resolve long time consensus stuck by network and simple refactorings

lib/consensus/ballot_send_record.go

@@ -24,6 +24,8 @@ func NewBallotSendRecord(nodeAlias string) *BallotSendRecord {
 	return p
 }
 
+// SetSent sets that the ballot of this ISAACState has already been sent.
+// This is to prevent one node from retransmitting another result.
 func (r *BallotSendRecord) SetSent(state ISAACState) {
 	r.Lock()
 	defer r.Unlock()
@@ -33,6 +35,17 @@ func (r *BallotSendRecord) SetSent(state ISAACState) {
 	return
 }
 
+// InitSent initializes the ballot transfer record of this ISAACState.InitSent.
+// This function is used when an existing ballot has expired.
+func (r *BallotSendRecord) InitSent(state ISAACState) {
+	r.Lock()
+	defer r.Unlock()
+	log.Debug("BallotSendRecord.InitSent()", "state", state)
+	r.record[state] = false
+
+	return
+}
+
 func (r *BallotSendRecord) Sent(state ISAACState) bool {
 	r.RLock()
 	defer r.RUnlock()

lib/node/runner/node_runner.go

@@ -770,3 +770,7 @@ func (nr *NodeRunner) BroadcastBallot(b ballot.Ballot) {
 
 	nr.ConnectionManager().Broadcast(b)
 }
+
+func (nr *NodeRunner) InitSent(state consensus.ISAACState) {
+	nr.ballotSendRecord.InitSent(state)
+}