Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,500 for cpuset (0.41 sec)

  1. 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)
  2. 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)
  3. pkg/kubelet/cm/cpumanager/fake_cpu_manager.go

    func (m *fakeManager) GetExclusiveCPUs(podUID, containerName string) cpuset.CPUSet {
    	klog.InfoS("GetExclusiveCPUs", "podUID", podUID, "containerName", containerName)
    	return cpuset.CPUSet{}
    }
    
    func (m *fakeManager) GetAllocatableCPUs() cpuset.CPUSet {
    	klog.InfoS("Get Allocatable CPUs")
    	return cpuset.CPUSet{}
    }
    
    func (m *fakeManager) GetCPUAffinity(podUID, containerName string) cpuset.CPUSet {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/state/state_checkpoint_test.go

    			assignments: map[string]map[string]cpuset.CPUSet{
    				"pod": {
    					"c1": cpuset.New(0, 1),
    					"c2": cpuset.New(2, 3, 4, 5),
    				},
    			},
    		},
    		{
    			description:   "Container without assigned cpus",
    			defaultCPUset: cpuset.New(0, 1, 2, 3, 4, 5, 6, 7, 8),
    			assignments: map[string]map[string]cpuset.CPUSet{
    				"pod": {
    					"c1": cpuset.New(),
    				},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/state/state_mem.go

    		s.assignments[podUID] = make(map[string]cpuset.CPUSet)
    	}
    
    	s.assignments[podUID][containerName] = cset
    	klog.InfoS("Updated desired CPUSet", "podUID", podUID, "containerName", containerName, "cpuSet", cset)
    }
    
    func (s *stateMemory) SetDefaultCPUSet(cset cpuset.CPUSet) {
    	s.Lock()
    	defer s.Unlock()
    
    	s.defaultCPUSet = cset
    	klog.InfoS("Updated default CPUSet", "cpuSet", cset)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top