mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-09-15 06:01:50 +00:00
Handle os.MkdirAll error
Signed-off-by: PingWang <wang.ping5@zte.com.cn>
This commit is contained in:
@@ -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 {
|
||||||
|
Reference in New Issue
Block a user