mirrors/ceph-csi
1
0
Fork 0
mirror of https://github.com/ceph/ceph-csi.git synced 2024-11-22 22:30:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

cephfs: replace variable name for builtin cap attribute

Browse Source 
Signed-off-by: Humble Chirammal <hchiramm@redhat.com>
This commit is contained in:
Humble Chirammal 2020-10-19 13:01:11 +05:30 committed by mergify[bot]
parent 01c02b5c02
commit 5b537754a7
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/cephfs/controllerserver.go
View File

@ -373,8 +373,8 @@ func (cs *ControllerServer) ValidateVolumeCapabilities(
ctx context.Context,
req *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error) {
// Cephfs doesn't support Block volume
for _, cap := range req.VolumeCapabilities {
if cap.GetBlock() != nil {
for _, capability := range req.VolumeCapabilities {
if capability.GetBlock() != nil {
return &csi.ValidateVolumeCapabilitiesResponse{Message: ""}, nil
}
}

4
internal/cephfs/util.go
View File

@ -67,8 +67,8 @@ func (cs *ControllerServer) validateCreateVolumeRequest(req *csi.CreateVolumeReq
return status.Error(codes.InvalidArgument, "volume Capabilities cannot be empty")
}
for _, cap := range reqCaps {
if cap.GetBlock() != nil {
for _, capability := range reqCaps {
if capability.GetBlock() != nil {
return status.Error(codes.Unimplemented, "block volume not supported")
}
}

4
internal/csi-common/driver.go
View File

@ -73,8 +73,8 @@ func (d *CSIDriver) ValidateControllerServiceRequest(c csi.ControllerServiceCapa
return nil
}
for _, cap := range d.cap {
if c == cap.GetRpc().GetType() {
for _, capability := range d.cap {
if c == capability.GetRpc().GetType() {
return nil
}
}