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

add logs

Browse source
This commit is contained in:
weiihann 2026-01-30 14:14:04 +08:00
parent a471810a70
commit 866713b600
1 changed files with 33 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
core/rawdb/database.go
View file

@ -988,11 +988,35 @@ func InspectContract(db ethdb.Database, address common.Address) error {
accountData := ReadAccountSnapshot(db, accountHash)
accountSnapshotSize := len(accountSnapshotKey(accountHash)) + len(accountData)
if len(accountData) == 0 {
return fmt.Errorf("account snapshot not found for address %s", address)
}
var (
storageStat stat
trieTracker = newDepthTracker()
storageKeys atomic.Uint64
trieKeys atomic.Uint64
)
// Progress reporter
done := make(chan struct{})
go func() {
ticker := time.NewTicker(8 * time.Second)
defer ticker.Stop()
for {
select {
case <-ticker.C:
log.Info("Inspecting contract",
"storageSlots", storageKeys.Load(),
"trieNodes", trieKeys.Load(),
"elapsed", common.PrettyDuration(time.Since(start)))
case <-done:
return
}
}
}()
eg, ctx := errgroup.WithContext(context.Background())
// 2. Storage snapshot: iterate all storage slots for this account
@ -1002,6 +1026,7 @@ func InspectContract(db ethdb.Database, address common.Address) error {
for it.Next() {
storageStat.add(common.StorageSize(len(it.Key()) + len(it.Value())))
storageKeys.Add(1)
select {
case <-ctx.Done():
@ -1024,6 +1049,7 @@ func InspectContract(db ethdb.Database, address common.Address) error {
}
trieTracker.add(string(path),
common.StorageSize(len(it.Key())+len(it.Value())))
trieKeys.Add(1)
select {
case <-ctx.Done():
@ -1035,22 +1061,22 @@ func InspectContract(db ethdb.Database, address common.Address) error {
})
if err := eg.Wait(); err != nil {
close(done)
return err
}
close(done)
trieCount, trieSize := trieTracker.total()
log.Info("Inspection complete", "elapsed", common.PrettyDuration(time.Since(start)))
log.Info("Inspection complete",
"storageSlots", storageKeys.Load(),
"trieNodes", trieCount,
"elapsed", common.PrettyDuration(time.Since(start)))
// Print results
fmt.Printf("\n=== Contract Inspection: %s ===\n", address)
fmt.Printf("Account hash: %s\n\n", accountHash)
if len(accountData) == 0 {
fmt.Println("Account snapshot: not found")
} else {
fmt.Printf("Account snapshot: %s\n", common.StorageSize(accountSnapshotSize))
}
fmt.Printf("Account snapshot: %s\n", common.StorageSize(accountSnapshotSize))
fmt.Printf("Snapshot storage: %s slots (%s)\n", storageStat.countString(), storageStat.sizeString())
fmt.Printf("Storage trie: %d nodes (%s)\n", trieCount, common.StorageSize(trieSize))