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 1

core/rawdb: fix tests

Browse source
This commit is contained in:
Gary Rong 2024-02-01 19:46:21 +08:00
parent 726dd7d064
commit 972b86780b
1 changed files with 10 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
core/rawdb/chain_freezer.go
View file

@ -19,13 +19,13 @@ package rawdb
import ( import (
"errors" "errors"
"fmt" "fmt"
"github.com/ethereum/go-ethereum/params"
"sync" "sync"
"time" "time"
"github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/ethdb" "github.com/ethereum/go-ethereum/ethdb"
"github.com/ethereum/go-ethereum/log" "github.com/ethereum/go-ethereum/log"
"github.com/ethereum/go-ethereum/params"
) )
const ( const (
@ -104,17 +104,21 @@ func (f *chainFreezer) readBlock(db ethdb.KeyValueReader, tag string) uint64 {
// freezeThreshold returns the threshold for chain freezing. It's determined // freezeThreshold returns the threshold for chain freezing. It's determined
// by formula: max(finality, HEAD-params.FullImmutabilityThreshold). // by formula: max(finality, HEAD-params.FullImmutabilityThreshold).
func (f *chainFreezer) freezeThreshold(db ethdb.KeyValueReader) (uint64, error) { func (f *chainFreezer) freezeThreshold(db ethdb.KeyValueReader) (uint64, error) {
final, head := f.readBlock(db, finalizedBlock), f.readBlock(db, headBlock) var (
head = f.readBlock(db, headBlock)
final = f.readBlock(db, finalizedBlock)
headLimit uint64
)
if head > params.FullImmutabilityThreshold { if head > params.FullImmutabilityThreshold {
head -= params.FullImmutabilityThreshold headLimit = head - params.FullImmutabilityThreshold
} }
if final == 0 && head == 0 { if final == 0 && headLimit == 0 {
return 0, errors.New("freezing threshold is not available") return 0, errors.New("freezing threshold is not available")
} }
if final > head { if final > headLimit {
return final, nil return final, nil
} }
return head, nil return headLimit, nil
} }
// freeze is a background thread that periodically checks the blockchain for any // freeze is a background thread that periodically checks the blockchain for any