Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Feature/del headers #134

Merged
merged 10 commits into from
Nov 2, 2022
Merged

Feature/del headers #134

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
745b590
Delete CanonicalNumberToHash when it exceeds the maximum
lbtsm Oct 31, 2022
7053f96
50000 to 5000
lbtsm Oct 31, 2022
9a7fec3
doc
lbtsm Oct 31, 2022
a7a3767
modify header store
lbtsm Nov 1, 2022
34e83bc
modify header store
lbtsm Nov 1, 2022
4a2b5b3
log
lbtsm Nov 1, 2022
b32044f
5000 to 100000
lbtsm Nov 1, 2022
515189e
modify key name
lbtsm Nov 1, 2022
f88c9ed
modify key name
lbtsm Nov 1, 2022
770956a
modify slice length
lbtsm Nov 2, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
log
  • Loading branch information
@lbtsm
lbtsm committed Nov 1, 2022
commit 4a2b5b3432bdf62c0a3c5f14537d410485437197
13 changes: 7 additions & 6 deletions chains/ethereum/header_store.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ func (hs *HeaderStore) ResetHeaderStore(state types.StateDB, ethHeaders []byte,
CanonicalNumberToHash: make([]common.Hash, MaxHeaderLimit),
}
cntIdx := hs.CanonicalHeaderIdx(number)
log.Info("ResetHeaderStore GetCanonicalHeaderIdx", "number", number, "idx", cntIdx)
//log.Info("ResetHeaderStore GetCanonicalHeaderIdx", "number", number, "idx", cntIdx)
h.CanonicalNumberToHash[cntIdx] = hash
if err := h.Store(state); err != nil {
return err
Expand Down Expand Up @@ -195,7 +195,7 @@ func (hs *HeaderStore) Store(state types.StateDB) error {

func (hs *HeaderStore) StoreHeader(state types.StateDB, number uint64, header *LightHeader) error {
idx := hs.headerIdx(number)
log.Info("StoreHeader GetHeaderIdx", "number", number, "idx", idx)
//log.Info("StoreHeader GetHeaderIdx", "number", number, "idx", idx)
address := chains.EthereumHeaderStoreAddress
data, err := rlp.EncodeToBytes(header)
if err != nil {
Expand Down Expand Up @@ -256,7 +256,7 @@ func (hs *HeaderStore) Load(state types.StateDB) (err error) {

func (hs *HeaderStore) LoadHeader(number uint64, db types.StateDB) (lh *LightHeader, err error) {
idx := hs.headerIdx(number)
log.Info("LoadHeader GetHeaderIdx", "number", number, "idx", idx)
//log.Info("LoadHeader GetHeaderIdx", "number", number, "idx", idx)
address := chains.EthereumHeaderStoreAddress
data := db.GetPOWState(address, common.BigToHash(new(big.Int).SetUint64(idx)))
if len(data) == 0 {
Expand Down Expand Up @@ -320,20 +320,20 @@ func (hs *HeaderStore) HasHeader(hash common.Hash, number uint64, db types.State

func (hs *HeaderStore) ReadCanonicalHash(number uint64) common.Hash {
cntIdx := hs.CanonicalHeaderIdx(number)
log.Info("ReadCanonicalHash GetCanonicalHeaderIdx", "number", number, "idx", cntIdx)
//log.Info("ReadCanonicalHash GetCanonicalHeaderIdx", "number", number, "idx", cntIdx)
return hs.CanonicalNumberToHash[cntIdx]
}

func (hs *HeaderStore) WriteCanonicalHash(hash common.Hash, number uint64) {
// number -> hash mapping
cntIdx := hs.CanonicalHeaderIdx(number)
log.Info("WriteCanonicalHash GetCanonicalHeaderIdx", "number", number, "idx", cntIdx)
//log.Info("WriteCanonicalHash GetCanonicalHeaderIdx", "number", number, "idx", cntIdx)
hs.CanonicalNumberToHash[cntIdx] = hash
}

func (hs *HeaderStore) DeleteCanonicalHash(number uint64) {
cntIdx := hs.CanonicalHeaderIdx(number)
log.Info("DeleteCanonicalHash GetCanonicalHeaderIdx", "number", number, "idx", cntIdx)
//log.Info("DeleteCanonicalHash GetCanonicalHeaderIdx", "number", number, "idx", cntIdx)
hs.CanonicalNumberToHash[cntIdx] = common.Hash{}
}

Expand Down Expand Up @@ -445,6 +445,7 @@ func (hs *HeaderStore) WriteHeaders(db types.StateDB, ethHeaders []byte) (*heade
if !chainAlreadyCanon {
for i := lastNumber + 1; ; i++ {
if i <= hs.CurNumber-MaxHeaderLimit+1 {
log.Info("chainAlreadyCanon=false, obsolete block", "current", hs.CurNumber, "calNumber", i)
continue
}
hash := hs.ReadCanonicalHash(i)
Expand Down