Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for Topo (0.07 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. pkg/kubelet/cm/cpumanager/cpu_manager_test.go

    				testCase.description, testCase.expCPUSet, mgr.state.GetDefaultCPUSet())
    		}
    	}
    }
    
    func TestCPUManagerAddWithInitContainers(t *testing.T) {
    	testCases := []struct {
    		description      string
    		topo             *topology.CPUTopology
    		numReservedCPUs  int
    		initContainerIDs []string
    		containerIDs     []string
    		stAssignments    state.ContainerCPUAssignments
    		stDefaultCPUSet  cpuset.CPUSet
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 42.9K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/container_manager.go

    	var respDevs []*podresourcesapi.ContainerDevices
    
    	for resourceName, resourceDevs := range devs {
    		for devID, dev := range resourceDevs {
    			topo := dev.GetTopology()
    			if topo == nil {
    				// Some device plugin do not report the topology information.
    				// This is legal, so we report the devices anyway,
    				// let the client decide what to do.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:13 UTC 2024
    - 9K bytes
    - Viewed (0)
  8. tensorflow/compiler/jit/deadness_analysis.cc

      }
    
      std::vector<Node*> topo;
      TF_RETURN_IF_ERROR(GetFrameBasedTopologicalOrder(&topo));
    
      size_t frame_start = 0;
      while (frame_start < topo.size()) {
        // Batching nodes who have the same root frame.
        absl::string_view cur_frame_name;
        TF_RETURN_IF_ERROR(
            GetRootFrame(topo[frame_start], control_flow_info_, &cur_frame_name));
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Mar 12 06:33:33 UTC 2024
    - 60.4K bytes
    - Viewed (0)
  9. maven-core/src/main/java/org/apache/maven/project/ProjectSorter.java

         * the set of projects we want to build then add an edge, otherwise throw
         * the edge away because that dependency is not within the set of projects
         * we are trying to build. we assume a closed set.</li>
         * <li>do a topo sort on the graph that remains.</li>
         * </ul>
         * @throws DuplicateProjectException if any projects are duplicated by id
         */
        // MAVENAPI FIXME: the DAG used is NOT only used to represent the dependency relation,
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Fri Sep 22 06:02:04 UTC 2023
    - 10.3K bytes
    - Viewed (0)
  10. docs/pt/docs/fastapi-cli.md

    Em muitos casos você pode ter (e deveria ter) um "proxy de saída" tratando HTTPS no topo, isso dependerá de como você fará o deploy da sua aplicação, seu provedor pode fazer isso pra você ou talvez seja necessário fazer você mesmo.
    
    !!! tip
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Tue Jun 11 23:49:51 UTC 2024
    - 6.4K bytes
    - Viewed (0)
Back to top