diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-06-02 23:09:33 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-06-02 23:09:33 -0700 |
| commit | 1155c60704504e05e58143dd1a39a9eb330f2534 (patch) | |
| tree | 079b72c33d0a759b4d36e2026897347245c26254 /pkg/driver/nodeserver.go | |
| parent | 77697d343356a59b649ffbcf42e927439033a413 (diff) | |
| download | seaweedfs-csi-driver-1155c60704504e05e58143dd1a39a9eb330f2534.tar.xz seaweedfs-csi-driver-1155c60704504e05e58143dd1a39a9eb330f2534.zip | |
compile
Diffstat (limited to 'pkg/driver/nodeserver.go')
| -rw-r--r-- | pkg/driver/nodeserver.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/pkg/driver/nodeserver.go b/pkg/driver/nodeserver.go index b58b23b..2a48c71 100644 --- a/pkg/driver/nodeserver.go +++ b/pkg/driver/nodeserver.go @@ -5,7 +5,7 @@ import ( "os" "strings" - "github.com/golang/glog" + "github.com/chrislusf/seaweedfs/weed/glog" "github.com/container-storage-interface/spec/lib/go/csi" "google.golang.org/grpc/codes" @@ -29,6 +29,9 @@ func (ns *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublis if req.GetVolumeCapability() == nil { return nil, status.Error(codes.InvalidArgument, "Volume capability missing in request") } + if !isValidVolumeCapabilities(ns.Driver.vcap, []*csi.VolumeCapability{req.GetVolumeCapability()}) { + return nil, status.Error(codes.InvalidArgument, "Volume capability not supported") + } if volumeID == "" { return nil, status.Error(codes.InvalidArgument, "Volume ID missing in request") } |