Documentation ¶
Index ¶
- Variables
- func TrimBlock(chain consensus.ChainHeaderReader, batch ethdb.Batch, denomination uint8, ...) [][]byte
- func UpdateTrimDepths(trimDepths map[uint8]uint64, utxoSetSize uint64) bool
- type Blake3pow
- func New(config Config, notify []string, noverify bool, logger *log.Logger) *Blake3pow
- func NewFakeDelayer(delay time.Duration) *Blake3pow
- func NewFakeFailer(fail uint64) *Blake3pow
- func NewFaker() *Blake3pow
- func NewFullFaker() *Blake3pow
- func NewShared() *Blake3pow
- func NewTester(notify []string, noverify bool) *Blake3pow
- func (blake3pow *Blake3pow) Author(header *types.WorkObject) (common.Address, error)
- func (blake3pow *Blake3pow) CalcDifficulty(chain consensus.ChainHeaderReader, parent *types.WorkObjectHeader, ...) *big.Int
- func (blake3pow *Blake3pow) CalcOrder(chain consensus.BlockReader, header *types.WorkObject) (*big.Int, int, error)
- func (blake3pow *Blake3pow) CalcRank(chain consensus.ChainHeaderReader, header *types.WorkObject) (int, error)
- func (blake3pow *Blake3pow) CheckIfValidWorkShare(workShare *types.WorkObjectHeader) types.WorkShareValidity
- func (blake3pow *Blake3pow) CheckWorkThreshold(workShare *types.WorkObjectHeader, workShareThresholdDiff int) bool
- func (blake3pow *Blake3pow) ComputePowHash(header *types.WorkObjectHeader) (common.Hash, error)
- func (blake3pow *Blake3pow) ComputePowLight(header *types.WorkObjectHeader) (common.Hash, common.Hash)
- func (blake3pow *Blake3pow) DeltaLogEntropy(chain consensus.ChainHeaderReader, header *types.WorkObject) *big.Int
- func (blake3pow *Blake3pow) Finalize(chain consensus.ChainHeaderReader, batch ethdb.Batch, header *types.WorkObject, ...) (*multiset.MultiSet, uint64, error)
- func (blake3pow *Blake3pow) FinalizeAndAssemble(chain consensus.ChainHeaderReader, header *types.WorkObject, ...) (*types.WorkObject, error)
- func (blake3pow *Blake3pow) IntrinsicLogEntropy(powHash common.Hash) *big.Int
- func (blake3pow *Blake3pow) IsDomCoincident(chain consensus.ChainHeaderReader, header *types.WorkObject) bool
- func (blake3pow *Blake3pow) Mine(header *types.WorkObject, abort <-chan struct{}, found chan *types.WorkObject)
- func (blake3pow *Blake3pow) MineToThreshold(workObject *types.WorkObject, workShareThreshold int, abort <-chan struct{}, ...)
- func (blake3pow *Blake3pow) NodeLocation() common.Location
- func (blake3pow *Blake3pow) Prepare(chain consensus.ChainHeaderReader, header *types.WorkObject, ...) error
- func (blake3pow *Blake3pow) Seal(header *types.WorkObject, results chan<- *types.WorkObject, ...) error
- func (blake3pow *Blake3pow) SetThreads(threads int)
- func (blake3pow *Blake3pow) Threads() int
- func (blake3pow *Blake3pow) TotalLogEntropy(chain consensus.ChainHeaderReader, header *types.WorkObject) *big.Int
- func (blake3pow *Blake3pow) UncledDeltaLogEntropy(chain consensus.ChainHeaderReader, header *types.WorkObject) *big.Int
- func (blake3pow *Blake3pow) UncledLogEntropy(block *types.WorkObject) *big.Int
- func (blake3pow *Blake3pow) VerifyHeader(chain consensus.ChainHeaderReader, header *types.WorkObject) error
- func (blake3pow *Blake3pow) VerifyHeaders(chain consensus.ChainHeaderReader, headers []*types.WorkObject) (chan<- struct{}, <-chan error)
- func (blake3pow *Blake3pow) VerifySeal(header *types.WorkObjectHeader) (common.Hash, error)
- func (blake3pow *Blake3pow) VerifyUncles(chain consensus.ChainReader, block *types.WorkObject) error
- func (blake3pow *Blake3pow) WorkShareLogEntropy(chain consensus.ChainHeaderReader, wo *types.WorkObject) (*big.Int, error)
- type Config
- type Mode
Constants ¶
This section is empty.
Variables ¶
var ( ContextTimeFactor = big10 ZoneBlockReward = big.NewInt(5e+18) RegionBlockReward = new(big.Int).Mul(ZoneBlockReward, big3) PrimeBlockReward = new(big.Int).Mul(RegionBlockReward, big3) )
Blake3pow proof-of-work protocol constants.
Functions ¶
func TrimBlock ¶ added in v0.35.0
func TrimBlock(chain consensus.ChainHeaderReader, batch ethdb.Batch, denomination uint8, checkDenom bool, blockHeight uint64, blockHash common.Hash, utxosDelete *[]common.Hash, trimmedUtxos *[]*types.SpentUtxoEntry, collidingKeys [][]byte, utxoSetSize *uint64, deleteFromDb bool, lock *sync.Mutex, logger *log.Logger) [][]byte
TrimBlock trims all UTXOs of a given denomination that were created in a given block. In the event of an attacker intentionally creating too many 9-byte keys that collide, we return the colliding keys to be trimmed in the next block.
Types ¶
type Blake3pow ¶
type Blake3pow struct {
// contains filtered or unexported fields
}
Blake3pow is a proof-of-work consensus engine using the blake3 hash algorithm
func New ¶
New creates a full sized blake3pow PoW scheme and starts a background thread for remote mining, also optionally notifying a batch of remote services of new work packages.
func NewFakeDelayer ¶
NewFakeDelayer creates a blake3pow consensus engine with a fake PoW scheme that accepts all blocks as valid, but delays verifications by some time, though they still have to conform to the Quai consensus rules.
func NewFakeFailer ¶
NewFakeFailer creates a blake3pow consensus engine with a fake PoW scheme that accepts all blocks as valid apart from the single one specified, though they still have to conform to the Quai consensus rules.
func NewFaker ¶
func NewFaker() *Blake3pow
NewFaker creates a blake3pow consensus engine with a fake PoW scheme that accepts all blocks' seal as valid, though they still have to conform to the Quai consensus rules.
func NewFullFaker ¶
func NewFullFaker() *Blake3pow
NewFullFaker creates an blake3pow consensus engine with a full fake scheme that accepts all blocks as valid, without checking any consensus rules whatsoever.
func NewShared ¶
func NewShared() *Blake3pow
NewShared creates a full sized blake3pow PoW shared between all requesters running in the same process.
func NewTester ¶
NewTester creates a small sized blake3pow PoW scheme useful only for testing purposes.
func (*Blake3pow) Author ¶
Author implements consensus.Engine, returning the header's coinbase as the proof-of-work verified author of the block.
func (*Blake3pow) CalcDifficulty ¶
func (blake3pow *Blake3pow) CalcDifficulty(chain consensus.ChainHeaderReader, parent *types.WorkObjectHeader, expansionNum uint8) *big.Int
CalcDifficulty is the difficulty adjustment algorithm. It returns the difficulty that a new block should have when created at time given the parent block's time and difficulty.
func (*Blake3pow) CalcOrder ¶
func (blake3pow *Blake3pow) CalcOrder(chain consensus.BlockReader, header *types.WorkObject) (*big.Int, int, error)
CalcOrder returns the order of the block within the hierarchy of chains
func (*Blake3pow) CalcRank ¶ added in v0.29.0
func (blake3pow *Blake3pow) CalcRank(chain consensus.ChainHeaderReader, header *types.WorkObject) (int, error)
CalcRank returns the rank of the block within the hierarchy of chains, this determines the level of the interlink
func (*Blake3pow) CheckIfValidWorkShare ¶ added in v0.29.0
func (blake3pow *Blake3pow) CheckIfValidWorkShare(workShare *types.WorkObjectHeader) types.WorkShareValidity
func (*Blake3pow) CheckWorkThreshold ¶ added in v0.32.0
func (blake3pow *Blake3pow) CheckWorkThreshold(workShare *types.WorkObjectHeader, workShareThresholdDiff int) bool
func (*Blake3pow) ComputePowHash ¶ added in v0.29.0
func (*Blake3pow) ComputePowLight ¶
func (*Blake3pow) DeltaLogEntropy ¶ added in v0.33.0
func (blake3pow *Blake3pow) DeltaLogEntropy(chain consensus.ChainHeaderReader, header *types.WorkObject) *big.Int
func (*Blake3pow) Finalize ¶
func (blake3pow *Blake3pow) Finalize(chain consensus.ChainHeaderReader, batch ethdb.Batch, header *types.WorkObject, state *state.StateDB, setRoots bool, utxoSetSize uint64, utxosCreate, utxosDelete []common.Hash) (*multiset.MultiSet, uint64, error)
Finalize implements consensus.Engine, accumulating the block and uncle rewards, setting the final state on the header Finalize returns the new MuHash of the UTXO set, the new size of the UTXO set and an error if any
func (*Blake3pow) FinalizeAndAssemble ¶
func (blake3pow *Blake3pow) FinalizeAndAssemble(chain consensus.ChainHeaderReader, header *types.WorkObject, state *state.StateDB, txs []*types.Transaction, uncles []*types.WorkObjectHeader, etxs []*types.Transaction, subManifest types.BlockManifest, receipts []*types.Receipt, parentUtxoSetSize uint64, utxosCreate, utxosDelete []common.Hash) (*types.WorkObject, error)
FinalizeAndAssemble implements consensus.Engine, accumulating the block and uncle rewards, setting the final state and assembling the block.
func (*Blake3pow) IntrinsicLogEntropy ¶ added in v0.33.0
IntrinsicLogEntropy returns the logarithm of the intrinsic entropy reduction of a PoW hash
func (*Blake3pow) IsDomCoincident ¶
func (blake3pow *Blake3pow) IsDomCoincident(chain consensus.ChainHeaderReader, header *types.WorkObject) bool
func (*Blake3pow) Mine ¶ added in v0.32.0
func (blake3pow *Blake3pow) Mine(header *types.WorkObject, abort <-chan struct{}, found chan *types.WorkObject)
func (*Blake3pow) MineToThreshold ¶ added in v0.32.0
func (blake3pow *Blake3pow) MineToThreshold(workObject *types.WorkObject, workShareThreshold int, abort <-chan struct{}, found chan *types.WorkObject)
func (*Blake3pow) NodeLocation ¶ added in v0.29.0
NodeLocation returns the location of the node
func (*Blake3pow) Prepare ¶
func (blake3pow *Blake3pow) Prepare(chain consensus.ChainHeaderReader, header *types.WorkObject, parent *types.WorkObject) error
Prepare implements consensus.Engine, initializing the difficulty field of a header to conform to the blake3pow protocol. The changes are done inline.
func (*Blake3pow) Seal ¶
func (blake3pow *Blake3pow) Seal(header *types.WorkObject, results chan<- *types.WorkObject, stop <-chan struct{}) error
Seal implements consensus.Engine, attempting to find a nonce that satisfies the header's difficulty requirements.
func (*Blake3pow) SetThreads ¶
SetThreads updates the number of mining threads currently enabled. Calling this method does not start mining, only sets the thread count. If zero is specified, the miner will use all cores of the machine. Setting a thread count below zero is allowed and will cause the miner to idle, without any work being done.
func (*Blake3pow) Threads ¶
Threads returns the number of mining threads currently enabled. This doesn't necessarily mean that mining is running!
func (*Blake3pow) TotalLogEntropy ¶ added in v0.33.0
func (blake3pow *Blake3pow) TotalLogEntropy(chain consensus.ChainHeaderReader, header *types.WorkObject) *big.Int
TotalLogEntropy returns the total entropy reduction if the chain since genesis to the given header
func (*Blake3pow) UncledDeltaLogEntropy ¶ added in v0.33.0
func (blake3pow *Blake3pow) UncledDeltaLogEntropy(chain consensus.ChainHeaderReader, header *types.WorkObject) *big.Int
func (*Blake3pow) UncledLogEntropy ¶ added in v0.33.0
func (blake3pow *Blake3pow) UncledLogEntropy(block *types.WorkObject) *big.Int
func (*Blake3pow) VerifyHeader ¶
func (blake3pow *Blake3pow) VerifyHeader(chain consensus.ChainHeaderReader, header *types.WorkObject) error
VerifyHeader checks whether a header conforms to the consensus rules of the stock Quai blake3pow engine.
func (*Blake3pow) VerifyHeaders ¶
func (blake3pow *Blake3pow) VerifyHeaders(chain consensus.ChainHeaderReader, headers []*types.WorkObject) (chan<- struct{}, <-chan error)
VerifyHeaders is similar to VerifyHeader, but verifies a batch of headers concurrently. The method returns a quit channel to abort the operations and a results channel to retrieve the async verifications.
func (*Blake3pow) VerifySeal ¶ added in v0.20.0
VerifySeal returns the PowHash and the verifySeal output
func (*Blake3pow) VerifyUncles ¶
func (blake3pow *Blake3pow) VerifyUncles(chain consensus.ChainReader, block *types.WorkObject) error
VerifyUncles verifies that the given block's uncles conform to the consensus rules of the stock Quai blake3pow engine.
func (*Blake3pow) WorkShareLogEntropy ¶ added in v0.33.0
func (blake3pow *Blake3pow) WorkShareLogEntropy(chain consensus.ChainHeaderReader, wo *types.WorkObject) (*big.Int, error)
type Config ¶
type Config struct { PowMode Mode DurationLimit *big.Int GasCeil uint64 NodeLocation common.Location MinDifficulty *big.Int // When set, notifications sent by the remote sealer will // be block header JSON objects instead of work package arrays. NotifyFull bool Log *log.Logger `toml:"-"` // Number of threads to mine on if mining NumThreads int }
Config are the configuration parameters of the blake3pow.