Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 62 for TopologyManager (0.21 sec)

  1. pkg/kubelet/cm/cpumanager/policy_options.go

    	if opts.AlignBySocket {
    		// Not compatible with topology manager single-numa-node policy option.
    		if topologyManager.GetPolicy().Name() == topologymanager.PolicySingleNumaNode {
    			return fmt.Errorf("Topolgy manager %s policy is incompatible with CPUManager %s policy option", topologymanager.PolicySingleNumaNode, AlignBySocketOption)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/memorymanager/fake_memory_manager.go

    	klog.InfoS("Get Topology Hints", "pod", klog.KObj(pod), "containerName", container.Name)
    	return map[string][]topologymanager.TopologyHint{}
    }
    
    func (m *fakeManager) GetPodTopologyHints(pod *v1.Pod) map[string][]topologymanager.TopologyHint {
    	klog.InfoS("Get Pod Topology Hints", "pod", klog.KObj(pod))
    	return map[string][]topologymanager.TopologyHint{}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/topology_hints_test.go

    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    	"k8s.io/utils/cpuset"
    )
    
    type testCase struct {
    	name          string
    	pod           v1.Pod
    	container     v1.Container
    	assignments   state.ContainerCPUAssignments
    	defaultCPUSet cpuset.CPUSet
    	expectedHints []topologymanager.TopologyHint
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 19K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/memorymanager/policy_static.go

    }
    
    func regenerateHints(pod *v1.Pod, ctn *v1.Container, ctnBlocks []state.Block, reqRsrc map[v1.ResourceName]uint64) map[string][]topologymanager.TopologyHint {
    	hints := map[string][]topologymanager.TopologyHint{}
    	for resourceName := range reqRsrc {
    		hints[string(resourceName)] = []topologymanager.TopologyHint{}
    	}
    
    	if len(ctnBlocks) != len(reqRsrc) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/types.go

    	// the node has been recreated.
    	ShouldResetExtendedResourceCapacity() bool
    
    	// TopologyManager HintProvider provider indicates the Device Manager implements the Topology Manager Interface
    	// and is consulted to make Topology aware resource alignments
    	GetTopologyHints(pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint
    
    	// TopologyManager HintProvider provider indicates the Device Manager implements the Topology Manager Interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 5K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/topologymanager/topology_manager.go

    	// the TopologyManager supports on the underlying machine.
    	//
    	// At present, having more than this number of NUMA Nodes will result in a
    	// state explosion when trying to enumerate possible NUMAAffinity masks and
    	// generate hints for them. As such, if more NUMA Nodes than this are
    	// present on a machine and the TopologyManager is enabled, an error will
    	// be returned and the TopologyManager will not be loaded.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 15 12:43:16 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/cpumanager/policy_none.go

    	return nil
    }
    
    func (p *nonePolicy) GetTopologyHints(s state.State, pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint {
    	return nil
    }
    
    func (p *nonePolicy) GetPodTopologyHints(s state.State, pod *v1.Pod) map[string][]topologymanager.TopologyHint {
    	return nil
    }
    
    // Assignable CPUs are the ones that can be exclusively allocated to pods that meet the exclusivity requirement
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/cpumanager/policy_static_test.go

    	pkgfeatures "k8s.io/kubernetes/pkg/features"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/state"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/topology"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    	"k8s.io/utils/cpuset"
    )
    
    type staticPolicyTest struct {
    	description     string
    	topo            *topology.CPUTopology
    	numReservedCPUs int
    	reservedCPUs    *cpuset.CPUSet
    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

    	"k8s.io/kubernetes/pkg/features"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/state"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager/topology"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager/bitmask"
    	"k8s.io/kubernetes/pkg/kubelet/metrics"
    	"k8s.io/kubernetes/pkg/kubelet/types"
    	"k8s.io/utils/cpuset"
    )
    
    const (
    
    	// PolicyStatic is the name of the static policy.
    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/container_manager_stub.go

    	podresourcesapi "k8s.io/kubelet/pkg/apis/podresources/v1"
    	"k8s.io/kubernetes/pkg/kubelet/cm/cpumanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/memorymanager"
    	"k8s.io/kubernetes/pkg/kubelet/cm/topologymanager"
    	"k8s.io/kubernetes/pkg/kubelet/config"
    	kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
    	"k8s.io/kubernetes/pkg/kubelet/lifecycle"
    	"k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 15 02:26:59 UTC 2023
    - 5.9K bytes
    - Viewed (0)
Back to top