- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for IsLikelyNotMountPoint (0.45 sec)
-
pkg/volume/csi/csi_mounter.go
} return false } // isDirMounted returns the !notMounted result from IsLikelyNotMountPoint check func isDirMounted(plug *csiPlugin, dir string) (bool, error) { mounter := plug.host.GetMounter(plug.GetPluginName()) notMnt, err := mounter.IsLikelyNotMountPoint(dir) if err != nil && !os.IsNotExist(err) { klog.Error(log("isDirMounted IsLikelyNotMountPoint test failed for dir [%v]", dir)) return false, err } return !notMnt, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 10:47:59 UTC 2024 - 21K bytes - Viewed (1) -
pkg/kubelet/kubelet_getters.go
mountedVolumes := []string{} volumePaths, err := kl.getPodVolumePathListFromDisk(podUID) if err != nil { return mountedVolumes, err } // Only use IsLikelyNotMountPoint to check might not cover all cases. For CSI volumes that // either: 1) don't mount or 2) bind mount in the rootfs, the mount check will not work as expected.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/volume/portworx/portworx.go
} // SetUpAt attaches the disk and bind mounts to the volume path. func (b *portworxVolumeMounter) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { notMnt, err := b.mounter.IsLikelyNotMountPoint(dir) klog.Infof("Portworx Volume set up. Dir: %s %v %v", dir, !notMnt, err) if err != nil && !os.IsNotExist(err) { klog.Errorf("Cannot validate mountpoint: %s", dir) return err } if !notMnt {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota_linux.go
// activity takes place, it is not able to get a consistent // view of /proc/self/mounts, causing it to time out and // report incorrectly. isNotMount, err := m.IsLikelyNotMountPoint(path) if err != nil { return "/", err } if !isNotMount { return path, nil } path = filepath.Dir(path) } return "/", nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 07 08:07:51 UTC 2023 - 14.1K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi_util.go
klog.Errorf("iscsi: failed to mkdir %s, error", globalPDPath) return err } if b.volumeMode == v1.PersistentVolumeFilesystem { notMnt, err := b.mounter.IsLikelyNotMountPoint(globalPDPath) if err != nil { return err } if !notMnt { // The volume is already mounted, therefore the previous WaitForAttach must have
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 22 12:53:01 UTC 2022 - 34.1K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
return ed.SetUpAt(ed.GetPath(), mounterArgs) } // SetUpAt creates new directory. func (ed *emptyDir) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { notMnt, err := ed.mounter.IsLikelyNotMountPoint(dir) // Getting an os.IsNotExist err from is a contingency; the directory // may not exist yet, in which case, setup should run. if err != nil && !os.IsNotExist(err) { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
pkg/volume/local/local.go
func (dm *deviceMounter) mountLocalBlockDevice(spec *volume.Spec, devicePath string, deviceMountPath string) error { klog.V(4).Infof("local: mounting device %s to %s", devicePath, deviceMountPath) notMnt, err := dm.mounter.IsLikelyNotMountPoint(deviceMountPath) if err != nil { if os.IsNotExist(err) { if err := os.MkdirAll(deviceMountPath, 0750); err != nil { return err } notMnt = true } else { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0)