Commit 90d8c47f authored by zhiqiangxu's avatar zhiqiangxu Committed by GitHub

improve readability and fix lint (#9864)

parent ffdca48a
...@@ -39,21 +39,21 @@ type BlockProcessor struct { ...@@ -39,21 +39,21 @@ type BlockProcessor struct {
dataProvider BlockDataProvider dataProvider BlockDataProvider
} }
func NewBlockProcessorFromPayloadAttributes(provider BlockDataProvider, parent common.Hash, params *eth.PayloadAttributes) (*BlockProcessor, error) { func NewBlockProcessorFromPayloadAttributes(provider BlockDataProvider, parent common.Hash, attrs *eth.PayloadAttributes) (*BlockProcessor, error) {
header := &types.Header{ header := &types.Header{
ParentHash: parent, ParentHash: parent,
Coinbase: params.SuggestedFeeRecipient, Coinbase: attrs.SuggestedFeeRecipient,
Difficulty: common.Big0, Difficulty: common.Big0,
GasLimit: uint64(*params.GasLimit), GasLimit: uint64(*attrs.GasLimit),
Time: uint64(params.Timestamp), Time: uint64(attrs.Timestamp),
Extra: nil, Extra: nil,
MixDigest: common.Hash(params.PrevRandao), MixDigest: common.Hash(attrs.PrevRandao),
Nonce: types.EncodeNonce(0), Nonce: types.EncodeNonce(0),
ParentBeaconRoot: params.ParentBeaconBlockRoot, ParentBeaconRoot: attrs.ParentBeaconBlockRoot,
} }
// Ecotone // Ecotone
if params.ParentBeaconBlockRoot != nil { if attrs.ParentBeaconBlockRoot != nil {
zero := uint64(0) zero := uint64(0)
header.BlobGasUsed = &zero header.BlobGasUsed = &zero
header.ExcessBlobGas = &zero header.ExcessBlobGas = &zero
......
...@@ -80,20 +80,20 @@ var ( ...@@ -80,20 +80,20 @@ var (
) )
// computePayloadId computes a pseudo-random payloadid, based on the parameters. // computePayloadId computes a pseudo-random payloadid, based on the parameters.
func computePayloadId(headBlockHash common.Hash, params *eth.PayloadAttributes) engine.PayloadID { func computePayloadId(headBlockHash common.Hash, attrs *eth.PayloadAttributes) engine.PayloadID {
// Hash // Hash
hasher := sha256.New() hasher := sha256.New()
hasher.Write(headBlockHash[:]) hasher.Write(headBlockHash[:])
_ = binary.Write(hasher, binary.BigEndian, params.Timestamp) _ = binary.Write(hasher, binary.BigEndian, attrs.Timestamp)
hasher.Write(params.PrevRandao[:]) hasher.Write(attrs.PrevRandao[:])
hasher.Write(params.SuggestedFeeRecipient[:]) hasher.Write(attrs.SuggestedFeeRecipient[:])
_ = binary.Write(hasher, binary.BigEndian, params.NoTxPool) _ = binary.Write(hasher, binary.BigEndian, attrs.NoTxPool)
_ = binary.Write(hasher, binary.BigEndian, uint64(len(params.Transactions))) _ = binary.Write(hasher, binary.BigEndian, uint64(len(attrs.Transactions)))
for _, tx := range params.Transactions { for _, tx := range attrs.Transactions {
_ = binary.Write(hasher, binary.BigEndian, uint64(len(tx))) // length-prefix to avoid collisions _ = binary.Write(hasher, binary.BigEndian, uint64(len(tx))) // length-prefix to avoid collisions
hasher.Write(tx) hasher.Write(tx)
} }
_ = binary.Write(hasher, binary.BigEndian, *params.GasLimit) _ = binary.Write(hasher, binary.BigEndian, *attrs.GasLimit)
var out engine.PayloadID var out engine.PayloadID
copy(out[:], hasher.Sum(nil)[:8]) copy(out[:], hasher.Sum(nil)[:8])
return out return out
...@@ -140,22 +140,22 @@ func (ea *L2EngineAPI) IncludeTx(tx *types.Transaction, from common.Address) err ...@@ -140,22 +140,22 @@ func (ea *L2EngineAPI) IncludeTx(tx *types.Transaction, from common.Address) err
return nil return nil
} }
func (ea *L2EngineAPI) startBlock(parent common.Hash, params *eth.PayloadAttributes) error { func (ea *L2EngineAPI) startBlock(parent common.Hash, attrs *eth.PayloadAttributes) error {
if ea.blockProcessor != nil { if ea.blockProcessor != nil {
ea.log.Warn("started building new block without ending previous block", "previous", ea.blockProcessor.header, "prev_payload_id", ea.payloadID) ea.log.Warn("started building new block without ending previous block", "previous", ea.blockProcessor.header, "prev_payload_id", ea.payloadID)
} }
processor, err := NewBlockProcessorFromPayloadAttributes(ea.backend, parent, params) processor, err := NewBlockProcessorFromPayloadAttributes(ea.backend, parent, attrs)
if err != nil { if err != nil {
return err return err
} }
ea.blockProcessor = processor ea.blockProcessor = processor
ea.pendingIndices = make(map[common.Address]uint64) ea.pendingIndices = make(map[common.Address]uint64)
ea.l2ForceEmpty = params.NoTxPool ea.l2ForceEmpty = attrs.NoTxPool
ea.payloadID = computePayloadId(parent, params) ea.payloadID = computePayloadId(parent, attrs)
// pre-process the deposits // pre-process the deposits
for i, otx := range params.Transactions { for i, otx := range attrs.Transactions {
var tx types.Transaction var tx types.Transaction
if err := tx.UnmarshalBinary(otx); err != nil { if err := tx.UnmarshalBinary(otx); err != nil {
return fmt.Errorf("transaction %d is not valid: %w", i, err) return fmt.Errorf("transaction %d is not valid: %w", i, err)
...@@ -304,7 +304,7 @@ func (ea *L2EngineAPI) NewPayloadV3(ctx context.Context, params *eth.ExecutionPa ...@@ -304,7 +304,7 @@ func (ea *L2EngineAPI) NewPayloadV3(ctx context.Context, params *eth.ExecutionPa
return ea.newPayload(ctx, params, versionedHashes, beaconRoot) return ea.newPayload(ctx, params, versionedHashes, beaconRoot)
} }
func (ea *L2EngineAPI) getPayload(ctx context.Context, payloadId eth.PayloadID) (*eth.ExecutionPayloadEnvelope, error) { func (ea *L2EngineAPI) getPayload(_ context.Context, payloadId eth.PayloadID) (*eth.ExecutionPayloadEnvelope, error) {
ea.log.Trace("L2Engine API request received", "method", "GetPayload", "id", payloadId) ea.log.Trace("L2Engine API request received", "method", "GetPayload", "id", payloadId)
if ea.payloadID != payloadId { if ea.payloadID != payloadId {
ea.log.Warn("unexpected payload ID requested for block building", "expected", ea.payloadID, "got", payloadId) ea.log.Warn("unexpected payload ID requested for block building", "expected", ea.payloadID, "got", payloadId)
...@@ -319,7 +319,7 @@ func (ea *L2EngineAPI) getPayload(ctx context.Context, payloadId eth.PayloadID) ...@@ -319,7 +319,7 @@ func (ea *L2EngineAPI) getPayload(ctx context.Context, payloadId eth.PayloadID)
return eth.BlockAsPayloadEnv(bl, ea.config().CanyonTime) return eth.BlockAsPayloadEnv(bl, ea.config().CanyonTime)
} }
func (ea *L2EngineAPI) forkchoiceUpdated(ctx context.Context, state *eth.ForkchoiceState, attr *eth.PayloadAttributes) (*eth.ForkchoiceUpdatedResult, error) { func (ea *L2EngineAPI) forkchoiceUpdated(_ context.Context, state *eth.ForkchoiceState, attr *eth.PayloadAttributes) (*eth.ForkchoiceUpdatedResult, error) {
ea.log.Trace("L2Engine API request received", "method", "ForkchoiceUpdated", "head", state.HeadBlockHash, "finalized", state.FinalizedBlockHash, "safe", state.SafeBlockHash) ea.log.Trace("L2Engine API request received", "method", "ForkchoiceUpdated", "head", state.HeadBlockHash, "finalized", state.FinalizedBlockHash, "safe", state.SafeBlockHash)
if state.HeadBlockHash == (common.Hash{}) { if state.HeadBlockHash == (common.Hash{}) {
ea.log.Warn("Forkchoice requested update to zero hash") ea.log.Warn("Forkchoice requested update to zero hash")
...@@ -438,7 +438,7 @@ func toGethWithdrawals(payload *eth.ExecutionPayload) []*types.Withdrawal { ...@@ -438,7 +438,7 @@ func toGethWithdrawals(payload *eth.ExecutionPayload) []*types.Withdrawal {
return result return result
} }
func (ea *L2EngineAPI) newPayload(ctx context.Context, payload *eth.ExecutionPayload, hashes []common.Hash, root *common.Hash) (*eth.PayloadStatusV1, error) { func (ea *L2EngineAPI) newPayload(_ context.Context, payload *eth.ExecutionPayload, hashes []common.Hash, root *common.Hash) (*eth.PayloadStatusV1, error) {
ea.log.Trace("L2Engine API request received", "method", "ExecutePayload", "number", payload.BlockNumber, "hash", payload.BlockHash) ea.log.Trace("L2Engine API request received", "method", "ExecutePayload", "number", payload.BlockNumber, "hash", payload.BlockHash)
txs := make([][]byte, len(payload.Transactions)) txs := make([][]byte, len(payload.Transactions))
for i, tx := range payload.Transactions { for i, tx := range payload.Transactions {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment