diff --git a/internal/cephfs/fsjournal.go b/internal/cephfs/fsjournal.go index ee1cc8691..4fd948e6d 100644 --- a/internal/cephfs/fsjournal.go +++ b/internal/cephfs/fsjournal.go @@ -132,7 +132,7 @@ func checkVolExists(ctx context.Context, return nil, fmt.Errorf("clone is not in complete state for %s", vid.FsSubvolName) } } else { - _, err = getVolumeRootPathCeph(ctx, volOptions, cr, volumeID(vid.FsSubvolName)) + _, err = getVolumeRootPathCeph(ctx, volOptions, volumeID(vid.FsSubvolName)) if err != nil { if errors.Is(err, ErrVolumeNotFound) { err = j.UndoReservation(ctx, volOptions.MetadataPool, diff --git a/internal/cephfs/volume.go b/internal/cephfs/volume.go index 4f3ebe468..d6f7baca3 100644 --- a/internal/cephfs/volume.go +++ b/internal/cephfs/volume.go @@ -56,7 +56,7 @@ func getVolumeRootPathCephDeprecated(volID volumeID) string { return path.Join("/", "csi-volumes", string(volID)) } -func getVolumeRootPathCeph(ctx context.Context, volOptions *volumeOptions, cr *util.Credentials, volID volumeID) (string, error) { +func getVolumeRootPathCeph(ctx context.Context, volOptions *volumeOptions, volID volumeID) (string, error) { fsa, err := volOptions.conn.GetFSAdmin() if err != nil { util.ErrorLog(ctx, "could not get FSAdmin err %s", err) diff --git a/internal/cephfs/volumeoptions.go b/internal/cephfs/volumeoptions.go index 345d80be8..4eb081dca 100644 --- a/internal/cephfs/volumeoptions.go +++ b/internal/cephfs/volumeoptions.go @@ -347,7 +347,7 @@ func newVolumeOptionsFromVolID(ctx context.Context, volID string, volOpt, secret } if errors.Is(err, ErrInvalidCommand) { - volOptions.RootPath, err = getVolumeRootPathCeph(ctx, &volOptions, cr, volumeID(vid.FsSubvolName)) + volOptions.RootPath, err = getVolumeRootPathCeph(ctx, &volOptions, volumeID(vid.FsSubvolName)) } return &volOptions, &vid, err