Skip to content

Commit c2ea987

Browse files
committed
storagenode/mud: use meta folder for other meta files
Change-Id: I1efa736b12cc3982dd23c1ae2c84ba7dcefad122
1 parent fb3c73b commit c2ea987

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

storagenode/mud.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -348,11 +348,15 @@ func Module(ball *mud.Ball) {
348348
mud.RegisterInterfaceImplementation[piecestore.PieceBackend, *piecestore.OldPieceBackend](ball)
349349

350350
mud.Provide[*retain.BloomFilterManager](ball, func(cfg piecestore.OldConfig, rcfg retain.Config) (*retain.BloomFilterManager, error) {
351-
return retain.NewBloomFilterManager(cfg.Path, rcfg.MaxTimeSkew)
351+
hashStoreDir := filepath.Join(cfg.Path, "hashstore")
352+
metaDir := filepath.Join(hashStoreDir, "meta")
353+
return retain.NewBloomFilterManager(metaDir, rcfg.MaxTimeSkew)
352354
})
353355
mud.Implementation[[]piecestore.QueueRetain, *retain.BloomFilterManager](ball)
354356
mud.Provide[*retain.RestoreTimeManager](ball, func(cfg piecestore.OldConfig) *retain.RestoreTimeManager {
355-
return retain.NewRestoreTimeManager(cfg.Path)
357+
hashStoreDir := filepath.Join(cfg.Path, "hashstore")
358+
metaDir := filepath.Join(hashStoreDir, "meta")
359+
return retain.NewRestoreTimeManager(metaDir)
356360
})
357361

358362
mud.Provide[*piecestore.Endpoint](ball, piecestore.NewEndpoint)

0 commit comments

Comments
 (0)