EIP-4844: Rename "data gas" to "blob gas" (#7937)

See ethereum/EIPs#7354 &
ethereum/consensus-specs#3461. Prerequisite:
ledgerwatch/erigon-lib#1058

Author: yperbasis

accounts/abi/bind/backends/simulated.go

@@ -30,6 +30,7 @@ import (
 
 	"github.com/ledgerwatch/erigon-lib/chain"
 	libcommon "github.com/ledgerwatch/erigon-lib/common"
+	"github.com/ledgerwatch/erigon-lib/common/fixedgas"
 	"github.com/ledgerwatch/erigon-lib/common/hexutility"
 	"github.com/ledgerwatch/erigon-lib/kv"
 	state2 "github.com/ledgerwatch/erigon-lib/state"
@@ -172,7 +173,7 @@ func (b *SimulatedBackend) emptyPendingBlock() {
 	b.pendingBlock = blockChain.Blocks[0]
 	b.pendingReceipts = blockChain.Receipts[0]
 	b.pendingHeader = blockChain.Headers[0]
-	b.gasPool = new(core.GasPool).AddGas(b.pendingHeader.GasLimit).AddDataGas(chain.MaxDataGasPerBlock)
+	b.gasPool = new(core.GasPool).AddGas(b.pendingHeader.GasLimit).AddBlobGas(fixedgas.MaxBlobGasPerBlock)
 	if b.pendingReaderTx != nil {
 		b.pendingReaderTx.Rollback()
 	}
@@ -723,7 +724,7 @@ func (b *SimulatedBackend) callContract(_ context.Context, call ethereum.CallMsg
 	// Create a new environment which holds all relevant information
 	// about the transaction and calling mechanisms.
 	vmEnv := vm.NewEVM(evmContext, txContext, statedb, b.m.ChainConfig, vm.Config{})
-	gasPool := new(core.GasPool).AddGas(math.MaxUint64).AddDataGas(math.MaxUint64)
+	gasPool := new(core.GasPool).AddGas(math.MaxUint64).AddBlobGas(math.MaxUint64)
 
 	return core.NewStateTransition(vmEnv, msg, gasPool).TransitionDb(true /* refunds */, false /* gasBailout */)
 }
@@ -752,7 +753,7 @@ func (b *SimulatedBackend) SendTransaction(ctx context.Context, tx types.Transac
 		&b.pendingHeader.Coinbase, b.gasPool,
 		b.pendingState, state.NewNoopWriter(),
 		b.pendingHeader, tx,
-		&b.pendingHeader.GasUsed, b.pendingHeader.DataGasUsed,
+		&b.pendingHeader.GasUsed, b.pendingHeader.BlobGasUsed,
 		vm.Config{}); err != nil {
 		return err
 	}
@@ -835,6 +836,6 @@ func (m callMsg) Data() []byte                  { return m.CallMsg.Data }
 func (m callMsg) AccessList() types2.AccessList { return m.CallMsg.AccessList }
 func (m callMsg) IsFree() bool                  { return false }
 
-func (m callMsg) DataGas() uint64                { return misc.GetDataGasUsed(len(m.CallMsg.DataHashes)) }
-func (m callMsg) MaxFeePerDataGas() *uint256.Int { return m.CallMsg.MaxFeePerDataGas }
+func (m callMsg) BlobGas() uint64                { return misc.GetBlobGasUsed(len(m.CallMsg.DataHashes)) }
+func (m callMsg) MaxFeePerBlobGas() *uint256.Int { return m.CallMsg.MaxFeePerBlobGas }
 func (m callMsg) DataHashes() []libcommon.Hash   { return m.CallMsg.DataHashes }

cl/cltypes/eth1_block.go

@@ -32,8 +32,8 @@ type Eth1Block struct {
 	BlockHash     libcommon.Hash
 	Transactions  *solid.TransactionsSSZ
 	Withdrawals   *solid.ListSSZ[*types.Withdrawal]
-	DataGasUsed   uint64
-	ExcessDataGas uint64
+	BlobGasUsed   uint64
+	ExcessBlobGas uint64
 	// internals
 	version clparams.StateVersion
 }
@@ -72,9 +72,9 @@ func NewEth1BlockFromHeaderAndBody(header *types.Header, body *types.RawBody) *E
 		Withdrawals:   solid.NewStaticListSSZFromList(body.Withdrawals, 16, 44),
 	}
 
-	if header.DataGasUsed != nil && header.ExcessDataGas != nil {
-		block.DataGasUsed = *header.DataGasUsed
-		block.ExcessDataGas = *header.ExcessDataGas
+	if header.BlobGasUsed != nil && header.ExcessBlobGas != nil {
+		block.BlobGasUsed = *header.BlobGasUsed
+		block.ExcessBlobGas = *header.ExcessBlobGas
 		block.version = clparams.DenebVersion
 	} else if header.WithdrawalsHash != nil {
 		block.version = clparams.CapellaVersion
@@ -102,10 +102,10 @@ func (b *Eth1Block) PayloadHeader() (*Eth1Header, error) {
 		}
 	}
 
-	var dataGasUsed, excessDataGas uint64
+	var blobGasUsed, excessBlobGas uint64
 	if b.version >= clparams.DenebVersion {
-		dataGasUsed = b.DataGasUsed
-		excessDataGas = b.ExcessDataGas
+		blobGasUsed = b.BlobGasUsed
+		excessBlobGas = b.ExcessBlobGas
 	}
 
 	return &Eth1Header{
@@ -124,8 +124,8 @@ func (b *Eth1Block) PayloadHeader() (*Eth1Header, error) {
 		BlockHash:        b.BlockHash,
 		TransactionsRoot: transactionsRoot,
 		WithdrawalsRoot:  withdrawalsRoot,
-		DataGasUsed:      dataGasUsed,
-		ExcessDataGas:    excessDataGas,
+		BlobGasUsed:      blobGasUsed,
+		ExcessBlobGas:    excessBlobGas,
 		version:          b.version,
 	}, nil
 }
@@ -149,7 +149,7 @@ func (b *Eth1Block) EncodingSizeSSZ() (size int) {
 	}
 
 	if b.version >= clparams.DenebVersion {
-		size += 8 * 2 // DataGasUsed + ExcessDataGas
+		size += 8 * 2 // BlobGasUsed + ExcessBlobGas
 	}
 
 	return
@@ -181,7 +181,7 @@ func (b *Eth1Block) getSchema() []interface{} {
 		s = append(s, b.Withdrawals)
 	}
 	if b.version >= clparams.DenebVersion {
-		s = append(s, &b.DataGasUsed, &b.ExcessDataGas)
+		s = append(s, &b.BlobGasUsed, &b.ExcessBlobGas)
 	}
 	return s
 }
@@ -228,10 +228,10 @@ func (b *Eth1Block) RlpHeader() (*types.Header, error) {
 	}
 
 	if b.version >= clparams.DenebVersion {
-		dataGasUsed := b.DataGasUsed
-		header.DataGasUsed = &dataGasUsed
-		excessDataGas := b.ExcessDataGas
-		header.ExcessDataGas = &excessDataGas
+		blobGasUsed := b.BlobGasUsed
+		header.BlobGasUsed = &blobGasUsed
+		excessBlobGas := b.ExcessBlobGas
+		header.ExcessBlobGas = &excessBlobGas
 	}
 
 	// If the header hash does not match the block hash, return an error.

cl/cltypes/eth1_header.go

@@ -30,8 +30,8 @@ type Eth1Header struct {
 	BlockHash        libcommon.Hash
 	TransactionsRoot libcommon.Hash
 	WithdrawalsRoot  libcommon.Hash
-	DataGasUsed      uint64
-	ExcessDataGas    uint64
+	BlobGasUsed      uint64
+	ExcessBlobGas    uint64
 	// internals
 	version clparams.StateVersion
 }
@@ -60,8 +60,8 @@ func (e *Eth1Header) Capella() {
 // Capella converts the header to capella version.
 func (e *Eth1Header) Deneb() {
 	e.version = clparams.DenebVersion
-	e.DataGasUsed = 0
-	e.ExcessDataGas = 0
+	e.BlobGasUsed = 0
+	e.ExcessBlobGas = 0
 }
 
 func (e *Eth1Header) IsZero() bool {
@@ -72,7 +72,7 @@ func (e *Eth1Header) IsZero() bool {
 		e.ReceiptsRoot == libcommon.Hash{} && e.LogsBloom == types.Bloom{} && e.PrevRandao == libcommon.Hash{} && e.BlockNumber == 0 &&
 		e.GasLimit == 0 && e.GasUsed == 0 && e.Time == 0 && e.Extra.EncodingSizeSSZ() == 0 && e.BaseFeePerGas == [32]byte{} &&
 		e.BlockHash == libcommon.Hash{} && e.TransactionsRoot == libcommon.Hash{} && e.WithdrawalsRoot == libcommon.Hash{} &&
-		e.DataGasUsed == 0 && e.ExcessDataGas == 0
+		e.BlobGasUsed == 0 && e.ExcessBlobGas == 0
 }
 
 // EncodeSSZ encodes the header in SSZ format.
@@ -98,7 +98,7 @@ func (h *Eth1Header) EncodingSizeSSZ() int {
 	}
 
 	if h.version >= clparams.DenebVersion {
-		size += 8 * 2 // DataGasUsed + ExcessDataGas
+		size += 8 * 2 // BlobGasUsed + ExcessBlobGas
 	}
 	if h.Extra == nil {
 		h.Extra = solid.NewExtraData()
@@ -121,7 +121,7 @@ func (h *Eth1Header) getSchema() []interface{} {
 		s = append(s, h.WithdrawalsRoot[:])
 	}
 	if h.version >= clparams.DenebVersion {
-		s = append(s, &h.DataGasUsed, &h.ExcessDataGas)
+		s = append(s, &h.BlobGasUsed, &h.ExcessBlobGas)
 	}
 	return s
 }

cl/cltypes/eth1_header_test.go

@@ -34,8 +34,8 @@ func TestEth1Header(t *testing.T) {
 	blockHash := libcommon.Hash{}
 	transactionsRoot := libcommon.Hash{}
 	withdrawalsRoot := libcommon.Hash{}
-	dataGasUsed := uint64(50)
-	excessDataGas := uint64(60)
+	blobGasUsed := uint64(50)
+	excessBlobGas := uint64(60)
 
 	// Test Eth1Header
 	header = &Eth1Header{
@@ -54,8 +54,8 @@ func TestEth1Header(t *testing.T) {
 		BlockHash:        blockHash,
 		TransactionsRoot: transactionsRoot,
 		WithdrawalsRoot:  withdrawalsRoot,
-		DataGasUsed:      dataGasUsed,
-		ExcessDataGas:    excessDataGas,
+		BlobGasUsed:      blobGasUsed,
+		ExcessBlobGas:    excessBlobGas,
 		version:          version,
 	}
 

cl/phase1/execution_client/execution_client_direct.go

@@ -63,10 +63,10 @@ func (cc *ExecutionClientDirect) NewPayload(payload *cltypes.Eth1Block) (invalid
 	}
 	// Process Deneb
 	if payload.Version() >= clparams.DenebVersion {
-		request.DataGasUsed = new(hexutil.Uint64)
-		request.ExcessDataGas = new(hexutil.Uint64)
-		*request.DataGasUsed = hexutil.Uint64(payload.DataGasUsed)
-		*request.ExcessDataGas = hexutil.Uint64(payload.ExcessDataGas)
+		request.BlobGasUsed = new(hexutil.Uint64)
+		request.ExcessBlobGas = new(hexutil.Uint64)
+		*request.BlobGasUsed = hexutil.Uint64(payload.BlobGasUsed)
+		*request.ExcessBlobGas = hexutil.Uint64(payload.ExcessBlobGas)
 	}
 
 	payloadStatus := &engine_types.PayloadStatus{} // As it is done in the rpcdaemon

cl/phase1/execution_client/execution_client_rpc.go

@@ -102,10 +102,10 @@ func (cc *ExecutionClientRpc) NewPayload(payload *cltypes.Eth1Block) (invalid bo
 	}
 	// Process Deneb
 	if payload.Version() >= clparams.DenebVersion {
-		request.DataGasUsed = new(hexutil.Uint64)
-		request.ExcessDataGas = new(hexutil.Uint64)
-		*request.DataGasUsed = hexutil.Uint64(payload.DataGasUsed)
-		*request.ExcessDataGas = hexutil.Uint64(payload.ExcessDataGas)
+		request.BlobGasUsed = new(hexutil.Uint64)
+		request.ExcessBlobGas = new(hexutil.Uint64)
+		*request.BlobGasUsed = hexutil.Uint64(payload.BlobGasUsed)
+		*request.ExcessBlobGas = hexutil.Uint64(payload.ExcessBlobGas)
 	}
 
 	payloadStatus := &engine_types.PayloadStatus{} // As it is done in the rpcdaemon

cl/transition/impl/eth2/utils.go

@@ -2,7 +2,9 @@ package eth2
 
 import (
 	"encoding/binary"
+
 	libcommon "github.com/ledgerwatch/erigon-lib/common"
+
 	"github.com/ledgerwatch/erigon/cl/abstract"
 	"github.com/ledgerwatch/erigon/cl/cltypes"
 	"github.com/ledgerwatch/erigon/cl/utils"
@@ -40,7 +42,7 @@ func txPeekBlobVersionedHashes(txBytes []byte) []libcommon.Hash {
 		value: 32 bytes
 		data: 4 bytes - offset to C (relative to A)
 		access_list: 4 bytes - offset to D (relative to A)
-		max_fee_per_data_gas: 32 bytes
+		max_fee_per_blob_gas: 32 bytes
 		blob_versioned_hashes: 4 bytes - offset to E (relative to A)
 	*/
 	// field offset: 32 + 8 + 32 + 32 + 8 + 4 + 32 + 4 + 4 + 32 = 188

cmd/integration/commands/state_domains.go

@@ -22,6 +22,7 @@ import (
 	libcommon "github.com/ledgerwatch/erigon-lib/common"
 	"github.com/ledgerwatch/erigon-lib/common/datadir"
 	"github.com/ledgerwatch/erigon-lib/common/dbg"
+	"github.com/ledgerwatch/erigon-lib/common/fixedgas"
 	"github.com/ledgerwatch/erigon-lib/common/length"
 	"github.com/ledgerwatch/erigon-lib/kv"
 	kv2 "github.com/ledgerwatch/erigon-lib/kv/mdbx"
@@ -500,9 +501,9 @@ func (b *blockProcessor) applyBlock(
 
 	header := block.Header()
 	b.vmConfig.Debug = true
-	gp := new(core.GasPool).AddGas(block.GasLimit()).AddDataGas(chain2.MaxDataGasPerBlock)
+	gp := new(core.GasPool).AddGas(block.GasLimit()).AddBlobGas(fixedgas.MaxBlobGasPerBlock)
 	usedGas := new(uint64)
-	usedDataGas := new(uint64)
+	usedBlobGas := new(uint64)
 	var receipts types.Receipts
 	rules := b.chainConfig.Rules(block.NumberU64(), block.Time())
 
@@ -535,7 +536,7 @@ func (b *blockProcessor) applyBlock(
 			ibs.SetTxContext(tx.Hash(), block.Hash(), i)
 			ct := exec3.NewCallTracer()
 			b.vmConfig.Tracer = ct
-			receipt, _, err := core.ApplyTransaction(b.chainConfig, getHashFn, b.engine, nil, gp, ibs, b.writer, header, tx, usedGas, usedDataGas, b.vmConfig)
+			receipt, _, err := core.ApplyTransaction(b.chainConfig, getHashFn, b.engine, nil, gp, ibs, b.writer, header, tx, usedGas, usedBlobGas, b.vmConfig)
 			if err != nil {
 				return nil, fmt.Errorf("could not apply tx %d [%x] failed: %w", i, tx.Hash(), err)
 			}

cmd/state/commands/erigon4.go

@@ -23,6 +23,7 @@ import (
 	libcommon "github.com/ledgerwatch/erigon-lib/common"
 	"github.com/ledgerwatch/erigon-lib/common/datadir"
 	"github.com/ledgerwatch/erigon-lib/common/dbg"
+	"github.com/ledgerwatch/erigon-lib/common/fixedgas"
 	"github.com/ledgerwatch/erigon-lib/kv"
 	kv2 "github.com/ledgerwatch/erigon-lib/kv/mdbx"
 	libstate "github.com/ledgerwatch/erigon-lib/state"
@@ -384,9 +385,9 @@ func processBlock23(startTxNum uint64, trace bool, txNumStart uint64, rw *StateR
 
 	header := block.Header()
 	vmConfig.Debug = true
-	gp := new(core.GasPool).AddGas(block.GasLimit()).AddDataGas(chain2.MaxDataGasPerBlock)
+	gp := new(core.GasPool).AddGas(block.GasLimit()).AddBlobGas(fixedgas.MaxBlobGasPerBlock)
 	usedGas := new(uint64)
-	usedDataGas := new(uint64)
+	usedBlobGas := new(uint64)
 	var receipts types.Receipts
 	rules := chainConfig.Rules(block.NumberU64(), block.Time())
 	txNum := txNumStart
@@ -420,7 +421,7 @@ func processBlock23(startTxNum uint64, trace bool, txNumStart uint64, rw *StateR
 			ibs.SetTxContext(tx.Hash(), block.Hash(), i)
 			ct := exec3.NewCallTracer()
 			vmConfig.Tracer = ct
-			receipt, _, err := core.ApplyTransaction(chainConfig, getHashFn, engine, nil, gp, ibs, ww, header, tx, usedGas, usedDataGas, vmConfig)
+			receipt, _, err := core.ApplyTransaction(chainConfig, getHashFn, engine, nil, gp, ibs, ww, header, tx, usedGas, usedBlobGas, vmConfig)
 			if err != nil {
 				return 0, nil, fmt.Errorf("could not apply tx %d [%x] failed: %w", i, tx.Hash(), err)
 			}

cmd/state/commands/opcode_tracer.go

@@ -18,6 +18,7 @@ import (
 
 	chain2 "github.com/ledgerwatch/erigon-lib/chain"
 	libcommon "github.com/ledgerwatch/erigon-lib/common"
+	"github.com/ledgerwatch/erigon-lib/common/fixedgas"
 	"github.com/ledgerwatch/erigon-lib/kv"
 	"github.com/ledgerwatch/erigon-lib/kv/kvcfg"
 	"github.com/ledgerwatch/erigon-lib/kv/mdbx"
@@ -710,9 +711,9 @@ func runBlock(engine consensus.Engine, ibs *state.IntraBlockState, txnWriter sta
 	chainConfig *chain2.Config, getHeader func(hash libcommon.Hash, number uint64) *types.Header, block *types.Block, vmConfig vm.Config, trace bool, logger log.Logger) (types.Receipts, error) {
 	header := block.Header()
 	vmConfig.TraceJumpDest = true
-	gp := new(core.GasPool).AddGas(block.GasLimit()).AddDataGas(chain2.MaxDataGasPerBlock)
+	gp := new(core.GasPool).AddGas(block.GasLimit()).AddBlobGas(fixedgas.MaxBlobGasPerBlock)
 	usedGas := new(uint64)
-	usedDataGas := new(uint64)
+	usedBlobGas := new(uint64)
 	var receipts types.Receipts
 	if chainConfig.DAOForkBlock != nil && chainConfig.DAOForkBlock.Cmp(block.Number()) == 0 {
 		misc.ApplyDAOHardFork(ibs)
@@ -721,7 +722,7 @@ func runBlock(engine consensus.Engine, ibs *state.IntraBlockState, txnWriter sta
 	rules := chainConfig.Rules(block.NumberU64(), block.Time())
 	for i, tx := range block.Transactions() {
 		ibs.SetTxContext(tx.Hash(), block.Hash(), i)
-		receipt, _, err := core.ApplyTransaction(chainConfig, core.GetHashFn(header, getHeader), engine, nil, gp, ibs, txnWriter, header, tx, usedGas, usedDataGas, vmConfig)
+		receipt, _, err := core.ApplyTransaction(chainConfig, core.GetHashFn(header, getHeader), engine, nil, gp, ibs, txnWriter, header, tx, usedGas, usedBlobGas, vmConfig)
 		if err != nil {
 			return nil, fmt.Errorf("could not apply tx %d [%x] failed: %w", i, tx.Hash(), err)
 		}