Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetDefaultCPUSet (0.18 sec)

  1. pkg/kubelet/cm/cpumanager/state/state_checkpoint.go

    	defer sc.mux.RUnlock()
    
    	res, ok := sc.cache.GetCPUSet(podUID, containerName)
    	return res, ok
    }
    
    // GetDefaultCPUSet returns default CPU set
    func (sc *stateCheckpoint) GetDefaultCPUSet() cpuset.CPUSet {
    	sc.mux.RLock()
    	defer sc.mux.RUnlock()
    
    	return sc.cache.GetDefaultCPUSet()
    }
    
    // GetCPUSetOrDefault returns current CPU set, or default one if it wasn't changed
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 00:59:30 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/state/state_mem.go

    	return res.Clone(), ok
    }
    
    func (s *stateMemory) GetDefaultCPUSet() cpuset.CPUSet {
    	s.RLock()
    	defer s.RUnlock()
    
    	return s.defaultCPUSet.Clone()
    }
    
    func (s *stateMemory) GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet {
    	if res, ok := s.GetCPUSet(podUID, containerName); ok {
    		return res
    	}
    	return s.GetDefaultCPUSet()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/state/state_checkpoint_test.go

    					}
    				}
    			}
    		})
    	}
    }
    
    func AssertStateEqual(t *testing.T, sf State, sm State) {
    	cpusetSf := sf.GetDefaultCPUSet()
    	cpusetSm := sm.GetDefaultCPUSet()
    	if !cpusetSf.Equals(cpusetSm) {
    		t.Errorf("State CPUSet mismatch. Have %v, want %v", cpusetSf, cpusetSm)
    	}
    
    	cpuassignmentSf := sf.GetCPUAssignments()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/state/state.go

    		}
    	}
    	return ret
    }
    
    // Reader interface used to read current cpu/pod assignment state
    type Reader interface {
    	GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool)
    	GetDefaultCPUSet() cpuset.CPUSet
    	GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet
    	GetCPUAssignments() ContainerCPUAssignments
    }
    
    type writer interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 00:59:30 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/cpu_manager_test.go

    	return res.Clone(), ok
    }
    
    func (s *mockState) GetDefaultCPUSet() cpuset.CPUSet {
    	return s.defaultCPUSet.Clone()
    }
    
    func (s *mockState) GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet {
    	if res, ok := s.GetCPUSet(podUID, containerName); ok {
    		return res
    	}
    	return s.GetDefaultCPUSet()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 42.9K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/cpumanager/policy_static.go

    func (p *staticPolicy) GetAvailableCPUs(s state.State) cpuset.CPUSet {
    	return s.GetDefaultCPUSet().Difference(p.reservedCPUs)
    }
    
    func (p *staticPolicy) GetAvailablePhysicalCPUs(s state.State) cpuset.CPUSet {
    	return s.GetDefaultCPUSet().Difference(p.reservedPhysicalCPUs)
    }
    
    func (p *staticPolicy) updateCPUsToReuse(pod *v1.Pod, container *v1.Container, cset cpuset.CPUSet) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/cpumanager/policy_static_test.go

    						t.Errorf("StaticPolicy Start() error. expected cpuid %d to be present in defaultCPUSet", cpuid)
    					}
    				}
    			}
    			if !st.GetDefaultCPUSet().Equals(testCase.expCSet) {
    				t.Errorf("State CPUSet is different than expected. Have %q wants: %q", st.GetDefaultCPUSet(),
    					testCase.expCSet)
    			}
    
    		})
    	}
    }
    
    func TestStaticPolicyAdd(t *testing.T) {
    	var largeTopoCPUids []int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 40.8K bytes
    - Viewed (0)
Back to top