github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 05:27:21 +00:00
Code Issues Projects Releases Wiki Activity

Restore staging path creation

Browse Source 
CSI says about NodeStage (=MountDevice):
// The CO SHALL ensure [...]
// that the path is directory and that the process serving the
// request has `read` and `write` permission to that directory. The
// CO SHALL be responsible for creating the directory if it does not
// exist.
This commit is contained in:
Jan Safranek 2020-11-06 15:47:25 +01:00
parent 55ffd9d5fc
commit 9a765f8c2d
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/volume/csi/csi_attacher.go
View File

@ -276,12 +276,11 @@ func (c *csiAttacher) MountDevice(spec *volume.Spec, devicePath string, deviceMo
// Store volume metadata for UnmountDevice. Keep it around even if the // Store volume metadata for UnmountDevice. Keep it around even if the
// driver does not support NodeStage, UnmountDevice still needs it. // driver does not support NodeStage, UnmountDevice still needs it.
parentDir := filepath.Dir(deviceMountPath) if err = os.MkdirAll(deviceMountPath, 0750); err != nil {
if err = os.MkdirAll(parentDir, 0750); err != nil { return errors.New(log("attacher.MountDevice failed to create dir %#v: %v", deviceMountPath, err))
return errors.New(log("attacher.MountDevice failed to create dir %#v: %v", parentDir, err))
} }
klog.V(4).Info(log("created target path successfully [%s]", parentDir)) klog.V(4).Info(log("created target path successfully [%s]", deviceMountPath))
dataDir := parentDir dataDir := filepath.Dir(deviceMountPath)
data := map[string]string{ data := map[string]string{
volDataKey.volHandle: csiSource.VolumeHandle, volDataKey.volHandle: csiSource.VolumeHandle,
volDataKey.driverName: csiSource.Driver, volDataKey.driverName: csiSource.Driver,