Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ListCheckpoints (0.26 sec)

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

    // has been recreated.
    func (m *ManagerImpl) ShouldResetExtendedResourceCapacity() bool {
    	checkpoints, err := m.checkpointManager.ListCheckpoints()
    	if err != nil {
    		return false
    	}
    	return len(checkpoints) == 0
    }
    
    func (m *ManagerImpl) setPodPendingAdmission(pod *v1.Pod) {
    	m.mutex.Lock()
    	defer m.mutex.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/devicemanager/manager_test.go

    	err = testManager.writeCheckpoint()
    	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)
Back to top