Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions lib/block_view.go
Original file line number Diff line number Diff line change
Expand Up @@ -3043,10 +3043,10 @@ func (bav *UtxoView) _connectUpdateGlobalParams(
return 0, 0, nil, fmt.Errorf("_connectUpdateGlobalParams: unable to decode ValidatorSetMaxNumValidators as uint64")
}
}
if len(extraData[StakingRewardDistributionMaxNumStakersKey]) > 0 {
newGlobalParamsEntry.StakingRewardDistributionMaxNumStakers, bytesRead = Uvarint(extraData[StakingRewardDistributionMaxNumStakersKey])
if len(extraData[StakingRewardsMaxNumStakesKey]) > 0 {
newGlobalParamsEntry.StakingRewardsMaxNumStakes, bytesRead = Uvarint(extraData[StakingRewardsMaxNumStakesKey])
if bytesRead <= 0 {
return 0, 0, nil, fmt.Errorf("_connectUpdateGlobalParams: unable to decode StakingRewardDistributionMaxNumStakers as uint64")
return 0, 0, nil, fmt.Errorf("_connectUpdateGlobalParams: unable to decode StakingRewardsMaxNumStakes as uint64")
}
}
if len(extraData[EpochDurationNumBlocksKey]) > 0 {
Expand Down
14 changes: 7 additions & 7 deletions lib/block_view_types.go
Original file line number Diff line number Diff line change
Expand Up @@ -3777,10 +3777,10 @@ type GlobalParamsEntry struct {
// consensus.
ValidatorSetMaxNumValidators uint64

// StakingRewardDistributionMaxNumStakers is the maximum number of stake entries
// that are eligible to receive block rewards every epoch in the Proof-of-Stake
// StakingRewardsMaxNumStakes is the maximum number of stake entries that are
// eligible to receive block rewards every epoch in the Proof-of-Stake
// consensus.
StakingRewardDistributionMaxNumStakers uint64
StakingRewardsMaxNumStakes uint64

// EpochDurationNumBlocks is the number of blocks included in one epoch.
EpochDurationNumBlocks uint64
Expand All @@ -3803,7 +3803,7 @@ func (gp *GlobalParamsEntry) Copy() *GlobalParamsEntry {
ValidatorJailEpochDuration: gp.ValidatorJailEpochDuration,
LeaderScheduleMaxNumValidators: gp.LeaderScheduleMaxNumValidators,
ValidatorSetMaxNumValidators: gp.ValidatorSetMaxNumValidators,
StakingRewardDistributionMaxNumStakers: gp.StakingRewardDistributionMaxNumStakers,
StakingRewardsMaxNumStakes: gp.StakingRewardsMaxNumStakes,
EpochDurationNumBlocks: gp.EpochDurationNumBlocks,
JailInactiveValidatorGracePeriodEpochs: gp.JailInactiveValidatorGracePeriodEpochs,
}
Expand All @@ -3825,7 +3825,7 @@ func (gp *GlobalParamsEntry) RawEncodeWithoutMetadata(blockHeight uint64, skipMe
data = append(data, UintToBuf(gp.ValidatorJailEpochDuration)...)
data = append(data, UintToBuf(gp.LeaderScheduleMaxNumValidators)...)
data = append(data, UintToBuf(gp.ValidatorSetMaxNumValidators)...)
data = append(data, UintToBuf(gp.StakingRewardDistributionMaxNumStakers)...)
data = append(data, UintToBuf(gp.StakingRewardsMaxNumStakes)...)
data = append(data, UintToBuf(gp.EpochDurationNumBlocks)...)
data = append(data, UintToBuf(gp.JailInactiveValidatorGracePeriodEpochs)...)
}
Expand Down Expand Up @@ -3878,9 +3878,9 @@ func (gp *GlobalParamsEntry) RawDecodeWithoutMetadata(blockHeight uint64, rr *by
if err != nil {
return errors.Wrapf(err, "GlobalParamsEntry.Decode: Problem reading ValidatorSetMaxNumValidators: ")
}
gp.StakingRewardDistributionMaxNumStakers, err = ReadUvarint(rr)
gp.StakingRewardsMaxNumStakes, err = ReadUvarint(rr)
if err != nil {
return errors.Wrapf(err, "GlobalParamsEntry.Decode: Problem reading StakingRewardDistributionMaxNumStakers: ")
return errors.Wrapf(err, "GlobalParamsEntry.Decode: Problem reading StakingRewardsMaxNumStakes: ")
}
gp.EpochDurationNumBlocks, err = ReadUvarint(rr)
if err != nil {
Expand Down
14 changes: 7 additions & 7 deletions lib/constants.go
Original file line number Diff line number Diff line change
Expand Up @@ -670,9 +670,9 @@ type DeSoParams struct {
// that are included in the validator set for any given epoch.
DefaultValidatorSetMaxNumValidators uint64

// DefaultStakingRewardDistributionMaxNumStakers is the default number of stake entries
// DefaultStakingRewardsMaxNumStakes is the default number of stake entries
// that are included in the staking reward distribution in each epoch.
DefaultStakingRewardDistributionMaxNumStakers uint64
DefaultStakingRewardsMaxNumStakes uint64

// DefaultEpochDurationNumBlocks is the default number of blocks included in one epoch.
DefaultEpochDurationNumBlocks uint64
Expand Down Expand Up @@ -1074,8 +1074,8 @@ var DeSoMainnetParams = DeSoParams{
// The max number of validators included in a validator set for any given epoch.
DefaultValidatorSetMaxNumValidators: uint64(1000),

// The max number of stakers included in a staking rewards distribution every epoch.
DefaultStakingRewardDistributionMaxNumStakers: uint64(10000),
// The max number of stakes included in a staking rewards distribution every epoch.
DefaultStakingRewardsMaxNumStakes: uint64(10000),

// The number of blocks in one epoch
DefaultEpochDurationNumBlocks: uint64(3600),
Expand Down Expand Up @@ -1329,8 +1329,8 @@ var DeSoTestnetParams = DeSoParams{
// The max number of validators included in a validator set for any given epoch.
DefaultValidatorSetMaxNumValidators: uint64(1000),

// The max number of stakers included in a staking rewards distribution every epoch.
DefaultStakingRewardDistributionMaxNumStakers: uint64(10000),
// The max number of stakes included in a staking rewards distribution every epoch.
DefaultStakingRewardsMaxNumStakes: uint64(10000),

// The number of blocks in one epoch
DefaultEpochDurationNumBlocks: uint64(3600),
Expand Down Expand Up @@ -1386,7 +1386,7 @@ const (
ValidatorJailEpochDurationKey = "ValidatorJailEpochDuration"
LeaderScheduleMaxNumValidatorsKey = "LeaderScheduleMaxNumValidators"
ValidatorSetMaxNumValidatorsKey = "ValidatorSetMaxNumValidators"
StakingRewardDistributionMaxNumStakersKey = "StakingRewardDistributionMaxNumStakers"
StakingRewardsMaxNumStakesKey = "StakingRewardsMaxNumStakes"
EpochDurationNumBlocksKey = "EpochDurationNumBlocks"
JailInactiveValidatorGracePeriodEpochsKey = "JailInactiveValidatorGracePeriodEpochs"

Expand Down
2 changes: 1 addition & 1 deletion lib/pos_epoch_complete_hook.go
Original file line number Diff line number Diff line change
Expand Up @@ -103,7 +103,7 @@ func (bav *UtxoView) RunEpochCompleteHook(blockHeight uint64) error {
}

// Snapshot the current top n stake entries.
topStakeEntries, err := bav.GetTopStakesByStakeAmount(currentGlobalParamsEntry.StakingRewardDistributionMaxNumStakers)
topStakeEntries, err := bav.GetTopStakesByStakeAmount(currentGlobalParamsEntry.StakingRewardsMaxNumStakes)
if err != nil {
return errors.Wrapf(err, "RunEpochCompleteHook: error retrieving top StakeEntries: ")
}
Expand Down
6 changes: 3 additions & 3 deletions lib/pos_snapshot_entries.go
Original file line number Diff line number Diff line change
Expand Up @@ -101,8 +101,8 @@ func _mergeGlobalParamEntryDefaults(bav *UtxoView, globalParamsEntry *GlobalPara
if globalParamsEntryCopy.ValidatorSetMaxNumValidators == 0 {
globalParamsEntryCopy.ValidatorSetMaxNumValidators = bav.Params.DefaultValidatorSetMaxNumValidators
}
if globalParamsEntryCopy.StakingRewardDistributionMaxNumStakers == 0 {
globalParamsEntryCopy.StakingRewardDistributionMaxNumStakers = bav.Params.DefaultStakingRewardDistributionMaxNumStakers
if globalParamsEntryCopy.StakingRewardsMaxNumStakes == 0 {
globalParamsEntryCopy.StakingRewardsMaxNumStakes = bav.Params.DefaultStakingRewardsMaxNumStakes
}
if globalParamsEntryCopy.EpochDurationNumBlocks == 0 {
globalParamsEntryCopy.EpochDurationNumBlocks = bav.Params.DefaultEpochDurationNumBlocks
Expand Down Expand Up @@ -686,7 +686,7 @@ type SnapshotStakeMapKey struct {
}

// This is a bare bones in-memory only construct used to capture the ValidatorPKID,
// StakerPKID, and StakeAmountNanos from a StakeEntry that has been snapshot. We
// StakerPKID, and StakeAmountNanos from a StakeEntry that has been snapshotted. We
// define a new type here rather than re-using the StakeEntry type to reduce the risk
// of bugs. The StakeEntry type has additional fields (ex: RestakeRewards, ExtraData)
// that are not snapshotted.
Expand Down