- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for UnmountDevice (0.47 sec)
-
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/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) -
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/kubelet/volumemanager/reconciler/reconciler_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K 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) -
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) -
pkg/volume/csi/csi_attacher_test.go
} // Clear out the client if specified // The lookup to generate a new client will fail if tc.unsetClient { csiAttacher.csiClient = nil } // Run err := csiAttacher.UnmountDevice(tc.deviceMountPath) // Verify if err != nil { if !tc.shouldFail { t.Errorf("test should not fail, but error occurred: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/volume/testing/testing.go
defer fv.Unlock() return nil, nil } func (fv *FakeVolume) GetDetachCallCount() int { fv.RLock() defer fv.RUnlock() return fv.DetachCallCount } func (fv *FakeVolume) UnmountDevice(globalMountPath string) error { fv.Lock() defer fv.Unlock() fv.UnmountDeviceCallCount++ if fv.UnmountDeviceHook != nil { return fv.UnmountDeviceHook(globalMountPath) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0)