Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 254 for unmounted (0.15 sec)

  1. pkg/volume/volume.go

    	// This function is called after SetUp()/SetUpAt().
    	GetAttributes() Attributes
    }
    
    // Unmounter interface provides methods to cleanup/unmount the volumes.
    type Unmounter interface {
    	Volume
    	// TearDown unmounts the volume from a self-determined directory and
    	// removes traces of the SetUp procedure.
    	TearDown() error
    	// TearDown unmounts the volume from the specified directory and
    	// removes traces of the SetUp procedure.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_volumes.go

    // pods for the specified volume are mounted or are uncertain.
    func (kl *Kubelet) podVolumesExist(podUID types.UID) bool {
    	if mountedVolumes :=
    		kl.volumeManager.GetPossiblyMountedVolumesForPod(
    			volumetypes.UniquePodName(podUID)); len(mountedVolumes) > 0 {
    		return true
    	}
    	// TODO: This checks pod volume paths and whether they are mounted. If checking returns error, podVolumesExist will return true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. src/syscall/syscall_plan9.go

    		w.Msg = ""
    	}
    	return
    }
    
    func Unmount(name, old string) (err error) {
    	if fixwd(name, old) {
    		defer runtime.UnlockOSThread()
    	}
    	oldp, err := BytePtrFromString(old)
    	if err != nil {
    		return err
    	}
    	oldptr := uintptr(unsafe.Pointer(oldp))
    
    	var r0 uintptr
    	var e ErrorString
    
    	// bind(2) man page: If name is zero, everything bound or mounted upon old is unbound or unmounted.
    	if name == "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 21:03:59 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. pkg/volume/fc/fc.go

    		// The volume must have been mounted in MountDevice with -o context.
    		b.mountedWithSELinuxContext = mounterArgs.SELinuxLabel != ""
    	}
    	return err
    }
    
    type fcDiskUnmounter struct {
    	*fcDisk
    	mounter    mount.Interface
    	deviceUtil util.DeviceUtil
    	exec       utilexec.Interface
    }
    
    var _ volume.Unmounter = &fcDiskUnmounter{}
    
    // Unmounts the bind mount, and detaches the disk only if the disk
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  5. pkg/volume/iscsi/iscsi.go

    	// leave the global mount still mounted, while marking the volume as unused.
    	// The volume can then be mounted on several nodes, resulting in volume
    	// corruption.
    	paths, err := ioutil.GetReliableMountRefs(mounter, mountPath)
    	if io.IsInconsistentReadError(err) {
    		klog.Errorf("Failed to read mount refs from /proc/mounts for %s: %s", mountPath, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/reconciler/reconciler.go

    			}
    
    			// Check whether volume is still mounted. Skip detach if it is still mounted unless we have
    			// decided to force detach or the node has `node.kubernetes.io/out-of-service` taint.
    			if attachedVolume.MountedByNode && !forceDetach && !hasOutOfServiceTaint {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 21:02:38 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  7. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	// between successive executions
    	ReconcilerLoopPeriod time.Duration
    
    	// ReconcilerMaxWaitForUnmountDuration is the maximum amount of time the
    	// attach detach controller will wait for a volume to be safely unmounted
    	// from its node. Once this time has expired, the controller will assume the
    	// node or kubelet are unresponsive and will detach the volume anyway.
    	ReconcilerMaxWaitForUnmountDuration time.Duration
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  8. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    		t.Fatalf("expected volume devices %s to be mounted globally", volumeName)
    	}
    }
    
    func waitForUncertainPodMount(t *testing.T, volumeName v1.UniqueVolumeName, podName types.UniquePodName, asw cache.ActualStateOfWorld) {
    	// check if volume is locally pod mounted in uncertain state
    	err := retryWithExponentialBackOff(
    		testOperationBackOffDuration,
    		func() (bool, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet.go

    	kl.statusManager.SetPodStatus(pod, apiPodStatus)
    
    	// volumes are unmounted after the pod worker reports ShouldPodRuntimeBeRemoved (which is satisfied
    	// before syncTerminatedPod is invoked)
    	if err := kl.volumeManager.WaitForUnmount(ctx, pod); err != nil {
    		return err
    	}
    	klog.V(4).InfoS("Pod termination unmounted volumes", "pod", klog.KObj(pod), "podUID", pod.UID)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  10. pkg/volume/local/local.go

    		}
    	}
    	return filtered
    }
    
    type localVolumeUnmounter struct {
    	*localVolume
    }
    
    var _ volume.Unmounter = &localVolumeUnmounter{}
    
    // TearDown unmounts the bind mount
    func (u *localVolumeUnmounter) TearDown() error {
    	return u.TearDownAt(u.GetPath())
    }
    
    // TearDownAt unmounts the bind mount
    func (u *localVolumeUnmounter) TearDownAt(dir string) error {
    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