Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for allocatedDevices (0.17 sec)

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

    				m.healthyDevices[r].Insert(d.ID)
    			}
    		}
    
    		for p := range tc.allocatedDevices {
    			for c := range tc.allocatedDevices[p] {
    				for r, devices := range tc.allocatedDevices[p][c] {
    					m.podDevices.insert(p, c, r, constructDevices(devices), nil)
    
    					m.allocatedDevices[r] = sets.New[string]()
    					for _, d := range devices {
    						m.allocatedDevices[r].Insert(d)
    					}
    				}
    			}
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 47.5K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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