Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for IsLikelyNotMountPoint (0.22 sec)

  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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top