- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ShouldResetExtendedResourceCapacity (0.57 sec)
-
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) -
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) -
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) -
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) -
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)