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

compact hotstore if it provides the method

Browse Source
This commit is contained in:
vyzo 2021-03-11 11:45:19 +02:00
parent 01ce9b5c44
commit 353bb1881f
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
blockstore/splitstore/splitstore.go
View File

@ -798,6 +798,18 @@ func (s *SplitStore) purgeTracking(cids []cid.Cid) error {
} }
func (s *SplitStore) gcHotstore() { func (s *SplitStore) gcHotstore() {
if compact, ok := s.hot.(interface{ Compact() error }); ok {
log.Infof("compacting hotstore")
startCompact := time.Now()
err := compact.Compact()
if err != nil {
log.Warnf("error compacting hotstore: %s", err)
return
} else {
log.Infow("hotstore compaction done", "took", time.Since(startCompact))
}
}
if gc, ok := s.hot.(interface{ CollectGarbage() error }); ok { if gc, ok := s.hot.(interface{ CollectGarbage() error }); ok {
log.Infof("garbage collecting hotstore") log.Infof("garbage collecting hotstore")
startGC := time.Now() startGC := time.Now()