Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for Topo (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top