fix(CSI-224): purgeVolume() not scheduled if gc.isRunning()

weka · Jul 28, 2024 · 8baaabf · 8baaabf
1 parent cf1f6f6
commit 8baaabf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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) {