Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for UnmountDevice (0.28 sec)

  1. pkg/volume/csi/csi_attacher.go

    	stageUnstageSet, err := csi.NodeSupportsStageUnstage(ctx)
    	if err != nil {
    		return errors.New(log("attacher.UnmountDevice failed to check whether STAGE_UNSTAGE_VOLUME set: %v", err))
    	}
    	if !stageUnstageSet {
    		klog.Infof(log("attacher.UnmountDevice STAGE_UNSTAGE_VOLUME capability not set. Skipping UnmountDevice..."))
    		// Just	delete the global directory + json file
    		if err := removeMountDir(c.plugin, deviceMountPath); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 03 07:38:14 UTC 2023
    - 25.9K bytes
    - Viewed (0)
  2. 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)
  3. pkg/volume/fc/attacher.go

    	return plugin.NewDetacher()
    }
    
    func (detacher *fcDetacher) Detach(volumeName string, nodeName types.NodeName) error {
    	return nil
    }
    
    func (detacher *fcDetacher) UnmountDevice(deviceMountPath string) error {
    	// Specify device name for DetachDisk later
    	devName, _, err := mount.GetDeviceNameFromMount(detacher.mounter, deviceMountPath)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 31 12:02:51 UTC 2022
    - 7.5K bytes
    - Viewed (0)
  4. pkg/volume/util/operationexecutor/operation_generator.go

    				// There is nothing else we can do. Hope that UnmountDevice will be re-tried shortly.
    				klog.Errorf(deviceToDetach.GenerateErrorDetailed("UnmountDevice.MarkDeviceAsUncertain failed", markDeviceUncertainErr).Error())
    			}
    
    			// On failure, return error. Caller will log and retry.
    			eventErr, detailedErr := deviceToDetach.GenerateError("UnmountDevice failed", unmountDeviceErr)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  5. pkg/volume/csi/csi_test.go

    						t.Fatalf("csiTest.VolumeAll deviceMounter.GetdeviceMountPath failed %s", err)
    					}
    					if err := csiDevUnmounter.UnmountDevice(devMountPath); err != nil {
    						t.Fatalf("csiTest.VolumeAll deviceMounter.UnmountDevice failed: %s", err)
    					}
    					t.Log("csiTest.VolumeAll deviceUnmounter.UnmountDevice done OK for path", devMountPath)
    				}
    			} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 15:55:13 UTC 2022
    - 21.1K bytes
    - Viewed (0)
  6. pkg/volume/iscsi/attacher.go

    	return plugin.NewDetacher()
    }
    
    func (detacher *iscsiDetacher) Detach(volumeName string, nodeName types.NodeName) error {
    	return nil
    }
    
    func (detacher *iscsiDetacher) UnmountDevice(deviceMountPath string) error {
    	unMounter := volumeSpecToUnmounter(detacher.mounter, detacher.host, detacher.plugin)
    	err := detacher.manager.DetachDisk(*unMounter, deviceMountPath)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 04 08:51:31 UTC 2022
    - 6.8K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    			deviceToDetach := operationexecutor.AttachedVolume{VolumeSpec: tmpSpec, PluginName: "fake-file-plugin"}
    			err := oex.UnmountDevice(deviceToDetach, asw, hostutil)
    			// Assert
    			if assert.Error(t, err) {
    				assert.Contains(t, err.Error(), tc.expectedErrMsg)
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
Back to top