diff --git a/internal/rbd/rbd_attach.go b/internal/rbd/rbd_attach.go index 943cb14f2da2..442778f0f1d9 100644 --- a/internal/rbd/rbd_attach.go +++ b/internal/rbd/rbd_attach.go @@ -283,17 +283,17 @@ func createPath(ctx context.Context, volOpt *rbdVolume, cr *util.Credentials) (s } func waitForrbdImage(ctx context.Context, backoff wait.Backoff, volOptions *rbdVolume) error { - imagePath := volOptions.String() + if volOptions.DisableInUseChecks { + util.UsefulLog(ctx, "valid multi-node attach requested, ignoring watcher in-use result") + return nil + } + imagePath := volOptions.String() err := wait.ExponentialBackoff(backoff, func() (bool, error) { used, err := volOptions.isInUse() if err != nil { return false, fmt.Errorf("fail to check rbd image status: (%w)", err) } - if (volOptions.DisableInUseChecks) && (used) { - util.UsefulLog(ctx, "valid multi-node attach requested, ignoring watcher in-use result") - return used, nil - } return !used, nil }) // return error if rbd image has not become available for the specified timeout diff --git a/internal/util/validate.go b/internal/util/validate.go index e45116aca557..98101a00d38a 100644 --- a/internal/util/validate.go +++ b/internal/util/validate.go @@ -90,7 +90,7 @@ func CheckReadOnlyManyIsSupported(req *csi.CreateVolumeRequest) error { writable = true } } - if ! writable && req.GetVolumeContentSource() == nil { + if !writable && req.GetVolumeContentSource() == nil { return status.Error(codes.InvalidArgument, "readOnly accessMode is supported only with content source") } return nil