forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

eth/catalyst: add comments

Browse source
This commit is contained in:
Marius van der Wijden 2023-11-27 13:12:26 +01:00
parent 790ce4aa79
commit 6ff924abf5
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
eth/catalyst/simulated_beacon.go
View file

@ -274,6 +274,7 @@ func (c *SimulatedBeacon) setCurrentState(headHash, finalizedHash common.Hash) {
} }
} }
// Commit seals a block on demand.
func (c *SimulatedBeacon) Commit() common.Hash { func (c *SimulatedBeacon) Commit() common.Hash {
withdrawals := c.withdrawals.gatherPending(10) withdrawals := c.withdrawals.gatherPending(10)
if err := c.sealBlock(withdrawals, uint64(time.Now().Unix())); err != nil { if err := c.sealBlock(withdrawals, uint64(time.Now().Unix())); err != nil {
@ -282,7 +283,7 @@ func (c *SimulatedBeacon) Commit() common.Hash {
return c.eth.BlockChain().CurrentBlock().Hash() return c.eth.BlockChain().CurrentBlock().Hash()
} }
// Rollback un-sends previously added transactions // Rollback un-sends previously added transactions.
func (c *SimulatedBeacon) Rollback() { func (c *SimulatedBeacon) Rollback() {
// Flush all transactions from the transaction pools // Flush all transactions from the transaction pools
c.eth.TxPool().SetGasTip(big.NewInt(-1)) c.eth.TxPool().SetGasTip(big.NewInt(-1))
@ -291,6 +292,7 @@ func (c *SimulatedBeacon) Rollback() {
c.eth.TxPool().SetGasTip(big.NewInt(params.GWei)) c.eth.TxPool().SetGasTip(big.NewInt(params.GWei))
} }
// Fork sets the head to the provided hash.
func (c *SimulatedBeacon) Fork(ctx context.Context, parentHash common.Hash) error { func (c *SimulatedBeacon) Fork(ctx context.Context, parentHash common.Hash) error {
if len(c.eth.TxPool().Pending(false)) != 0 { if len(c.eth.TxPool().Pending(false)) != 0 {
return errors.New("pending block dirty") return errors.New("pending block dirty")
@ -302,6 +304,7 @@ func (c *SimulatedBeacon) Fork(ctx context.Context, parentHash common.Hash) erro
return c.eth.BlockChain().SetHead(parent.NumberU64()) return c.eth.BlockChain().SetHead(parent.NumberU64())
} }
// AdjustTime creates a new block with an adjusted timestamp.
func (c *SimulatedBeacon) AdjustTime(adjustment time.Duration) error { func (c *SimulatedBeacon) AdjustTime(adjustment time.Duration) error {
if len(c.eth.TxPool().Pending(false)) != 0 { if len(c.eth.TxPool().Pending(false)) != 0 {
return errors.New("could not adjust time on non-empty block") return errors.New("could not adjust time on non-empty block")