Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 13 of 13 for podUIDs (0.1 sec)

  1. pkg/kubelet/kubelet_pods.go

    func (kl *Kubelet) removeOrphanedPodStatuses(pods []*v1.Pod, mirrorPods []*v1.Pod) {
    	podUIDs := make(map[types.UID]bool)
    	for _, pod := range pods {
    		podUIDs[pod.UID] = true
    	}
    	for _, pod := range mirrorPods {
    		podUIDs[pod.UID] = true
    	}
    	kl.statusManager.RemoveOrphanedStatuses(podUIDs)
    }
    
    // HandlePodCleanups performs a series of cleanup work, including terminating
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/devicemanager/manager.go

    	for _, pod := range activeAndAdmittedPods {
    		podsToBeRemoved.Delete(string(pod.UID))
    	}
    	if len(podsToBeRemoved) <= 0 {
    		return
    	}
    	klog.V(3).InfoS("Pods to be removed", "podUIDs", sets.List(podsToBeRemoved))
    	m.podDevices.delete(sets.List(podsToBeRemoved))
    	// Regenerated allocatedDevices after we update pod allocation information.
    	m.allocatedDevices = m.podDevices.devices()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet.go

    // PodWorker which pods should be synced.
    func (kl *Kubelet) getPodsToSync() []*v1.Pod {
    	allPods := kl.podManager.GetPods()
    	podUIDs := kl.workQueue.GetWork()
    	podUIDSet := sets.New[string]()
    	for _, podUID := range podUIDs {
    		podUIDSet.Insert(string(podUID))
    	}
    	var podsToSync []*v1.Pod
    	for _, pod := range allPods {
    		if podUIDSet.Has(string(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)
Back to top