aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/nodeserver.go
diff options
context:
space:
mode:
Diffstat (limited to 'pkg/driver/nodeserver.go')
-rw-r--r--pkg/driver/nodeserver.go141
1 files changed, 27 insertions, 114 deletions
diff --git a/pkg/driver/nodeserver.go b/pkg/driver/nodeserver.go
index 616c79b..c0572a8 100644
--- a/pkg/driver/nodeserver.go
+++ b/pkg/driver/nodeserver.go
@@ -26,12 +26,12 @@ type NodeServer struct {
var _ = csi.NodeServer(&NodeServer{})
-func (ns *NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error) {
+func (ns *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error) {
volumeID := req.GetVolumeId()
// mount the fs here
- stagingTargetPath := req.GetStagingTargetPath()
+ targetPath := req.GetTargetPath()
- glog.Infof("node stage volume %s to %s", volumeID, stagingTargetPath)
+ glog.Infof("node target volume %s to %s", volumeID, targetPath)
// Check arguments
if req.GetVolumeCapability() == nil {
@@ -43,7 +43,7 @@ func (ns *NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol
if volumeID == "" {
return nil, status.Error(codes.InvalidArgument, "Volume ID missing in request")
}
- if stagingTargetPath == "" {
+ if targetPath == "" {
return nil, status.Error(codes.InvalidArgument, "Target path missing in request")
}
@@ -51,10 +51,10 @@ func (ns *NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol
volumeMutex.Lock()
defer volumeMutex.Unlock()
- // The volume has been staged.
+ // The volume has been publish.
if _, ok := ns.volumes.Load(volumeID); ok {
- glog.Infof("volume %s has been already staged", volumeID)
- return &csi.NodeStageVolumeResponse{}, nil
+ glog.Infof("volume %s has been already published", volumeID)
+ return &csi.NodePublishVolumeResponse{}, nil
}
volContext := req.GetVolumeContext()
@@ -62,14 +62,14 @@ func (ns *NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol
mounter, err := newMounter(volumeID, readOnly, ns.Driver, volContext)
if err != nil {
- // node stage is unsuccessfull
+ // node publish is unsuccessfull
ns.removeVolumeMutex(volumeID)
return nil, err
}
volume := NewVolume(volumeID, mounter)
- if err := volume.Stage(stagingTargetPath); err != nil {
- // node stage is unsuccessfull
+ if err := volume.Publish(targetPath); err != nil {
+ // node publish is unsuccessfull
ns.removeVolumeMutex(volumeID)
if os.IsPermission(err) {
@@ -90,63 +90,21 @@ func (ns *NodeServer) NodeStageVolume(ctx context.Context, req *csi.NodeStageVol
}
ns.volumes.Store(volumeID, volume)
- glog.Infof("volume %s successfully staged to %s", volumeID, stagingTargetPath)
+ glog.Infof("volume %s successfully publish to %s", volumeID, targetPath)
- return &csi.NodeStageVolumeResponse{}, nil
-}
-
-func (ns *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error) {
- volumeID := req.GetVolumeId()
- targetPath := req.GetTargetPath()
- stagingTargetPath := req.GetStagingTargetPath()
-
- glog.Infof("node publish volume %s to %s", volumeID, targetPath)
-
- // Check arguments
- 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")
- }
- if targetPath == "" {
- return nil, status.Error(codes.InvalidArgument, "Target path missing in request")
- }
- if stagingTargetPath == "" {
- return nil, status.Error(codes.InvalidArgument, "Staging target path missing in request")
- }
-
- volumeMutex := ns.getVolumeMutex(volumeID)
- volumeMutex.Lock()
- defer volumeMutex.Unlock()
-
- volume, ok := ns.volumes.Load(volumeID)
- if !ok {
- return nil, status.Error(codes.FailedPrecondition, "volume hasn't been staged yet")
- }
-
- // When pod uses a volume in read-only mode, k8s will automatically
- // mount the volume as a read-only file system.
- if err := volume.(*Volume).Publish(stagingTargetPath, targetPath, req.GetReadonly()); err != nil {
- return nil, status.Error(codes.Internal, err.Error())
- }
-
- glog.Infof("volume %s successfully published to %s", volumeID, targetPath)
return &csi.NodePublishVolumeResponse{}, nil
}
func (ns *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error) {
volumeID := req.GetVolumeId()
targetPath := req.GetTargetPath()
+
glog.Infof("node unpublish volume %s from %s", volumeID, targetPath)
+ // Check arguments
if volumeID == "" {
return nil, status.Error(codes.InvalidArgument, "Volume ID missing in request")
}
-
if targetPath == "" {
return nil, status.Error(codes.InvalidArgument, "Target path missing in request")
}
@@ -161,15 +119,18 @@ func (ns *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpu
// make sure there is no any garbage
_ = mount.CleanupMountPoint(targetPath, mountutil, true)
-
- return &csi.NodeUnpublishVolumeResponse{}, nil
+ } else {
+ if err := volume.(*Volume).Unpublish(targetPath); err != nil {
+ return nil, status.Error(codes.Internal, err.Error())
+ } else {
+ ns.volumes.Delete(volumeID)
+ }
}
- if err := volume.(*Volume).Unpublish(targetPath); err != nil {
- return nil, status.Error(codes.Internal, err.Error())
- }
+ // remove mutex on successfull unpublish
+ ns.volumeMutexes.RemoveMutex(volumeID)
- glog.Infof("volume %s successfully unpublished from %s", volumeID, targetPath)
+ glog.Infof("volume %s successfully unpublish from %s", volumeID, targetPath)
return &csi.NodeUnpublishVolumeResponse{}, nil
}
@@ -184,19 +145,11 @@ func (ns *NodeServer) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoReque
func (ns *NodeServer) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error) {
glog.V(3).Infof("node get capabilities")
-
return &csi.NodeGetCapabilitiesResponse{
Capabilities: []*csi.NodeServiceCapability{
{
Type: &csi.NodeServiceCapability_Rpc{
Rpc: &csi.NodeServiceCapability_RPC{
- Type: csi.NodeServiceCapability_RPC_STAGE_UNSTAGE_VOLUME,
- },
- },
- },
- {
- Type: &csi.NodeServiceCapability_Rpc{
- Rpc: &csi.NodeServiceCapability_RPC{
Type: csi.NodeServiceCapability_RPC_EXPAND_VOLUME,
},
},
@@ -205,46 +158,6 @@ func (ns *NodeServer) NodeGetCapabilities(ctx context.Context, req *csi.NodeGetC
}, nil
}
-func (ns *NodeServer) NodeUnstageVolume(ctx context.Context, req *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error) {
- volumeID := req.GetVolumeId()
- stagingTargetPath := req.GetStagingTargetPath()
-
- glog.Infof("node unstage volume %s from %s", volumeID, stagingTargetPath)
-
- // Check arguments
- if volumeID == "" {
- return nil, status.Error(codes.InvalidArgument, "Volume ID missing in request")
- }
- if stagingTargetPath == "" {
- return nil, status.Error(codes.InvalidArgument, "Target path missing in request")
- }
-
- volumeMutex := ns.getVolumeMutex(volumeID)
- volumeMutex.Lock()
- defer volumeMutex.Unlock()
-
- volume, ok := ns.volumes.Load(volumeID)
- if !ok {
- glog.Warningf("volume %s hasn't been staged", volumeID)
-
- // make sure there is no any garbage
- _ = mount.CleanupMountPoint(stagingTargetPath, mountutil, true)
- } else {
- if err := volume.(*Volume).Unstage(stagingTargetPath); err != nil {
- return nil, status.Error(codes.Internal, err.Error())
- } else {
- ns.volumes.Delete(volumeID)
- }
- }
-
- // remove mutex on successfull unstage
- ns.volumeMutexes.RemoveMutex(volumeID)
-
- glog.Infof("volume %s successfully unstaged from %s", volumeID, stagingTargetPath)
-
- return &csi.NodeUnstageVolumeResponse{}, nil
-}
-
func (ns *NodeServer) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandVolumeRequest) (*csi.NodeExpandVolumeResponse, error) {
volumeID := req.GetVolumeId()
volumePath := req.GetVolumePath()
@@ -279,11 +192,11 @@ func (ns *NodeServer) NodeExpandVolume(ctx context.Context, req *csi.NodeExpandV
func (ns *NodeServer) NodeCleanup() {
ns.volumes.Range(func(_, vol any) bool {
v := vol.(*Volume)
- if len(v.StagedPath) > 0 {
- glog.Infof("cleaning up volume %s at %s", v.VolumeId, v.StagedPath)
- err := v.Unstage(v.StagedPath)
+ if len(v.TargetPath) > 0 {
+ glog.Infof("cleaning up volume %s at %s", v.VolumeId, v.TargetPath)
+ err := v.Unpublish(v.TargetPath)
if err != nil {
- glog.Warningf("error cleaning up volume %s at %s, err: %v", v.VolumeId, v.StagedPath, err)
+ glog.Warningf("error cleaning up volume %s at %s, err: %v", v.VolumeId, v.TargetPath, err)
}
}
return true
@@ -298,7 +211,7 @@ func (ns *NodeServer) removeVolumeMutex(volumeID string) {
ns.volumeMutexes.RemoveMutex(volumeID)
}
-func isVolumeReadOnly(req *csi.NodeStageVolumeRequest) bool {
+func isVolumeReadOnly(req *csi.NodePublishVolumeRequest) bool {
mode := req.GetVolumeCapability().GetAccessMode().Mode
readOnlyModes := []csi.VolumeCapability_AccessMode_Mode{
generated by cgit v1.2.3 (git 2.25.1) at 2025-12-20 20:06:22 +0000