OKE (CSI) Expand Volume support.

mrunalpagnis · mrunalpagnis · commit fb9348c37416 · 2022-02-28T13:55:54.000+05:30
diff --git a/pkg/csi/driver/bv_node.go b/pkg/csi/driver/bv_node.go
@@ -477,7 +477,7 @@ func (d BlockVolumeNodeDriver) NodeExpandVolume(ctx context.Context, req *csi.No
 	logger := d.logger.With("volumeId", req.VolumeId, "volumePath", req.VolumePath)
 
 	if acquired := d.volumeLocks.TryAcquire(req.VolumeId); !acquired {
-		logger.Error("Could not acquire lock for NodeUnpublishVolume.")
+		logger.Error("Could not acquire lock for NodeExpandVolume.")
 		return nil, status.Errorf(codes.Aborted, volumeOperationAlreadyExistsFmt, req.VolumeId)
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -477,7 +477,7 @@ func (d BlockVolumeNodeDriver) NodeExpandVolume(ctx context.Context, req *csi.No`
`477`	`477`	`logger := d.logger.With("volumeId", req.VolumeId, "volumePath", req.VolumePath)`
`478`	`478`
`479`	`479`	`if acquired := d.volumeLocks.TryAcquire(req.VolumeId); !acquired {`
`480`		`- logger.Error("Could not acquire lock for NodeUnpublishVolume.")`
	`480`	`+ logger.Error("Could not acquire lock for NodeExpandVolume.")`
`481`	`481`	`return nil, status.Errorf(codes.Aborted, volumeOperationAlreadyExistsFmt, req.VolumeId)`
`482`	`482`	`}`
`483`	`483`