Skip to content

Commit df85475

Browse files
committed
fix: set correct account prefix for NFS protocol
1 parent 36f0562 commit df85475

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

pkg/blob/controllerserver.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -33,9 +33,7 @@ import (
3333
"k8s.io/legacy-cloud-providers/azure"
3434
)
3535

36-
const blobfuseAccountNamePrefix = "fuse"
37-
38-
// CreateVolume provisions an blobfuse
36+
// CreateVolume provisions a volume
3937
func (d *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error) {
4038
if err := d.ValidateControllerServiceRequest(csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME); err != nil {
4139
klog.Errorf("invalid create volume req: %v", req)
@@ -122,7 +120,7 @@ func (d *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest)
122120
var accountName, accountKey string
123121
err = wait.ExponentialBackoff(d.cloud.RequestBackoff(), func() (bool, error) {
124122
var retErr error
125-
accountName, accountKey, retErr = d.cloud.EnsureStorageAccount(accountOptions, blobfuseAccountNamePrefix)
123+
accountName, accountKey, retErr = d.cloud.EnsureStorageAccount(accountOptions, protocol)
126124
if isRetriableError(retErr) {
127125
klog.Warningf("EnsureStorageAccount(%s) failed with error(%v), waiting for retrying", account, retErr)
128126
return false, nil

0 commit comments

Comments
 (0)