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

Lint

Browse Source
This commit is contained in:
zenground0 2023-03-08 18:20:27 -07:00
parent efbb63582e
commit 7931414735
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
blockstore/splitstore/splitstore_compact.go
View File

@ -236,7 +236,7 @@ func (s *SplitStore) markLiveRefs(cids []cid.Cid) {
log.Errorf("error marking tipset refs: %s", err) log.Errorf("error marking tipset refs: %s", err)
} }
log.Debugw("marking live refs done", "took", time.Since(startMark), "marked", *count) log.Debugw("marking live refs done", "took", time.Since(startMark), "marked", *count)
atomic.AddInt64(szMarked, int64(sz)) atomic.AddInt64(szMarked, sz)
return return
} }
@ -252,7 +252,7 @@ func (s *SplitStore) markLiveRefs(cids []cid.Cid) {
if err != nil { if err != nil {
return err return err
} }
atomic.AddInt64(szMarked, int64(sz)) atomic.AddInt64(szMarked, sz)
} }
return nil return nil
@ -969,7 +969,7 @@ func (s *SplitStore) walkChain(ts *types.TipSet, inclState, inclMsgs abi.ChainEp
if err != nil { if err != nil {
return xerrors.Errorf("error walking messages (cid: %s): %w", hdr.Messages, err) return xerrors.Errorf("error walking messages (cid: %s): %w", hdr.Messages, err)
} }
atomic.AddInt64(szWalk, int64(sz)) atomic.AddInt64(szWalk, sz)
sz, err = s.walkObjectIncomplete(hdr.ParentMessageReceipts, visitor, fHot, stopWalk) sz, err = s.walkObjectIncomplete(hdr.ParentMessageReceipts, visitor, fHot, stopWalk)
if err != nil { if err != nil {

5
blockstore/splitstore/splitstore_gc.go
View File

@ -37,10 +37,9 @@ func (s *SplitStore) gcHotAfterCompaction() {
return 0 return 0
} }
return size return size
} else {
log.Errorf("Could not measure hotstore size, assuming it is 0 bytes, which it is not")
return 0
} }
log.Errorf("Could not measure hotstore size, assuming it is 0 bytes, which it is not")
return 0
} }
hotSize := getSize() hotSize := getSize()