|
|
@ -356,7 +356,7 @@ func (consensus *Consensus) onViewChange(recvMsg *FBFTMessage) { |
|
|
|
consensus.mutex.Lock() |
|
|
|
consensus.mutex.Lock() |
|
|
|
defer consensus.mutex.Unlock() |
|
|
|
defer consensus.mutex.Unlock() |
|
|
|
|
|
|
|
|
|
|
|
consensus.getLogger().Info(). |
|
|
|
consensus.getLogger().Debug(). |
|
|
|
Uint64("viewID", recvMsg.ViewID). |
|
|
|
Uint64("viewID", recvMsg.ViewID). |
|
|
|
Uint64("blockNum", recvMsg.BlockNum). |
|
|
|
Uint64("blockNum", recvMsg.BlockNum). |
|
|
|
Interface("SenderPubkeys", recvMsg.SenderPubkeys). |
|
|
|
Interface("SenderPubkeys", recvMsg.SenderPubkeys). |
|
|
@ -366,7 +366,7 @@ func (consensus *Consensus) onViewChange(recvMsg *FBFTMessage) { |
|
|
|
newLeaderKey := recvMsg.LeaderPubkey |
|
|
|
newLeaderKey := recvMsg.LeaderPubkey |
|
|
|
newLeaderPriKey, err := consensus.GetLeaderPrivateKey(newLeaderKey.Object) |
|
|
|
newLeaderPriKey, err := consensus.GetLeaderPrivateKey(newLeaderKey.Object) |
|
|
|
if err != nil { |
|
|
|
if err != nil { |
|
|
|
consensus.getLogger().Info(). |
|
|
|
consensus.getLogger().Debug(). |
|
|
|
Err(err). |
|
|
|
Err(err). |
|
|
|
Interface("SenderPubkeys", recvMsg.SenderPubkeys). |
|
|
|
Interface("SenderPubkeys", recvMsg.SenderPubkeys). |
|
|
|
Str("NextLeader", recvMsg.LeaderPubkey.Bytes.Hex()). |
|
|
|
Str("NextLeader", recvMsg.LeaderPubkey.Bytes.Hex()). |
|
|
|