- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Topo (0.22 sec)
-
pkg/kubelet/cm/cpumanager/policy_static_test.go
// objects which are accessed read-only func (spt staticPolicyTest) PseudoClone() staticPolicyTest { return staticPolicyTest{ description: spt.description, topo: spt.topo, // accessed in read-only numReservedCPUs: spt.numReservedCPUs, podUID: spt.podUID, options: spt.options, // accessed in read-only containerName: spt.containerName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 40.8K bytes - Viewed (0) -
src/internal/dag/alg.go
visit(root) } for i, j := 0, len(topo)-1; i < j; i, j = i+1, j-1 { topo[i], topo[j] = topo[j], topo[i] } return topo } // TransitiveReduction removes edges from g that are transitively // reachable. g must be transitively closed. func (g *Graph) TransitiveReduction() { // For i -> j -> k, if i -> k exists, delete it. for _, i := range g.Nodes { for _, j := range g.Nodes { if g.HasEdge(i, j) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 04 15:31:44 UTC 2022 - 1.3K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/topology/topology.go
// each core. func (topo *CPUTopology) CPUsPerCore() int { if topo.NumCores == 0 { return 0 } return topo.NumCPUs / topo.NumCores } // CPUsPerSocket returns the number of logical CPUs are associated with // each socket. func (topo *CPUTopology) CPUsPerSocket() int { if topo.NumSockets == 0 { return 0 } return topo.NumCPUs / topo.NumSockets }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 7.9K bytes - Viewed (0) -
src/internal/dag/alg_test.go
} func TestTopo(t *testing.T) { g := mustParse(t, diamond) got := g.Topo() // "d" is the root, so it's first. // // "c" and "b" could be in either order, but Topo is // deterministic in reverse node definition order. // // "a" is a leaf. wantNodes := strings.Fields("d c b a") if !reflect.DeepEqual(wantNodes, got) { t.Fatalf("want topo sort %v, got %v", wantNodes, got) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 04 15:31:44 UTC 2022 - 1.1K bytes - Viewed (0) -
src/runtime/mklockrank.go
fmt.Fprintf(w, `// Code generated by mklockrank.go; DO NOT EDIT. package runtime type lockRank int `) // Create numeric ranks. topo := g.Topo() for i, j := 0, len(topo)-1; i < j; i, j = i+1, j-1 { topo[i], topo[j] = topo[j], topo[i] } fmt.Fprintf(w, ` // Constants representing the ranks of all non-leaf runtime locks, in rank order.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/fake.go
allClusters := make(cluster.Map) for i := 0; i < f.NumClusters; i++ { topo := cluster.NewTopology(cluster.Config{ Name: fmt.Sprintf("cluster-%d", i), PrimaryClusterName: fmt.Sprintf("cluster-%d", i), ConfigClusterName: fmt.Sprintf("cluster-%d", i), }, allClusters) c := &kube.Cluster{Topology: topo} res = append(res, c) allClusters[c.Name()] = c } return res }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 1.8K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/topology/topology_test.go
} tests := []struct { name string topo *CPUTopology id int want int wantErr bool }{{ name: "Known Core ID", topo: topoDualSocketHT, id: 2, want: 2, }, { name: "Known Core ID (core sibling).", topo: topoDualSocketHT, id: 8, want: 2, }, { name: "Unknown Core ID.", topo: topoDualSocketHT, id: -2, want: -1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 31.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_assignment_test.go
acc := newCPUAccumulator(tc.topo, tc.availableCPUs, 0) result := acc.freeSockets() sort.Ints(result) if !reflect.DeepEqual(result, tc.expect) { t.Errorf("expected %v to equal %v", result, tc.expect) } }) } } func TestCPUAccumulatorFreeNUMANodes(t *testing.T) { testCases := []struct { description string topo *topology.CPUTopology
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 17:31:37 UTC 2023 - 22.7K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_assignment.go
numaOrSocketsFirst numaOrSocketsFirstFuncs } func newCPUAccumulator(topo *topology.CPUTopology, availableCPUs cpuset.CPUSet, numCPUs int) *cpuAccumulator { acc := &cpuAccumulator{ topo: topo, details: topo.CPUDetails.KeepOnly(availableCPUs), numCPUsNeeded: numCPUs, result: cpuset.New(), } if topo.NumSockets >= topo.NumNUMANodes { acc.numaOrSocketsFirst = &numaFirst{acc} } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 25 23:56:21 UTC 2024 - 36.3K bytes - Viewed (0) -
pkg/api/storage/util.go
var warnings []string if sc != nil && sc.AllowedTopologies != nil { // use of deprecated node labels in allowedTopologies's matchLabelExpressions for i, topo := range sc.AllowedTopologies { for j, expression := range topo.MatchLabelExpressions { if msg, deprecated := nodeapi.GetNodeLabelDeprecatedMessage(expression.Key); deprecated {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 25 07:15:34 UTC 2022 - 1.5K bytes - Viewed (0)