- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 295 for unmounted (0.2 sec)
-
pkg/kubelet/volumemanager/volume_manager.go
// pod and blocks until they are all attached and mounted (reflected in // actual state of the world). // An error is returned if all volumes are not attached and mounted within // the duration defined in podAttachAndMountTimeout. WaitForAttachAndMount(ctx context.Context, pod *v1.Pod) error // WaitForUnmount processes the volumes referenced in the specified // pod and blocks until they are all unmounted (reflected in the actual
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
} func (rc *reconciler) unmountVolumes() { // Ensure volumes that should be unmounted are unmounted. for _, mountedVolume := range rc.actualStateOfWorld.GetAllMountedVolumes() { if !rc.desiredStateOfWorld.PodExistsInVolume(mountedVolume.PodName, mountedVolume.VolumeName, mountedVolume.SELinuxMountContext) { // Volume is mounted, unmount it
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/kubelet/kubelet_volumes_test.go
t.Fatalf("expected volume unmount to wait for no volumes: %v", actual) } // Verify volumes unmounted podVolumes = kubelet.volumeManager.GetMountedVolumesForPod( util.GetUniquePodName(pod)) assert.Len(t, podVolumes, 0, "Expected volumes to be unmounted and detached. But some volumes are still mounted: %#v", podVolumes) assert.NoError(t, volumetest.VerifyTearDownCallCount(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 20.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
// - VolumeMountUncertain: means volume for pod may not be mounted, but it must be unmounted volumeMountStateForPod operationexecutor.VolumeMountState // seLinuxMountContext is the context with that the volume is mounted to Pod directory // (via -o context=XYZ mount option). If nil, the volume is not mounted. If "", the volume is // mounted without "-o context=".
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter.go
// so we still need to remove the target_path here if it's unmounted and // empty. if err := removeMountDir(c.plugin, dir); err != nil { return errors.New(log("Unmounter.TearDownAt failed to clean mount dir [%s]: %v", dir, err)) } klog.V(4).Infof(log("Unmounter.TearDownAt successfully unmounted dir [%s]", dir)) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 10:47:59 UTC 2024 - 21K bytes - Viewed (1) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
t.Errorf("Error waiting for volumes to get unmounted: %s: %s", err, lastErr) } }) } } func verifyTearDownCalls(plugin *volumetesting.FakeVolumePlugin, expected int) error { unmounters := plugin.GetUnmounters() if len(unmounters) == 0 && (expected == 0) { return nil } actualCallCount := 0 for _, unmounter := range unmounters { actualCallCount = unmounter.GetTearDownCallCount()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/desired_state_of_world.go
// Handling two volumes with the same name and different SELinux context // as two *different* volumes here. Because if a volume is mounted with // an old SELinux context, it must be unmounted first and then mounted again // with the new context. // // This will happen when a pod A with context alpha_t runs and is being // terminated by kubelet and its volumes are being torn down, while a
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/util/operationexecutor/operation_executor.go
// state of the world cache after successful mount/unmount. type ActualStateOfWorldMounterUpdater interface { // Marks the specified volume as mounted to the specified pod MarkVolumeAsMounted(markVolumeOpts MarkVolumeOpts) error // Marks the specified volume as unmounted from the specified pod MarkVolumeAsUnmounted(podName volumetypes.UniquePodName, volumeName v1.UniqueVolumeName) error
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/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) -
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)