Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for allocatedDevices (0.16 sec)

  1. pkg/kubelet/cm/devicemanager/manager.go

    		// device manager will recalculate the allocatedDevices map. Some entries with
    		// empty sets may be removed, so we reinit here.
    		if m.allocatedDevices[resource] == nil {
    			m.allocatedDevices[resource] = sets.New[string]()
    		}
    		for device := range devices.Difference(allocated) {
    			m.allocatedDevices[resource].Insert(device)
    			allocated.Insert(device)
    			needed--
    			if needed == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/devicemanager/manager_test.go

    	// require one of resource1 and one of resource2
    	testManager.allocatedDevices[resourceName1] = sets.New[string]()
    	testManager.allocatedDevices[resourceName1].Insert(devID1)
    	testManager.allocatedDevices[resourceName2] = sets.New[string]()
    	testManager.allocatedDevices[resourceName2].Insert(devID2)
    
    	cachedNode := &v1.Node{
    		Status: v1.NodeStatus{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/devicemanager/topology_hints.go

    	}
    	return false
    }
    
    func (m *ManagerImpl) getAvailableDevices(resource string) sets.Set[string] {
    	// Strip all devices in use from the list of healthy ones.
    	return m.healthyDevices[resource].Difference(m.allocatedDevices[resource])
    }
    
    func (m *ManagerImpl) generateDeviceTopologyHints(resource string, available sets.Set[string], reusable sets.Set[string], request int) []topologymanager.TopologyHint {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 27 02:10:25 UTC 2024
    - 9.9K bytes
    - Viewed (0)
Back to top