Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for UnmountDevice (0.2 sec)

  1. pkg/kubelet/volumemanager/reconciler/reconciler_common.go

    				klog.V(5).InfoS(attachedVolume.GenerateMsgDetailed("Starting operationExecutor.UnmountDevice", ""))
    				err := rc.operationExecutor.UnmountDevice(
    					attachedVolume.AttachedVolume, rc.actualStateOfWorld, rc.hostutil)
    				if err != nil && !isExpectedError(err) {
    					klog.ErrorS(err, attachedVolume.GenerateErrorDetailed(fmt.Sprintf("operationExecutor.UnmountDevice failed (controllerAttachDetachEnabled %v)", rc.controllerAttachDetachEnabled), err).Error())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:23:12 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  2. pkg/volume/volume.go

    }
    
    // DeviceUnmounter can unmount a block volume from the global path.
    type DeviceUnmounter interface {
    	// UnmountDevice unmounts the global mount of the disk. This
    	// should only be called once all bind mounts have been
    	// unmounted.
    	UnmountDevice(deviceMountPath string) error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. pkg/volume/util/operationexecutor/operation_executor_test.go

    	pdName := "pd-volume"
    
    	// Act
    	for i := range attachedVolumes {
    		attachedVolumes[i] = AttachedVolume{
    			VolumeName: v1.UniqueVolumeName(pdName),
    			NodeName:   "node-name",
    		}
    		oe.UnmountDevice(attachedVolumes[i], nil /* actualStateOfWorldMounterUpdater */, nil /* mount.Interface */)
    	}
    
    	// Assert
    	if !isOperationRunSerially(ch, quit) {
    		t.Fatalf("Unmount device operations should not start concurrently")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  4. pkg/volume/util/operationexecutor/operation_executor.go

    	UnmountVolume(volumeToUnmount MountedVolume, actualStateOfWorld ActualStateOfWorldMounterUpdater, podsDir string) error
    
    	// If a volume has 'Filesystem' volumeMode, UnmountDevice unmounts the
    	// volumes global mount path from the device (for attachable volumes only,
    	// freeing it for detach. It then updates the actual state of the world to
    	// reflect that.
    	//
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  5. pkg/volume/local/local.go

    	mounter := plugin.host.GetMounter(plugin.GetPluginName())
    	return mounter.GetMountRefs(deviceMountPath)
    }
    
    var _ volume.DeviceUnmounter = &deviceMounter{}
    
    func (dm *deviceMounter) UnmountDevice(deviceMountPath string) error {
    	// If the local PV is a block device,
    	// The deviceMountPath is generated to the format like :/var/lib/kubelet/plugins/kubernetes.io/local-volume/mounts/localpv.spec.Name;
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  6. pkg/kubelet/volumemanager/cache/desired_state_of_world.go

    		// pod B with context beta_t is already scheduled on the same node,
    		// using the same volumes
    		// The volumes from Pod A must be fully unmounted (incl. UnmountDevice)
    		// and mounted with new SELinux mount options for pod B.
    		// Without SELinux, kubelet can (and often does) reuse device mounted
    		// for A.
    		return vol.effectiveSELinuxMountFileLabel == seLinuxMountContext
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 27.1K bytes
    - Viewed (0)
Back to top