|
|
@ -803,8 +803,6 @@ func (i *IBFT) runPrepare(ctx context.Context) { |
|
|
|
for { |
|
|
|
for { |
|
|
|
prepareMessages := i.handlePrepare(view) |
|
|
|
prepareMessages := i.handlePrepare(view) |
|
|
|
if prepareMessages != nil { |
|
|
|
if prepareMessages != nil { |
|
|
|
i.log.Debug("commit message multicasted") |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
i.state.finalizePrepare( |
|
|
|
i.state.finalizePrepare( |
|
|
|
&proto.PreparedCertificate{ |
|
|
|
&proto.PreparedCertificate{ |
|
|
|
ProposalMessage: i.state.getProposalMessage(), |
|
|
|
ProposalMessage: i.state.getProposalMessage(), |
|
|
@ -818,6 +816,8 @@ func (i *IBFT) runPrepare(ctx context.Context) { |
|
|
|
// Multicast the COMMIT message
|
|
|
|
// Multicast the COMMIT message
|
|
|
|
i.sendCommitMessage(view) |
|
|
|
i.sendCommitMessage(view) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
i.log.Debug("commit message multicasted") |
|
|
|
|
|
|
|
|
|
|
|
return |
|
|
|
return |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|