Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ShouldResetExtendedResourceCapacity (0.57 sec)

  1. pkg/kubelet/cm/container_manager_linux.go

    		containerDynamicResources = append(containerDynamicResources, &containerDynamicResource)
    	}
    	return containerDynamicResources
    }
    
    func (cm *containerManagerImpl) ShouldResetExtendedResourceCapacity() bool {
    	return cm.deviceManager.ShouldResetExtendedResourceCapacity()
    }
    
    func (cm *containerManagerImpl) UpdateAllocatedDevices() {
    	cm.deviceManager.UpdateAllocatedDevices()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 10:18:16 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/devicemanager/manager.go

    	return m.podDevices.getContainerDevices(podUID, containerName)
    }
    
    // ShouldResetExtendedResourceCapacity returns whether the extended resources should be zeroed or not,
    // depending on whether the node has been recreated. Absence of the checkpoint file strongly indicates the node
    // has been recreated.
    func (m *ManagerImpl) ShouldResetExtendedResourceCapacity() bool {
    	checkpoints, err := m.checkpointManager.ListCheckpoints()
    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

    	as.Nil(err)
    
    	as.False(testManager.ShouldResetExtendedResourceCapacity())
    
    	// checkpoint is absent, representing node recreation
    	ckpts, err := ckm.ListCheckpoints()
    	as.Nil(err)
    	for _, ckpt := range ckpts {
    		err = ckm.RemoveCheckpoint(ckpt)
    		as.Nil(err)
    	}
    	as.True(testManager.ShouldResetExtendedResourceCapacity())
    }
    
    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/kubelet_node_status.go

    	// Check with the device manager to see if node has been recreated, in which case extended resources should be zeroed until they are available
    	if kl.containerManager.ShouldResetExtendedResourceCapacity() {
    		for k := range node.Status.Capacity {
    			if v1helper.IsExtendedResourceName(k) {
    				klog.InfoS("Zero out resource capacity in existing node", "resourceName", k, "node", klog.KObj(node))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_node_status_test.go

    	testKubelet.kubelet.kubeClient = nil // ensure only the heartbeat client is used
    	testKubelet.kubelet.containerManager = cm.NewStubContainerManagerWithExtendedResource(true /* shouldResetExtendedResourceCapacity*/)
    	testKubeletNoReset := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
    	defer testKubeletNoReset.Cleanup()
    	extendedResourceName1 := v1.ResourceName("test.com/resource1")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
Back to top