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

overestimate markSetSize a bit

Browse Source
This commit is contained in:
vyzo 2021-03-03 09:46:12 +02:00
parent 6b680d112b
commit 11b2f41804
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
blockstore/splitstore/splitstore.go
View File

@ -518,10 +518,10 @@ func (s *SplitStore) compact(curTs *types.TipSet) {
} }
func (s *SplitStore) estimateMarkSetSize(curTs *types.TipSet) { func (s *SplitStore) estimateMarkSetSize(curTs *types.TipSet) {
s.markSetSize = 0 var count int64
err := s.chain.WalkSnapshot(context.Background(), curTs, 1, s.skipOldMsgs, s.skipMsgReceipts, err := s.chain.WalkSnapshot(context.Background(), curTs, 1, s.skipOldMsgs, s.skipMsgReceipts,
func(cid cid.Cid) error { func(cid cid.Cid) error {
s.markSetSize++ count++
return nil return nil
}) })
@ -529,6 +529,8 @@ func (s *SplitStore) estimateMarkSetSize(curTs *types.TipSet) {
// TODO do something better here // TODO do something better here
panic(err) panic(err)
} }
s.markSetSize = count + count>>2
} }
func (s *SplitStore) compactSimple(curTs *types.TipSet) { func (s *SplitStore) compactSimple(curTs *types.TipSet) {
@ -566,7 +568,7 @@ func (s *SplitStore) compactSimple(curTs *types.TipSet) {
} }
if count > s.markSetSize { if count > s.markSetSize {
s.markSetSize = count s.markSetSize = count + count>>2
} }
log.Infow("marking done", "took", time.Since(startMark)) log.Infow("marking done", "took", time.Since(startMark))
@ -790,7 +792,7 @@ func (s *SplitStore) compactFull(curTs *types.TipSet) {
} }
if count > s.markSetSize { if count > s.markSetSize {
s.markSetSize = count s.markSetSize = count + count>>2
} }
// Phase 1b: mark all reachable CIDs in the cold range // Phase 1b: mark all reachable CIDs in the cold range
@ -813,7 +815,7 @@ func (s *SplitStore) compactFull(curTs *types.TipSet) {
} }
if count > s.markSetSize { if count > s.markSetSize {
s.markSetSize = count s.markSetSize = count + count>>2
} }
log.Infow("marking done", "took", time.Since(startMark)) log.Infow("marking done", "took", time.Since(startMark))