Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 975 for cpuset (0.15 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/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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/kubelet/cm/container_manager_linux_test.go

    )
    
    func fakeContainerMgrMountInt() mount.Interface {
    	return mount.NewFakeMounter(
    		[]mount.MountPoint{
    			{
    				Device: "cgroup",
    				Type:   "cgroup",
    				Opts:   []string{"rw", "relatime", "cpuset"},
    			},
    			{
    				Device: "cgroup",
    				Type:   "cgroup",
    				Opts:   []string{"rw", "relatime", "cpu"},
    			},
    			{
    				Device: "cgroup",
    				Type:   "cgroup",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  10. 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)
Back to top