forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-22 04:36:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

core: rename to processingTime, time.Duration

Browse source
This commit is contained in:
MariusVanDerWijden 2025-12-11 20:01:20 +01:00
parent eac2b2e5b4
commit 2cc1f5fca8
3 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
core/blockchain.go
View file

@ -1778,7 +1778,7 @@ func (bc *BlockChain) insertChain(chain types.Blocks, setHead bool, makeWitness
// Fire a single chain head event if we've progressed the chain // Fire a single chain head event if we've progressed the chain
defer func() { defer func() {
if lastCanon != nil && bc.CurrentBlock().Hash() == lastCanon.Hash() { if lastCanon != nil && bc.CurrentBlock().Hash() == lastCanon.Hash() {
bc.chainHeadFeed.Send(ChainHeadEvent{Header: lastCanon.Header(), Time: uint64(mclock.Now().Sub(stats.startTime))}) bc.chainHeadFeed.Send(ChainHeadEvent{Header: lastCanon.Header(), ProcessingTime: mclock.Now().Sub(stats.startTime)})
} }
}() }()
// Start the parallel header verifier // Start the parallel header verifier

6
core/events.go
View file

@ -17,6 +17,8 @@
package core package core
import ( import (
"time"
"github.com/ethereum/go-ethereum/core/types" "github.com/ethereum/go-ethereum/core/types"
) )
@ -33,6 +35,6 @@ type ChainEvent struct {
} }
type ChainHeadEvent struct { type ChainHeadEvent struct {
Header *types.Header Header *types.Header
Time uint64 ProcessingTime time.Duration
} }

6
ethstats/ethstats.go
View file

@ -604,7 +604,7 @@ func (s uncleStats) MarshalJSON() ([]byte, error) {
// reportBlock retrieves the current chain head and reports it to the stats server. // reportBlock retrieves the current chain head and reports it to the stats server.
func (s *Service) reportBlock(conn *connWrapper, header *core.ChainHeadEvent) error { func (s *Service) reportBlock(conn *connWrapper, header *core.ChainHeadEvent) error {
// Gather the block details from the header or block chain // Gather the block details from the header or block chain
details := s.assembleBlockStats(header.Header, header.Time) details := s.assembleBlockStats(header.Header, header.ProcessingTime)
// Short circuit if the block detail is not available. // Short circuit if the block detail is not available.
if details == nil { if details == nil {
@ -625,7 +625,7 @@ func (s *Service) reportBlock(conn *connWrapper, header *core.ChainHeadEvent) er
// assembleBlockStats retrieves any required metadata to report a single block // assembleBlockStats retrieves any required metadata to report a single block
// and assembles the block stats. If block is nil, the current head is processed. // and assembles the block stats. If block is nil, the current head is processed.
func (s *Service) assembleBlockStats(header *types.Header, time uint64) *blockStats { func (s *Service) assembleBlockStats(header *types.Header, processingTime time.Duration) *blockStats {
// Gather the block infos from the local blockchain // Gather the block infos from the local blockchain
var ( var (
txs []txStats txs []txStats
@ -672,7 +672,7 @@ func (s *Service) assembleBlockStats(header *types.Header, time uint64) *blockSt
TxHash: header.TxHash, TxHash: header.TxHash,
Root: header.Root, Root: header.Root,
Uncles: uncles, Uncles: uncles,
ProcessingTime: time, ProcessingTime: uint64(processingTime),
} }
} }