diff --git a/internal/cephfs/controllerserver.go b/internal/cephfs/controllerserver.go index f0061bd5f..4a1ecd773 100644 --- a/internal/cephfs/controllerserver.go +++ b/internal/cephfs/controllerserver.go @@ -331,7 +331,7 @@ func (cs *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVol if acquired := cs.VolumeLocks.TryAcquire(volOptions.RequestName); !acquired { return nil, status.Errorf(codes.Aborted, util.VolumeOperationAlreadyExistsFmt, volOptions.RequestName) } - defer cs.VolumeLocks.Release(string(volID)) + defer cs.VolumeLocks.Release(volOptions.RequestName) // Deleting a volume requires admin credentials cr, err := util.NewAdminCredentials(secrets)