- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for numaNodes (3.51 sec)
-
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) -
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) -
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) -
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) -
samples/kind-lb/setupkind.sh
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 02 19:08:19 UTC 2023 - 7.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)