Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 64 for numaNodes (2.59 sec)

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

    	// Get the total number of NUMA nodes in the system.
    	numNUMANodes := a.topo.CPUDetails.NUMANodes().Size()
    
    	// Get the total number of NUMA nodes that have CPUs available on them.
    	numNUMANodesAvailable := a.details.NUMANodes().Size()
    
    	// Get the total number of CPUs in the system.
    	numCPUs := a.topo.CPUDetails.CPUs().Size()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 25 23:56:21 UTC 2024
    - 36.3K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/policy_static.go

    	// Initialize minAffinitySize to include all NUMA Nodes.
    	minAffinitySize := p.topology.CPUDetails.NUMANodes().Size()
    
    	// Iterate through all combinations of numa nodes bitmask and build hints from them.
    	hints := []topologymanager.TopologyHint{}
    	bitmask.IterateBitMasks(p.topology.CPUDetails.NUMANodes().List(), func(mask bitmask.BitMask) {
    		// First, update minAffinitySize for the current request size.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/devicemanager/topology_hints_test.go

    			allocatedDevices: make(map[string]sets.Set[string]),
    			podDevices:       newPodDevices(),
    			sourcesReady:     &sourcesReadyStub{},
    			activePods:       func() []*v1.Pod { return []*v1.Pod{tc.pod} },
    			numaNodes:        []int{0, 1},
    		}
    
    		for r := range tc.devices {
    			m.allDevices[r] = make(DeviceInstances)
    			m.healthyDevices[r] = sets.New[string]()
    
    			for _, d := range tc.devices[r] {
    				m.allDevices[r][d.ID] = d
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 47.5K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/cache/node_tree.go

    // over nodes in a round robin fashion.
    func (nt *nodeTree) list() ([]string, error) {
    	if len(nt.zones) == 0 {
    		return nil, nil
    	}
    	nodesList := make([]string, 0, nt.numNodes)
    	numExhaustedZones := 0
    	nodeIndex := 0
    	for len(nodesList) < nt.numNodes {
    		if numExhaustedZones >= len(nt.zones) { // all zones are exhausted.
    			return nodesList, errors.New("all zones exhausted before reaching count of nodes expected")
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  5. pkg/kubelet/apis/podresources/server_v1_test.go

    			Topology:     &podresourcesapi.TopologyInfo{Nodes: []*podresourcesapi.NUMANode{{ID: numaID}}},
    		},
    	}
    
    	cpus := []int64{12, 23, 30}
    
    	memory := []*podresourcesapi.ContainerMemory{
    		{
    			MemoryType: "memory",
    			Size_:      1073741824,
    			Topology:   &podresourcesapi.TopologyInfo{Nodes: []*podresourcesapi.NUMANode{{ID: numaID}}},
    		},
    		{
    			MemoryType: "hugepages-1Gi",
    			Size_:      1073741824,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  6. samples/kind-lb/setupkind.sh

      exit 1
    fi
    
    if [[ "${MODE}" == "ambient" ]]; then
      NUMNODES=${NUMNODES:-2}
    fi
    
    NODES=$(cat <<-EOM
    nodes:
    - role: control-plane
    EOM
    )
    
    if [[ -n "${NUMNODES}" ]]; then
    for _ in $(seq 1 "${NUMNODES}"); do
      NODES+=$(printf "\n%s" "- role: worker")
    done
    fi
    
    CONFIG=$(cat <<-EOM
    kind: Cluster
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Oct 02 19:08:19 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go

    // candidates returned will never be greater than <numNodes>.
    func (pl *DefaultPreemption) calculateNumCandidates(numNodes int32) int32 {
    	n := (numNodes * pl.args.MinCandidateNodesPercentage) / 100
    	if n < pl.args.MinCandidateNodesAbsolute {
    		n = pl.args.MinCandidateNodesAbsolute
    	}
    	if n > numNodes {
    		n = numNodes
    	}
    	return n
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 25 19:36:04 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  8. cluster/gce/config-common.sh

    # limitations under the License.
    
    # Returns the total number of Linux and Windows nodes in the cluster.
    #
    # Vars assumed:
    #   NUM_NODES
    #   NUM_WINDOWS_NODES
    function get-num-nodes {
      echo "$((NUM_NODES + NUM_WINDOWS_NODES))"
    }
    
    # Vars assumed:
    #   NUM_NODES
    #   NUM_WINDOWS_NODES
    function get-master-size {
      local suggested_master_size=2
      if [[ "$(get-num-nodes)" -gt "10" ]]; then
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 20:06:08 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. pkg/scheduler/internal/cache/node_tree_test.go

    	expectedNumNodes := int(0)
    	for _, na := range expectedTree {
    		expectedNumNodes += len(na)
    	}
    	if numNodes := nt.numNodes; numNodes != expectedNumNodes {
    		t.Errorf("unexpected nodeTree.numNodes. Expected: %v, Got: %v", expectedNumNodes, numNodes)
    	}
    	if diff := cmp.Diff(expectedTree, nt.tree); diff != "" {
    		t.Errorf("Unexpected node tree (-want, +got):\n%s", diff)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 08:00:25 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/memorymanager/memory_manager_test.go

    			[]kubeletconfig.MemoryReservation{
    				{
    					NumaNode: 0,
    					Limits: v1.ResourceList{
    						v1.ResourceMemory: *resource.NewQuantity(0, resource.DecimalSI),
    					},
    				},
    			},
    			"",
    		},
    		{
    			"Node Allocatable not set (equal zero), reserved set",
    			v1.ResourceList{},
    			machineInfo,
    			[]kubeletconfig.MemoryReservation{
    				{
    					NumaNode: 0,
    					Limits: v1.ResourceList{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 05 13:01:40 UTC 2023
    - 70.2K bytes
    - Viewed (0)
Back to top