- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 975 for cpuset (0.15 sec)
-
pkg/kubelet/cm/cpumanager/cpu_manager_test.go
{"2000m", "2000m"}}), expInitCSets: []cpuset.CPUSet{ cpuset.New(0, 4), cpuset.New(0, 4)}, expCSets: []cpuset.CPUSet{ cpuset.New(0, 4)}, }, { description: "Multi Init Container Less CPUs", topo: topoSingleSocketHT, numReservedCPUs: 0, stAssignments: state.ContainerCPUAssignments{}, stDefaultCPUSet: cpuset.New(0, 1, 2, 3, 4, 5, 6, 7),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 42.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state.go
ret[pod][container] = cset } } 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) -
pkg/kubelet/cm/cpumanager/cpu_assignment_test.go
cpuset.New(0, 1, 2, 3, 4, 5, 6, 7), []cpuset.CPUSet{ cpuset.New(0), cpuset.New(1), cpuset.New(2), cpuset.New(3), cpuset.New(4), cpuset.New(5), cpuset.New(6), cpuset.New(7), }, 8, true, false, }, } for _, tc := range testCases { t.Run(tc.description, func(t *testing.T) { acc := newCPUAccumulator(tc.topo, tc.availableCPUs, tc.numCPUs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 17:31:37 UTC 2023 - 22.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_checkpoint.go
sc.mux.Lock() defer sc.mux.Unlock() sc.cache.SetCPUSet(podUID, containerName, cset) err := sc.storeState() if err != nil { klog.InfoS("Store state to checkpoint error", "err", err) } } // SetDefaultCPUSet sets default CPU set func (sc *stateCheckpoint) SetDefaultCPUSet(cset cpuset.CPUSet) { sc.mux.Lock() defer sc.mux.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 00:59:30 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static_test.go
topo: topoDualSocketHT, stAssignments: state.ContainerCPUAssignments{ "fakePod": map[string]cpuset.CPUSet{ "0": cpuset.New(0, 1, 2), "1": cpuset.New(3, 4), }, }, stDefaultCPUSet: cpuset.New(5, 6, 7, 8, 9, 10, 11, 12), expErr: fmt.Errorf("current set of available CPUs \"0-11\" doesn't match with CPUs in state \"0-12\""), }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 40.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static.go
func getAssignedCPUsOfSiblings(s state.State, podUID string, containerName string) cpuset.CPUSet { assignments := s.GetCPUAssignments() cset := cpuset.New() for name, cpus := range assignments[podUID] { if containerName == name { continue } cset = cset.Union(cpus) } return cset
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 28.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/topology_hints_test.go
pod: *testPod1, container: *testContainer1, assignments: state.ContainerCPUAssignments{ string(testPod1.UID): map[string]cpuset.CPUSet{ testContainer1.Name: cpuset.New(0, 6), }, }, defaultCPUSet: cpuset.New(), expectedHints: []topologymanager.TopologyHint{ { NUMANodeAffinity: firstSocketMask, Preferred: true, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 19K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_assignment.go
// the least amount of free CPUs to the one with the highest amount of free CPUs (i.e. in ascending // order of free CPUs). For any NUMA node, the cores are selected from the ones in the socket with // the least amount of free CPUs to the one with the highest amount of free CPUs. func takeByTopologyNUMAPacked(topo *topology.CPUTopology, availableCPUs cpuset.CPUSet, numCPUs int) (cpuset.CPUSet, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 25 23:56:21 UTC 2024 - 36.3K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager.go
TopologyManagerPolicyOptions map[string]string } type NodeAllocatableConfig struct { KubeReservedCgroupName string SystemReservedCgroupName string ReservedSystemCPUs cpuset.CPUSet EnforceNodeAllocatable sets.Set[string] KubeReserved v1.ResourceList SystemReserved v1.ResourceList HardEvictionThresholds []evictionapi.Threshold } type Status struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:13 UTC 2024 - 9K bytes - Viewed (0)