cerc-io/lotus
15
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

adjust walk boundaries for marking

Browse Source
This commit is contained in:
vyzo 2020-12-01 21:48:08 +02:00
parent 76d6edbb52
commit 8b0087524f
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
chain/store/splitstore/splitstore.go
View File

@ -339,7 +339,7 @@ func (s *SplitStore) compact() {
epoch := curTs.Height() epoch := curTs.Height()
coldEpoch := s.baseEpoch + build.Finality coldEpoch := s.baseEpoch + build.Finality
err = s.cs.WalkSnapshot(context.Background(), curTs, epoch-coldEpoch+1, false, false, err = s.cs.WalkSnapshot(context.Background(), curTs, epoch-coldEpoch, false, false,
func(cid cid.Cid) error { func(cid cid.Cid) error {
return hotSet.Mark(cid) return hotSet.Mark(cid)
}) })
@ -350,7 +350,7 @@ func (s *SplitStore) compact() {
} }
// Phase 1b: mark all reachable CIDs in the cold range // Phase 1b: mark all reachable CIDs in the cold range
coldTs, err := s.cs.GetTipsetByHeight(context.Background(), coldEpoch-1, curTs, true) coldTs, err := s.cs.GetTipsetByHeight(context.Background(), coldEpoch, curTs, true)
if err != nil { if err != nil {
// TODO do something better here // TODO do something better here
panic(err) panic(err)
@ -392,7 +392,7 @@ func (s *SplitStore) compact() {
} }
// is the object stil hot? // is the object stil hot?
if wrEpoch >= coldEpoch { if wrEpoch > coldEpoch {
// yes, stay in the hotstore // yes, stay in the hotstore
stHot++ stHot++
continue continue