mirror of
https://github.com/kaspanet/kaspad.git
synced 2025-03-30 15:08:33 +00:00
3dbc42b4f7
* Replace the old blockSubsidy parameters with the new ones. * Return subsidyGenesisReward if blockHash is the genesis hash. * Traverse a block's past for the subsidy calculation. * Partially implement SubsidyStore. * Refer to SubsidyStore from CoinbaseManager. * Wrap calcBlockSubsidy in getBlockSubsidy, which first checks the database. * Fix finalityStore not calling GenerateShardingID. * Implement calculateAveragePastSubsidy. * Implement calculateMergeSetSubsidySum. * Implement calculateSubsidyRandomVariable. * Implement calcBlockSubsidy. * Add a TODO about floats. * Update the calcBlockSubsidy TODO. * Use binary.LittleEndian in calculateSubsidyRandomVariable. * Fix bad range in calculateSubsidyRandomVariable. * Replace float64 with big.Rat everywhere except for subsidyRandomVariable. * Fix a nil dereference. * Use a random walk to approximate the normal distribution. * In order to avoid unsupported fractional results from powInt64, flip the numerator and the denominator manually. * Set standardDeviation to 0.25, MaxSompi to 10_000_000_000 * SompiPerKaspa and defaultSubsidyGenesisReward to 1_000. * Set the standard deviation to 0.2. * Use a binomial distribution instead of trying to estimate the normal distribution. * Change some values around. * Clamp the block subsidy. * Remove the fake duplicate constants in the util package. * Reduce MaxSompi to only 100m Kaspa to avoid hitting the uint64 ceiling. * Lower MaxSompi further to avoid new and exciting ways for the uint64 ceiling to be hit. * Remove debug logs. * Fix a couple of failing tests. * Fix TestBlockWindow. * Fix limitTransactionCount sometimes crashing on index-out-of-bounds. * In TrustedDataDataDAABlock, replace BlockHeader with DomainBlock * In calculateAveragePastSubsidy, use blockWindow instead of doing a BFS manually. * Remove the reference to DAGTopologyManager in coinbaseManager. * Add subsidy to the coinbase payload. * Get rid of the subsidy store and extract subsidies out of coinbase transactions. * Keep a blockWindow amount of blocks under the virtual for IBD purposes. * Manually remove the virtual genesis from the merge set. * Fix simnet genesis. * Fix TestPruning. * Fix TestCheckBlockIsNotPruned. * Fix TestBlockWindow. * Fix TestCalculateSignatureHashSchnorr. * Fix TestCalculateSignatureHashECDSA. * Fix serializing the wrong value into the coinbase payload. * Rename coinbaseOutputForBlueBlock to coinbaseOutputAndSubsidyForBlueBlock. * Add a TODO about optimizing trusted data DAA window blocks. * Expand on a comment in TestCheckBlockIsNotPruned. * In calcBlockSubsidy, divide the big.Int numerator by the big.Int denominator instead of converting to float64. * Clarify a comment. * Rename SubsidyMinGenesisReward to MinSubsidy. * Properly handle trusted data blocks in calculateMergeSetSubsidySum. * Use the first two bytes of the selected parent's hash for randomness instead of math/rand. * Restore maxSompi to what it used to be. * Fix TestPruning. * Fix TestAmountCreation. * Fix TestBlockWindow. * Fix TestAmountUnitConversions. * Increase the timeout in many-tips to 30 minutes. * Check coinbase subsidy for every block * Re-rename functions * Use shift instead of powInt64 to determine subsidyRandom Co-authored-by: Ori Newman <orinewman1@gmail.com>
64 lines
1.9 KiB
Go
64 lines
1.9 KiB
Go
package finalitystore
|
|
|
|
import (
|
|
"github.com/kaspanet/kaspad/domain/consensus/model"
|
|
"github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
|
|
"github.com/kaspanet/kaspad/domain/consensus/utils/lrucache"
|
|
"github.com/kaspanet/kaspad/util/staging"
|
|
)
|
|
|
|
var bucketName = []byte("finality-points")
|
|
|
|
type finalityStore struct {
|
|
shardID model.StagingShardID
|
|
cache *lrucache.LRUCache
|
|
bucket model.DBBucket
|
|
}
|
|
|
|
// New instantiates a new FinalityStore
|
|
func New(prefixBucket model.DBBucket, cacheSize int, preallocate bool) model.FinalityStore {
|
|
return &finalityStore{
|
|
shardID: staging.GenerateShardingID(),
|
|
cache: lrucache.New(cacheSize, preallocate),
|
|
bucket: prefixBucket.Bucket(bucketName),
|
|
}
|
|
}
|
|
|
|
func (fs *finalityStore) StageFinalityPoint(stagingArea *model.StagingArea, blockHash *externalapi.DomainHash, finalityPointHash *externalapi.DomainHash) {
|
|
stagingShard := fs.stagingShard(stagingArea)
|
|
|
|
stagingShard.toAdd[*blockHash] = finalityPointHash
|
|
}
|
|
|
|
func (fs *finalityStore) FinalityPoint(dbContext model.DBReader, stagingArea *model.StagingArea, blockHash *externalapi.DomainHash) (*externalapi.DomainHash, error) {
|
|
stagingShard := fs.stagingShard(stagingArea)
|
|
|
|
if finalityPointHash, ok := stagingShard.toAdd[*blockHash]; ok {
|
|
return finalityPointHash, nil
|
|
}
|
|
|
|
if finalityPointHash, ok := fs.cache.Get(blockHash); ok {
|
|
return finalityPointHash.(*externalapi.DomainHash), nil
|
|
}
|
|
|
|
finalityPointHashBytes, err := dbContext.Get(fs.hashAsKey(blockHash))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
finalityPointHash, err := externalapi.NewDomainHashFromByteSlice(finalityPointHashBytes)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
fs.cache.Add(blockHash, finalityPointHash)
|
|
return finalityPointHash, nil
|
|
}
|
|
|
|
func (fs *finalityStore) IsStaged(stagingArea *model.StagingArea) bool {
|
|
return fs.stagingShard(stagingArea).isStaged()
|
|
}
|
|
|
|
func (fs *finalityStore) hashAsKey(hash *externalapi.DomainHash) model.DBKey {
|
|
return fs.bucket.Key(hash.ByteSlice())
|
|
}
|