s.makhov/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Pull requests Activity

[#668] shard/test: Disable GC where it is not needed

Browse source 
Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>
This commit is contained in:
Evgenii Stratonikov 2023-08-31 18:17:55 +03:00 committed by Evgenii Stratonikov
parent 42696016de
commit 382eb8a485
2 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
pkg/local_object_storage/shard/gc.go
View file

@ -119,6 +119,8 @@ type gcCfg struct {
expiredCollectorBatchSize int expiredCollectorBatchSize int
metrics GCMectrics metrics GCMectrics
testHookRemover func(ctx context.Context) gcRunResult
} }
func defaultGCCfg() gcCfg { func defaultGCCfg() gcCfg {
@ -209,7 +211,12 @@ func (gc *gc) tickRemover(ctx context.Context) {
case <-timer.C: case <-timer.C:
startedAt := time.Now() startedAt := time.Now()
result := gc.remover(ctx) var result gcRunResult
if gc.testHookRemover != nil {
result = gc.testHookRemover(ctx)
} else {
result = gc.remover(ctx)
}
timer.Reset(gc.removerInterval) timer.Reset(gc.removerInterval)
gc.metrics.AddRunDuration(time.Since(startedAt), result.success) gc.metrics.AddRunDuration(time.Since(startedAt), result.success)

2
pkg/local_object_storage/shard/gc_internal_test.go
View file

@ -75,7 +75,7 @@ func Test_ObjectNotFoundIfNotDeletedFromMetabase(t *testing.T) {
} }
sh = New(opts...) sh = New(opts...)
sh.gcCfg.testHookRemover = func(context.Context) gcRunResult { return gcRunResult{} }
require.NoError(t, sh.Open()) require.NoError(t, sh.Open())
require.NoError(t, sh.Init(context.Background())) require.NoError(t, sh.Init(context.Background()))