mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-07 10:12:19 +00:00
69 lines
2.5 KiB
Go
69 lines
2.5 KiB
Go
package state
|
|
|
|
import (
|
|
"encoding/binary"
|
|
|
|
v "github.com/prysmaticlabs/prysm/beacon-chain/core/validators"
|
|
pb "github.com/prysmaticlabs/prysm/proto/beacon/p2p/v1"
|
|
"github.com/prysmaticlabs/prysm/shared/params"
|
|
)
|
|
|
|
// FinalizeAndJustifySlots justifies slots and sets the justified streak according to Casper FFG
|
|
// conditions. It also finalizes slots when the conditions are fulfilled.
|
|
func FinalizeAndJustifySlots(
|
|
slot uint64, justifiedSlot uint64, finalizedSlot uint64,
|
|
justifiedStreak uint64, blockVoteBalance uint64, totalDeposits uint64) (uint64, uint64, uint64) {
|
|
cycleLength := params.BeaconConfig().CycleLength
|
|
|
|
if 3*blockVoteBalance >= 2*totalDeposits {
|
|
if slot > justifiedSlot {
|
|
justifiedSlot = slot
|
|
}
|
|
justifiedStreak++
|
|
} else {
|
|
justifiedStreak = 0
|
|
}
|
|
|
|
newFinalizedSlot := slot - cycleLength - 1
|
|
|
|
if slot > cycleLength && justifiedStreak >= cycleLength+1 && newFinalizedSlot > finalizedSlot {
|
|
finalizedSlot = newFinalizedSlot
|
|
}
|
|
|
|
return justifiedSlot, finalizedSlot, justifiedStreak
|
|
}
|
|
|
|
// UpdateCrosslinks checks the vote balances and if there is a supermajority it sets the crosslink
|
|
// for that shard.
|
|
func UpdateCrosslinks(slot uint64, voteBalance uint64, totalBalance uint64,
|
|
attestation *pb.AggregatedAttestation, crosslinkRecords []*pb.CrosslinkRecord) []*pb.CrosslinkRecord {
|
|
// if 2/3 of committee voted on this crosslink, update the crosslink
|
|
// with latest dynasty number, shard block hash, and slot number.
|
|
voteMajority := 3*voteBalance >= 2*totalBalance
|
|
if voteMajority {
|
|
crosslinkRecords[attestation.Shard] = &pb.CrosslinkRecord{
|
|
ShardBlockHash: attestation.ShardBlockHash,
|
|
Slot: slot,
|
|
}
|
|
}
|
|
return crosslinkRecords
|
|
}
|
|
|
|
// ProcessSpecialRecords processes the pending special record objects,
|
|
// this is called during crystallized state transition.
|
|
func ProcessSpecialRecords(slotNumber uint64, validators []*pb.ValidatorRecord,
|
|
pendingSpecials []*pb.SpecialRecord) ([]*pb.ValidatorRecord, error) {
|
|
// For each special record object in active state.
|
|
for _, specialRecord := range pendingSpecials {
|
|
// Covers validators submitted logouts from last cycle.
|
|
if specialRecord.Kind == uint32(params.Logout) {
|
|
validatorIndex := binary.BigEndian.Uint64(specialRecord.Data[0])
|
|
exitedValidator := v.ExitValidator(validators[validatorIndex], slotNumber, false)
|
|
validators[validatorIndex] = exitedValidator
|
|
// TODO(#633): Verify specialRecord.Data[1] as signature.
|
|
// BLSVerify(pubkey=validator.pubkey, msg=hash(LOGOUT_MESSAGE + bytes8(version))
|
|
}
|
|
}
|
|
return validators, nil
|
|
}
|