- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for findAndRemoveDeletedPods (0.19 sec)
-
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
} // 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 if _, ok := dswp.pods.processedPods[podName]; ok {
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/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
if !volumeExists { t.Fatalf( "VolumeExists(%q) failed. Expected: <true> Actual: <%v>", expectedVolumeName, volumeExists) } fakePodInformer.Informer().GetStore().Delete(pod) dswp.findAndRemoveDeletedPods(logger) //check if the given volume referenced by the pod still exists in dsw volumeExists = dswp.desiredStateOfWorld.VolumeExists(expectedVolumeName, k8stypes.NodeName(pod.Spec.NodeName)) if volumeExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
dswp.hasAddedPodsLock.RLock() defer dswp.hasAddedPodsLock.RUnlock() return dswp.hasAddedPods } func (dswp *desiredStateOfWorldPopulator) populatorLoop() { dswp.findAndAddNewPods() dswp.findAndRemoveDeletedPods() } // Iterate through all pods and add to desired state of world if they don't // exist but should func (dswp *desiredStateOfWorldPopulator) findAndAddNewPods() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0)