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

core/rawdb: add more debug logs

Browse source
This commit is contained in:
Gary Rong 2023-09-18 11:39:11 +08:00
parent dcdac9f549
commit 7dbec351f0
2 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
core/rawdb/freezer_resettable.go
View file

@ -22,6 +22,7 @@ import (
"sync"
"github.com/ethereum/go-ethereum/ethdb"
"github.com/ethereum/go-ethereum/log"
)
const tmpSuffix = ".tmp"
@ -224,6 +225,7 @@ func cleanup(path string) error {
}
for _, name := range names {
if name == filepath.Base(path)+tmpSuffix {
log.Info("Removed leftover directory", "name", name)
return os.RemoveAll(filepath.Join(parent, name))
}
}

12
core/rawdb/freezer_table.go
View file

@ -209,16 +209,20 @@ func (t *freezerTable) repair() error {
if _, err := t.index.Write(buffer); err != nil {
return err
}
t.logger.Info("Initialized index file")
}
// Ensure the index is a multiple of indexEntrySize bytes
if overflow := stat.Size() % indexEntrySize; overflow != 0 {
truncateFreezerFile(t.index, stat.Size()-overflow) // New file can't trigger this path
remain := stat.Size() - overflow
truncateFreezerFile(t.index, remain) // New file can't trigger this path
t.logger.Info("Truncated extra data in index", "overflow", overflow, "remain", remain)
}
// Retrieve the file sizes and prepare for truncation
if stat, err = t.index.Stat(); err != nil {
return err
}
offsetsSize := stat.Size()
log.Info("Resolved index file", "size", offsetsSize)
// Open the head file
var (
@ -246,13 +250,16 @@ func (t *freezerTable) repair() error {
return err
}
t.itemHidden.Store(meta.VirtualTail)
t.logger.Info("Resolved tails", "tailnum", t.tailId, "offset", t.itemOffset.Load(), "hidden", t.itemHidden.Load())
// Read the last index, use the default value in case the freezer is empty
if offsetsSize == indexEntrySize {
lastIndex = indexEntry{filenum: t.tailId, offset: 0}
t.logger.Info("Initialized last index", "filenum", lastIndex.filenum, "offset", lastIndex.offset)
} else {
t.index.ReadAt(buffer, offsetsSize-indexEntrySize)
lastIndex.unmarshalBinary(buffer)
t.logger.Info("Resolved last index", "filenum", lastIndex.filenum, "offset", lastIndex.offset)
}
if t.readonly {
t.head, err = t.openFile(lastIndex.filenum, openFreezerFileForReadOnly)
@ -266,6 +273,7 @@ func (t *freezerTable) repair() error {
return err
}
contentSize = stat.Size()
t.logger.Info("Resolved head data file", "size", contentSize, "filenum", lastIndex.filenum)
// Keep truncating both files until they come in sync
contentExp = int64(lastIndex.offset)
@ -768,7 +776,7 @@ func (t *freezerTable) retrieveItems(start, count, maxBytes uint64) ([]byte, []i
return fmt.Errorf("missing data file %d", fileId)
}
if _, err := dataFile.ReadAt(output[len(output)-length:], int64(start)); err != nil {
return err
return fmt.Errorf("%w fileid: %d, start: %d, length: %d", err, fileId, start, length)
}
return nil
}