Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for removeStaleState (0.52 sec)

  1. pkg/kubelet/cm/memorymanager/memory_manager.go

    	// Garbage collect any stranded resources before providing TopologyHints
    	m.removeStaleState()
    	// Delegate to active policy
    	return m.policy.GetTopologyHints(m.state, pod, container)
    }
    
    // TODO: move the method to the upper level, to re-use it under the CPU and memory managers
    func (m *manager) removeStaleState() {
    	// Only once all sources are ready do we attempt to remove any stale state.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/cpu_manager.go

    			if _, ok := activeContainers[podUID][containerName]; !ok {
    				klog.ErrorS(nil, "RemoveStaleState: removing container", "podUID", podUID, "containerName", containerName)
    				err := m.policyRemoveContainerByRef(podUID, containerName)
    				if err != nil {
    					klog.ErrorS(err, "RemoveStaleState: failed to remove container", "podUID", podUID, "containerName", containerName)
    				}
    			}
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 19.9K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/memorymanager/memory_manager_test.go

    			mgr.state.SetMemoryAssignments(testCase.assignments)
    			mgr.state.SetMachineState(testCase.machineState)
    
    			mgr.removeStaleState()
    
    			if !areContainerMemoryAssignmentsEqual(t, mgr.state.GetMemoryAssignments(), testCase.expectedAssignments) {
    				t.Errorf("Memory Manager removeStaleState() error, expected assignments %v, but got: %v",
    					testCase.expectedAssignments, mgr.state.GetMemoryAssignments())
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 05 13:01:40 UTC 2023
    - 70.2K bytes
    - Viewed (0)
Back to top