Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 85 for num_nodes (0.14 sec)

  1. cluster/log-dump/log-dump.sh

    # are present then they will be detected and their logs will be dumped too.
    function dump_nodes() {
      local node_names=()
      local windows_node_names=()
      if [[ -n "${1:-}" ]]; then
        echo 'Dumping logs for nodes provided as args to dump_nodes() function'
        node_names=( "$@" )
      elif [[ -n "${use_custom_instance_list}" ]]; then
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 21:15:57 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/internal_container_lifecycle_linux.go

    			containerConfig.Linux.Resources.CpusetCpus = allocatedCPUs.String()
    		}
    	}
    
    	if i.memoryManager != nil {
    		numaNodes := i.memoryManager.GetMemoryNUMANodes(pod, container)
    		if numaNodes.Len() > 0 {
    			var affinity []string
    			for _, numaNode := range sets.List(numaNodes) {
    				affinity = append(affinity, strconv.Itoa(numaNode))
    			}
    			containerConfig.Linux.Resources.CpusetMems = strings.Join(affinity, ",")
    		}
    	}
    
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/topology/topology.go

    		}
    	}
    	return result
    }
    
    // NUMANodes returns all of the NUMANode IDs associated with the CPUs in this
    // CPUDetails.
    func (d CPUDetails) NUMANodes() cpuset.CPUSet {
    	var numaNodeIDs []int
    	for _, info := range d {
    		numaNodeIDs = append(numaNodeIDs, info.NUMANodeID)
    	}
    	return cpuset.New(numaNodeIDs...)
    }
    
    // NUMANodesInSockets returns all of the logical NUMANode IDs associated with
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/memorymanager/memory_manager.go

    	numaNodes := map[int]bool{}
    	for _, numaNode := range machineInfo.Topology {
    		numaNodes[numaNode.Id] = true
    	}
    
    	for _, reservation := range reservedMemory {
    		if !numaNodes[int(reservation.NumaNode)] {
    			return nil, fmt.Errorf("the reserved memory configuration references a NUMA node %d that does not exist on this machine", reservation.NumaNode)
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  5. tensorflow/compiler/mlir/tensorflow/translate/import_model.cc

                                         node->name(),
                                         "' is missing attribute 'index'");
    
        auto index = attr->i();
        const int num_nodes = nodes->size();
        if (num_nodes < index + 1) nodes->resize(index + 1);
    
        if ((*nodes)[index].node != nullptr)
          return errors::InvalidArgument(node->type_string(), " node '",
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed May 01 11:17:36 UTC 2024
    - 183.2K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/devicemanager/topology_hints.go

    	// Initialize minAffinitySize to include all NUMA Nodes
    	minAffinitySize := len(m.numaNodes)
    
    	// Iterate through all combinations of NUMA Nodes and build hints from them.
    	hints := []topologymanager.TopologyHint{}
    	bitmask.IterateBitMasks(m.numaNodes, func(mask bitmask.BitMask) {
    		// First, update minAffinitySize for the current request size.
    		devicesInMask := 0
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 27 02:10:25 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/cpumanager/topology/topology_test.go

    		3: {NUMANodeID: 2, SocketID: 3},
    	}
    
    	tests := []struct {
    		name string
    		ids  []int
    		want cpuset.CPUSet
    	}{{
    		name: "NUMANodes IDs is in CPUDetails.",
    		ids:  []int{0, 1},
    		want: cpuset.New(0, 1, 2),
    	}, {
    		name: "NUMANodes IDs is not in CPUDetails.",
    		ids:  []int{3},
    		want: cpuset.New(),
    	}}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 31.7K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/topologymanager/numa_info.go

    type NUMAInfo struct {
    	Nodes         []int
    	NUMADistances NUMADistances
    }
    
    func NewNUMAInfo(topology []cadvisorapi.Node, opts PolicyOptions) (*NUMAInfo, error) {
    	var numaNodes []int
    	distances := map[int][]uint64{}
    	for _, node := range topology {
    		numaNodes = append(numaNodes, node.Id)
    
    		var nodeDistance []uint64
    		if opts.PreferClosestNUMA {
    			nodeDistance = node.Distances
    			if nodeDistance == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:14 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top