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

share a concurrent visitor between workers in markLiveRefs

Browse Source
This commit is contained in:
vyzo 2022-02-01 21:40:09 +02:00
parent 4b4104e400
commit c1d8368fdc
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
blockstore/splitstore/splitstore_compact.go
View File

@ -190,8 +190,9 @@ func (s *SplitStore) markLiveRefs(cids []cid.Cid) {
startMark := time.Now() startMark := time.Now()
count := new(int32) count := new(int32)
visitor := newConcurrentVisitor()
walkObject := func(c cid.Cid) error { walkObject := func(c cid.Cid) error {
return s.walkObjectIncomplete(c, newTmpVisitor(), return s.walkObjectIncomplete(c, visitor,
func(c cid.Cid) error { func(c cid.Cid) error {
if isUnitaryObject(c) { if isUnitaryObject(c) {
return errStopWalk return errStopWalk