Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for numaNodes (3.51 sec)

  1. 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)
  2. 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)
  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/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. 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)
  6. 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)
  7. tensorflow/cc/client/client_session.cc

                 nullptr);
    }
    
    Status ClientSession::Impl::MaybeExtendGraph() const {
      mutex_lock l(mu_);
      int num_nodes = graph_->num_node_ids();
      if (num_nodes > last_num_graph_nodes_) {
        GraphDef graph_def;
        graph_->ToGraphDefSubRange(&graph_def, last_num_graph_nodes_);
        last_num_graph_nodes_ = num_nodes;
        return session_->Extend(graph_def);
      }
      return absl::OkStatus();
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Feb 28 09:04:10 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. pkg/scheduler/internal/cache/snapshot.go

    	return s
    }
    
    // StorageInfos returns a StorageInfoLister.
    func (s *Snapshot) StorageInfos() framework.StorageInfoLister {
    	return s
    }
    
    // NumNodes returns the number of nodes in the snapshot.
    func (s *Snapshot) NumNodes() int {
    	return len(s.nodeInfoList)
    }
    
    // List returns the list of nodes in the snapshot.
    func (s *Snapshot) List() ([]*framework.NodeInfo, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  9. internal/bucket/bandwidth/monitor.go

    // NewMonitor returns a monitor with defaults.
    func NewMonitor(ctx context.Context, numNodes uint64) *Monitor {
    	m := &Monitor{
    		bucketsMeasurement:    make(map[BucketOptions]*bucketMeasurement),
    		bucketsThrottle:       make(map[BucketOptions]*bucketThrottle),
    		bucketMovingAvgTicker: time.NewTicker(2 * time.Second),
    		ctx:                   ctx,
    		NodeCount:             numNodes,
    	}
    	go m.trackEWMA()
    	return m
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. cluster/gce/windows/README-GCE-Windows-kube-up.md

    Linux worker node is required and two are recommended because many default
    cluster-addons (e.g., `kube-dns`) need to run on Linux nodes. The master control
    plane only runs on Linux.
    
    ```bash
    export NUM_NODES=2  # number of Linux nodes
    export NUM_WINDOWS_NODES=2
    export KUBE_GCE_ENABLE_IP_ALIASES=true
    export KUBERNETES_NODE_PLATFORM=windows
    export LOGGING_STACKDRIVER_RESOURCE_TYPES=new
    ```
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 21:39:56 UTC 2023
    - 8.7K bytes
    - Viewed (0)
Back to top