You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
90 lines
2.7 KiB
90 lines
2.7 KiB
5 years ago
|
package network
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
"math/big"
|
||
|
|
|
||
|
|
"github.com/ethereum/go-ethereum/common"
|
||
|
|
"github.com/harmony-one/harmony/common/denominations"
|
||
|
|
"github.com/harmony-one/harmony/consensus/engine"
|
||
|
|
"github.com/harmony-one/harmony/consensus/reward"
|
||
|
|
"github.com/harmony-one/harmony/internal/utils"
|
||
|
|
"github.com/harmony-one/harmony/numeric"
|
||
|
|
)
|
||
|
|
|
||
|
|
var (
|
||
|
|
// BlockReward is the block reward, to be split evenly among block signers.
|
||
|
|
BlockReward = new(big.Int).Mul(big.NewInt(24), big.NewInt(denominations.One))
|
||
|
|
// BaseStakedReward is the base block reward for epos.
|
||
|
|
BaseStakedReward = numeric.NewDecFromBigInt(new(big.Int).Mul(
|
||
|
|
big.NewInt(18), big.NewInt(denominations.One),
|
||
|
|
))
|
||
|
|
// BlockRewardStakedCase is the baseline block reward in staked case -
|
||
|
|
totalTokens = numeric.NewDecFromBigInt(
|
||
|
|
new(big.Int).Mul(big.NewInt(12600000000), big.NewInt(denominations.One)),
|
||
|
|
)
|
||
|
|
targetStakedPercentage = numeric.MustNewDecFromStr("0.35")
|
||
|
|
dynamicAdjust = numeric.MustNewDecFromStr("0.4")
|
||
|
|
// ErrPayoutNotEqualBlockReward ..
|
||
|
|
ErrPayoutNotEqualBlockReward = errors.New("total payout not equal to blockreward")
|
||
|
|
// NoReward ..
|
||
|
|
NoReward = common.Big0
|
||
|
|
)
|
||
|
|
|
||
|
|
func adjust(amount numeric.Dec) numeric.Dec {
|
||
|
|
return amount.MulTruncate(
|
||
|
|
numeric.NewDecFromBigInt(big.NewInt(denominations.One)),
|
||
|
|
)
|
||
|
|
}
|
||
|
|
|
||
|
|
// Adjustment ..
|
||
|
|
func Adjustment(percentageStaked numeric.Dec) (numeric.Dec, numeric.Dec) {
|
||
|
|
howMuchOff := targetStakedPercentage.Sub(percentageStaked)
|
||
|
|
adjustBy := adjust(
|
||
|
|
howMuchOff.MulTruncate(numeric.NewDec(100)).Mul(dynamicAdjust),
|
||
|
|
)
|
||
|
|
return howMuchOff, adjustBy
|
||
|
|
}
|
||
|
|
|
||
|
|
// WhatPercentStakedNow ..
|
||
|
|
func WhatPercentStakedNow(
|
||
|
|
beaconchain engine.ChainReader,
|
||
|
|
timestamp int64,
|
||
|
|
) (*big.Int, *numeric.Dec, error) {
|
||
|
|
stakedNow := numeric.ZeroDec()
|
||
|
|
// Only active validators' stake is counted in stake ratio because only their stake is under slashing risk
|
||
|
|
active, err := beaconchain.ReadActiveValidatorList()
|
||
|
|
if err != nil {
|
||
|
|
return nil, nil, err
|
||
|
|
}
|
||
|
|
|
||
|
|
soFarDoledOut, err := beaconchain.ReadBlockRewardAccumulator(
|
||
|
|
beaconchain.CurrentHeader().Number().Uint64(),
|
||
|
|
)
|
||
|
|
|
||
|
|
if err != nil {
|
||
|
|
return nil, nil, err
|
||
|
|
}
|
||
|
|
|
||
|
|
dole := numeric.NewDecFromBigInt(soFarDoledOut)
|
||
|
|
|
||
|
|
for i := range active {
|
||
|
|
wrapper, err := beaconchain.ReadValidatorInformation(active[i])
|
||
|
|
if err != nil {
|
||
|
|
return nil, nil, err
|
||
|
|
}
|
||
|
|
stakedNow = stakedNow.Add(
|
||
|
|
numeric.NewDecFromBigInt(wrapper.TotalDelegation()),
|
||
|
|
)
|
||
|
|
}
|
||
|
|
percentage := stakedNow.Quo(totalTokens.Mul(
|
||
|
|
reward.PercentageForTimeStamp(timestamp),
|
||
|
|
).Add(dole))
|
||
|
|
utils.Logger().Info().
|
||
|
|
Str("so-far-doled-out", dole.String()).
|
||
|
|
Str("staked-percentage", percentage.String()).
|
||
|
|
Str("currently-staked", stakedNow.String()).
|
||
|
|
Msg("Computed how much staked right now")
|
||
|
|
return soFarDoledOut, &percentage, nil
|
||
|
|
}
|