From 8baaabf28ca42362c32ebc95b7c76e0465bd125b Mon Sep 17 00:00:00 2001 From: Sergey Berezansky Date: Sun, 28 Jul 2024 17:13:25 +0300 Subject: [PATCH] fix(CSI-224): purgeVolume() not scheduled if gc.isRunning() --- pkg/wekafs/gc.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/wekafs/gc.go b/pkg/wekafs/gc.go index ab95e4eb3..3bc75fe7e 100644 --- a/pkg/wekafs/gc.go +++ b/pkg/wekafs/gc.go @@ -43,13 +43,13 @@ func (gc *innerPathVolGc) triggerGcVolume(ctx context.Context, volume *Volume) { fsName := volume.FilesystemName gc.Lock() defer gc.Unlock() + go gc.purgeVolume(ctx, volume) if gc.isRunning[fsName] { gc.isDeferred[fsName] = true return } gc.isRunning[fsName] = true gc.isDeferred[fsName] = true - go gc.purgeVolume(ctx, volume) } func (gc *innerPathVolGc) purgeVolume(ctx context.Context, volume *Volume) {