diff options
| author | washcycle <litho23@gmail.com> | 2023-04-22 15:56:02 -0500 |
|---|---|---|
| committer | washcycle <litho23@gmail.com> | 2023-04-22 15:56:02 -0500 |
| commit | 8208f32f3f7047ed5f315523dcf89ba86329d0ee (patch) | |
| tree | ebfa63bf893086ce2f3571983fde68fc4432e7f2 /pkg/driver/nodeserver.go | |
| parent | 3b656266b0da5457668b002ae6146b5d0976e781 (diff) | |
| download | seaweedfs-csi-driver-8208f32f3f7047ed5f315523dcf89ba86329d0ee.tar.xz seaweedfs-csi-driver-8208f32f3f7047ed5f315523dcf89ba86329d0ee.zip | |
-fixed several csi sanity tests
-removed deprecated/unneeded passthrough import
-added test.sh (needs work)
Diffstat (limited to 'pkg/driver/nodeserver.go')
| -rw-r--r-- | pkg/driver/nodeserver.go | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/pkg/driver/nodeserver.go b/pkg/driver/nodeserver.go index 3f18202..87fe6c5 100644 --- a/pkg/driver/nodeserver.go +++ b/pkg/driver/nodeserver.go @@ -9,7 +9,6 @@ import ( "github.com/container-storage-interface/spec/lib/go/csi" "github.com/seaweedfs/seaweedfs/weed/glog" "google.golang.org/grpc/codes" - _ "google.golang.org/grpc/resolver/passthrough" "google.golang.org/grpc/status" "k8s.io/utils/mount" ) @@ -238,7 +237,20 @@ func (ns *NodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstag } func (ns *NodeServer) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error) { + volumeID := req.GetVolumeId() + if len(volumeID) == 0 { + return nil, status.Error(codes.InvalidArgument, "Volume ID missing in request") + } + + volumePath := req.GetVolumePath() + if len(volumePath) == 0 { + return nil, status.Error(codes.InvalidArgument, "Volume path missing in request") + } + + // TODO Check if volume exists + // TODO Check if node exists + requiredBytes := req.GetCapacityRange().GetRequiredBytes() glog.V(0).Infof("Node expand volume %s to %d bytes", volumeID, requiredBytes) |