mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-25 04:33:26 +00:00
Merge pull request #110879 from ping035627/k8s-220630
Handle os.MkdirAll error
This commit is contained in:
commit
29705ce027
@ -340,7 +340,9 @@ func (cephfsVolume *cephfs) execFuseMount(mountpoint string) error {
|
|||||||
klog.V(4).Info("cephfs mount begin using fuse.")
|
klog.V(4).Info("cephfs mount begin using fuse.")
|
||||||
|
|
||||||
keyringPath := cephfsVolume.GetKeyringPath()
|
keyringPath := cephfsVolume.GetKeyringPath()
|
||||||
os.MkdirAll(keyringPath, 0750)
|
if err := os.MkdirAll(keyringPath, 0750); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
payload := make(map[string]util.FileProjection, 1)
|
payload := make(map[string]util.FileProjection, 1)
|
||||||
var fileProjection util.FileProjection
|
var fileProjection util.FileProjection
|
||||||
|
@ -247,7 +247,9 @@ func (mounter *quobyteMounter) SetUpAt(dir string, mounterArgs volume.MounterArg
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
os.MkdirAll(dir, 0750)
|
if err := os.MkdirAll(dir, 0750); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
var options []string
|
var options []string
|
||||||
options = append(options, "allow-usermapping-in-volumename")
|
options = append(options, "allow-usermapping-in-volumename")
|
||||||
if mounter.readOnly {
|
if mounter.readOnly {
|
||||||
|
Loading…
Reference in New Issue
Block a user