Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for mirrorToPod (0.14 sec)

  1. pkg/kubelet/pod/pod_manager.go

    func (pm *basicManager) GetUIDTranslations() (podToMirror map[kubetypes.ResolvedPodUID]kubetypes.MirrorPodUID,
    	mirrorToPod map[kubetypes.MirrorPodUID]kubetypes.ResolvedPodUID) {
    	pm.lock.RLock()
    	defer pm.lock.RUnlock()
    
    	podToMirror = make(map[kubetypes.ResolvedPodUID]kubetypes.MirrorPodUID, len(pm.translationByUID))
    	mirrorToPod = make(map[kubetypes.MirrorPodUID]kubetypes.ResolvedPodUID, len(pm.translationByUID))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. pkg/kubelet/status/status_manager.go

    	}
    
    	var updatedStatuses []podSync
    	podToMirror, mirrorToPod := m.podManager.GetUIDTranslations()
    	func() { // Critical section
    		m.podStatusesLock.RLock()
    		defer m.podStatusesLock.RUnlock()
    
    		// Clean up orphaned versions.
    		if all {
    			for uid := range m.apiStatusVersions {
    				_, hasPod := m.podStatuses[types.UID(uid)]
    				_, hasMirror := mirrorToPod[uid]
    				if !hasPod && !hasMirror {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
Back to top