Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for fromCheckpointData (0.15 sec)

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

    					DeviceIDs:     devices.deviceIds,
    					AllocResp:     allocResp})
    			}
    		}
    	}
    	return data
    }
    
    // Populates podDevices from the passed in checkpointData.
    func (pdev *podDevices) fromCheckpointData(data []checkpoint.PodDevicesEntry) {
    	for _, entry := range data {
    		klog.V(2).InfoS("Get checkpoint entry",
    			"podUID", entry.PodUID, "containerName", entry.ContainerName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 27 02:10:25 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/devicemanager/manager.go

    			return nil
    		}
    		return err
    	}
    
    	m.mutex.Lock()
    	defer m.mutex.Unlock()
    	podDevices, registeredDevs := cp.GetData()
    	m.podDevices.fromCheckpointData(podDevices)
    	m.allocatedDevices = m.podDevices.devices()
    	for resource := range registeredDevs {
    		// During start up, creates empty healthyDevices list so that the resource capacity
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
Back to top