Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 71 for num_nodes (0.43 sec)

  1. 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)
  2. pkg/kubelet/cm/devicemanager/pod_devices.go

    				if numaid != nodeWithoutTopology {
    					NUMANodes := []*pluginapi.NUMANode{{ID: numaid}}
    					if pDev, ok := devicePluginMap[devID]; ok && pDev.Topology != nil {
    						if nodes := pDev.Topology.GetNodes(); nodes != nil {
    							NUMANodes = append(NUMANodes, nodes...)
    						}
    					}
    
    					// ID and Healthy are not relevant here.
    					topology = &pluginapi.TopologyInfo{Nodes: NUMANodes}
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 27 02:10:25 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  3. 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)
  4. pkg/kubelet/cm/topologymanager/policy_test.go

    			expected: TopologyHint{
    				NUMANodeAffinity: NewTestBitMask(numaNodes...),
    				Preferred:        true,
    			},
    		},
    		{
    			name: "HintProvider returns empty non-nil map[string][]TopologyHint",
    			hp: []HintProvider{
    				&mockHintProvider{
    					map[string][]TopologyHint{},
    				},
    			},
    			expected: TopologyHint{
    				NUMANodeAffinity: NewTestBitMask(numaNodes...),
    				Preferred:        true,
    			},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:08 UTC 2022
    - 34.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. pkg/scheduler/internal/cache/debugger/dumper.go

    }
    
    // DumpAll writes cached nodes and scheduling queue information to the scheduler logs.
    func (d *CacheDumper) DumpAll(logger klog.Logger) {
    	d.dumpNodes(logger)
    	d.dumpSchedulingQueue(logger)
    }
    
    // dumpNodes writes NodeInfo to the scheduler logs.
    func (d *CacheDumper) dumpNodes(logger klog.Logger) {
    	dump := d.cache.Dump()
    	nodeInfos := make([]string, 0, len(dump.Nodes))
    	for name, nodeInfo := range dump.Nodes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  8. 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)
  9. pkg/kubelet/cm/devicemanager/manager.go

    	klog.V(2).InfoS("Creating Device Plugin manager", "path", socketPath)
    
    	var numaNodes []int
    	for _, node := range topology {
    		numaNodes = append(numaNodes, node.Id)
    	}
    
    	manager := &ManagerImpl{
    		endpoints: make(map[string]endpointInfo),
    
    		allDevices:            NewResourceDeviceInstances(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  10. pkg/scheduler/internal/cache/snapshot_test.go

    				"gcr.io/200:v1": sets.New("node-0"),
    			},
    			expected: map[string]*framework.ImageStateSummary{
    				"gcr.io/10:v1": {
    					Size:     int64(10 * mb),
    					NumNodes: 2,
    				},
    				"gcr.io/200:v1": {
    					Size:     int64(200 * mb),
    					NumNodes: 1,
    				},
    			},
    		},
    		{
    			node: &v1.Node{
    				ObjectMeta: metav1.ObjectMeta{Name: "node-0"},
    				Status:     v1.NodeStatus{},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 08:00:25 UTC 2023
    - 12K bytes
    - Viewed (0)
Back to top