Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for ShouldResetExtendedResourceCapacity (0.49 sec)

  1. pkg/kubelet/cm/container_manager_stub.go

    }
    
    func NewStubContainerManager() ContainerManager {
    	return &containerManagerStub{shouldResetExtendedResourceCapacity: false}
    }
    
    func NewStubContainerManagerWithExtendedResource(shouldResetExtendedResourceCapacity bool) ContainerManager {
    	return &containerManagerStub{shouldResetExtendedResourceCapacity: shouldResetExtendedResourceCapacity}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 15 02:26:59 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/fake_container_manager.go

    	return nil
    }
    
    func (cm *FakeContainerManager) ShouldResetExtendedResourceCapacity() bool {
    	cm.Lock()
    	defer cm.Unlock()
    	cm.CalledFunctions = append(cm.CalledFunctions, "ShouldResetExtendedResourceCapacity")
    	return cm.shouldResetExtendedResourceCapacity
    }
    
    func (cm *FakeContainerManager) GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler {
    	cm.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 17:33:04 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/devicemanager/types.go

    	GetAllocatableDevices() ResourceDeviceInstances
    
    	// ShouldResetExtendedResourceCapacity returns whether the extended resources should be reset or not,
    	// depending on the checkpoint file availability. Absence of the checkpoint file strongly indicates
    	// the node has been recreated.
    	ShouldResetExtendedResourceCapacity() bool
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 5K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/container_manager_windows.go

    }
    
    func (cm *containerManagerImpl) GetAllocatableDevices() []*podresourcesapi.ContainerDevices {
    	return nil
    }
    
    func (cm *containerManagerImpl) ShouldResetExtendedResourceCapacity() bool {
    	return cm.deviceManager.ShouldResetExtendedResourceCapacity()
    }
    
    func (cm *containerManagerImpl) GetAllocateResourcesPodAdmitHandler() lifecycle.PodAdmitHandler {
    	return &noopWindowsResourceAllocator{}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 11:25:36 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/container_manager.go

    	// registration.
    	GetPluginRegistrationHandler() cache.PluginHandler
    
    	// ShouldResetExtendedResourceCapacity returns whether or not the extended resources should be zeroed,
    	// due to node recreation.
    	ShouldResetExtendedResourceCapacity() bool
    
    	// GetAllocateResourcesPodAdmitHandler returns an instance of a PodAdmitHandler responsible for allocating pod resources.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:13 UTC 2024
    - 9K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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