- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for unmountdevice (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
} return "", nil } func (attacher *testPluginAttacher) MountDevice(spec *volume.Spec, devicePath string, deviceMountPath string, _ volume.DeviceMounterArgs) error { attacher.pluginLock.Lock() defer attacher.pluginLock.Unlock() if spec == nil { *attacher.ErrorEncountered = true return fmt.Errorf("MountDevice called with nil volume spec") } return nil } // Detacher
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/volume/local/local_test.go
err = dm.MountDevice(pvSpec, tmpBlockDir, expectedGlobalPath, volume.DeviceMounterArgs{}) if err != nil { t.Fatal(err) } if _, err := os.Stat(actualPath); err != nil { if os.IsNotExist(err) { t.Errorf("DeviceMounter.MountDevice() failed, device mount path not created: %s", actualPath) } else { t.Errorf("DeviceMounter.MountDevice() failed: %v", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 10:53:39 UTC 2023 - 22.5K bytes - Viewed (0) -
pkg/volume/csi/csi_block.go
- operation_executor.UnmountVolume - csi.GetPodDeviceMapPath - util.UnmapBlockVolume - csi.UnmapPodDevice - NodeUnpublishVolume - ASW.MarkVolumeAsUnmounted - operation_executor.UnmountDevice - csi.TearDownDevice - NodeUnstageVolume - ASW.MarkDeviceAsUnmounted After successful MountVolume for block volume, directory structure will be like below:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 20.1K bytes - Viewed (0) -
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)