|
@ -2087,12 +2087,10 @@ func (cs *State) defaultSetProposal(proposal *types.Proposal, recvTime time.Time |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
proposal.Signature = p.Signature |
|
|
proposal.Signature = p.Signature |
|
|
func() { |
|
|
|
|
|
cs.mtx.Lock() |
|
|
|
|
|
defer cs.mtx.RUnlock() |
|
|
|
|
|
cs.Proposal = proposal |
|
|
|
|
|
cs.ProposalReceiveTime = recvTime |
|
|
|
|
|
}() |
|
|
|
|
|
|
|
|
cs.mtx.Lock() |
|
|
|
|
|
cs.Proposal = proposal |
|
|
|
|
|
cs.ProposalReceiveTime = recvTime |
|
|
|
|
|
cs.mtx.Unlock() |
|
|
cs.calculateProposalTimestampDifferenceMetric() |
|
|
cs.calculateProposalTimestampDifferenceMetric() |
|
|
// We don't update cs.ProposalBlockParts if it is already set.
|
|
|
// We don't update cs.ProposalBlockParts if it is already set.
|
|
|
// This happens if we're already in cstypes.RoundStepCommit or if there is a valid block in the current round.
|
|
|
// This happens if we're already in cstypes.RoundStepCommit or if there is a valid block in the current round.
|
|
|