From c1d8368fdcf2fb87ece72cd3e60d2981ad60f600 Mon Sep 17 00:00:00 2001 From: vyzo Date: Tue, 1 Feb 2022 21:40:09 +0200 Subject: [PATCH] share a concurrent visitor between workers in markLiveRefs --- blockstore/splitstore/splitstore_compact.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/blockstore/splitstore/splitstore_compact.go b/blockstore/splitstore/splitstore_compact.go index 109d8a246..ae123abc9 100644 --- a/blockstore/splitstore/splitstore_compact.go +++ b/blockstore/splitstore/splitstore_compact.go @@ -190,8 +190,9 @@ func (s *SplitStore) markLiveRefs(cids []cid.Cid) { startMark := time.Now() count := new(int32) + visitor := newConcurrentVisitor() walkObject := func(c cid.Cid) error { - return s.walkObjectIncomplete(c, newTmpVisitor(), + return s.walkObjectIncomplete(c, visitor, func(c cid.Cid) error { if isUnitaryObject(c) { return errStopWalk