- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for WaitForUnmount (0.27 sec)
-
pkg/kubelet/volumemanager/volume_manager_fake.go
} // WaitForAttachAndMount is not implemented func (f *FakeVolumeManager) WaitForAttachAndMount(ctx context.Context, pod *v1.Pod) error { return nil } // WaitForUnmount is not implemented func (f *FakeVolumeManager) WaitForUnmount(ctx context.Context, pod *v1.Pod) error { return nil } // GetMountedVolumesForPod is not implemented
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes_test.go
ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(2*time.Second)) err := kubelet.volumeManager.WaitForUnmount(ctx, pod) delta := time.Since(start) // the standard timeout is 2 minutes, so if it's just a few seconds we know that the context timeout was the cause assert.Lessf(t, delta, 10*time.Second, "WaitForUnmount should timeout when the context is cancelled") assert.ErrorIs(t, err, context.DeadlineExceeded) cancel() }
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/volume_manager.go
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 // state of the world). // An error is returned if all volumes are not unmounted within // the duration defined in podAttachAndMountTimeout. WaitForUnmount(ctx context.Context, pod *v1.Pod) error
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/populator/desired_state_of_world_populator_test.go
dswp.findAndRemoveDeletedPods() if dswp.pods.processedPods[podName] { t.Fatalf("Failed to remove pods from desired state of world since they no longer exist") } // podWorker may call volume_manager WaitForUnmount() after we processed the pod in findAndRemoveDeletedPods() dswp.ReprocessPod(podName) dswp.findAndRemoveDeletedPods() // findAndRemoveDeletedPods() above must detect orphaned pod and delete it from the map
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// volumes are unmounted after the pod worker reports ShouldPodRuntimeBeRemoved (which is satisfied // before syncTerminatedPod is invoked) if err := kl.volumeManager.WaitForUnmount(ctx, pod); err != nil { return err } klog.V(4).InfoS("Pod termination unmounted volumes", "pod", klog.KObj(pod), "podUID", pod.UID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)