Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 41 for num_nodes (3.93 sec)

  1. pkg/kubelet/cm/topologymanager/policy_test.go

    			expected: TopologyHint{
    				NUMANodeAffinity: NewTestBitMask(numaNodes...),
    				Preferred:        true,
    			},
    		},
    		{
    			name: "HintProvider returns empty non-nil map[string][]TopologyHint",
    			hp: []HintProvider{
    				&mockHintProvider{
    					map[string][]TopologyHint{},
    				},
    			},
    			expected: TopologyHint{
    				NUMANodeAffinity: NewTestBitMask(numaNodes...),
    				Preferred:        true,
    			},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:08 UTC 2022
    - 34.6K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go

    // candidates returned will never be greater than <numNodes>.
    func (pl *DefaultPreemption) calculateNumCandidates(numNodes int32) int32 {
    	n := (numNodes * pl.args.MinCandidateNodesPercentage) / 100
    	if n < pl.args.MinCandidateNodesAbsolute {
    		n = pl.args.MinCandidateNodesAbsolute
    	}
    	if n > numNodes {
    		n = numNodes
    	}
    	return n
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 25 19:36:04 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/cache/node_tree_test.go

    	expectedNumNodes := int(0)
    	for _, na := range expectedTree {
    		expectedNumNodes += len(na)
    	}
    	if numNodes := nt.numNodes; numNodes != expectedNumNodes {
    		t.Errorf("unexpected nodeTree.numNodes. Expected: %v, Got: %v", expectedNumNodes, numNodes)
    	}
    	if diff := cmp.Diff(expectedTree, nt.tree); diff != "" {
    		t.Errorf("Unexpected node tree (-want, +got):\n%s", diff)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 08:00:25 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  4. pkg/kubelet/apis/podresources/server_v1_test.go

    			Topology:     &podresourcesapi.TopologyInfo{Nodes: []*podresourcesapi.NUMANode{{ID: numaID}}},
    		},
    	}
    
    	cpus := []int64{12, 23, 30}
    
    	memory := []*podresourcesapi.ContainerMemory{
    		{
    			MemoryType: "memory",
    			Size_:      1073741824,
    			Topology:   &podresourcesapi.TopologyInfo{Nodes: []*podresourcesapi.NUMANode{{ID: numaID}}},
    		},
    		{
    			MemoryType: "hugepages-1Gi",
    			Size_:      1073741824,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/manager.go

    	klog.V(2).InfoS("Creating Device Plugin manager", "path", socketPath)
    
    	var numaNodes []int
    	for _, node := range topology {
    		numaNodes = append(numaNodes, node.Id)
    	}
    
    	manager := &ManagerImpl{
    		endpoints: make(map[string]endpointInfo),
    
    		allDevices:            NewResourceDeviceInstances(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/cache/snapshot_test.go

    				"gcr.io/200:v1": sets.New("node-0"),
    			},
    			expected: map[string]*framework.ImageStateSummary{
    				"gcr.io/10:v1": {
    					Size:     int64(10 * mb),
    					NumNodes: 2,
    				},
    				"gcr.io/200:v1": {
    					Size:     int64(200 * mb),
    					NumNodes: 1,
    				},
    			},
    		},
    		{
    			node: &v1.Node{
    				ObjectMeta: metav1.ObjectMeta{Name: "node-0"},
    				Status:     v1.NodeStatus{},
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 08:00:25 UTC 2023
    - 12K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/cache/cache.go

    	snapshot.havePodsWithRequiredAntiAffinityNodeInfoList = make([]*framework.NodeInfo, 0, cache.nodeTree.numNodes)
    	snapshot.usedPVCSet = sets.New[string]()
    	if updateAll {
    		// Take a snapshot of the nodes order in the tree
    		snapshot.nodeInfoList = make([]*framework.NodeInfo, 0, cache.nodeTree.numNodes)
    		nodesList, err := cache.nodeTree.list()
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/volumezone/volume_zone_test.go

    	tests := []struct {
    		Name      string
    		Pod       *v1.Pod
    		NumPV     int
    		NumPVC    int
    		NumNodes  int
    		PreFilter bool
    	}{
    		{
    			Name:      "with prefilter",
    			Pod:       createPodWithVolume("pod_0", "PVC_Stable_0"),
    			NumPV:     1000,
    			NumPVC:    1000,
    			NumNodes:  1000,
    			PreFilter: true,
    		},
    		{
    			Name:      "without prefilter",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 05:17:04 UTC 2023
    - 20K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/memorymanager/policy_static.go

    	var numaNodes []int
    	for n := range machineState {
    		numaNodes = append(numaNodes, n)
    	}
    	sort.Ints(numaNodes)
    
    	// Initialize minAffinitySize to include all NUMA Cells.
    	minAffinitySize := len(numaNodes)
    
    	hints := map[string][]topologymanager.TopologyHint{}
    	bitmask.IterateBitMasks(numaNodes, func(mask bitmask.BitMask) {
    		maskBits := mask.GetBits()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  10. tensorflow/c/kernels_experimental.cc

      // DT_VARIANT tensors must be allocated on CPU since they wrap C++
      // objects which can not be efficiently represented in GPU memory.
      int numa_node = cc_ctx->device()->NumaNode();
      Tensor out(::tensorflow::cpu_allocator(numa_node), ::tensorflow::DT_VARIANT,
                 ::tensorflow::TensorShape({}));
      Variant* out_v = &(out.scalar<Variant>()());
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Apr 23 06:12:29 UTC 2024
    - 30.9K bytes
    - Viewed (0)
Back to top