Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 706 for _nodes (0.21 sec)

  1. pkg/scheduler/framework/plugins/imagelocality/image_locality_test.go

    			// Node2
    			// Image: not present
    			// Score: 0
    			pod:          &v1.Pod{Spec: test40300},
    			nodes:        []*v1.Node{makeImageNode("node1", node403002000), makeImageNode("node2", node25010)},
    			expectedList: []framework.NodeScore{{Name: "node1", Score: 7}, {Name: "node2", Score: 0}},
    			name:         "two images on one node, prefer this node",
    		},
    		{
    			// Pod: gcr.io/4000 gcr.io/10
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 06:17:57 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  2. src/cmd/compile/internal/ssa/poset.go

    func (po *poset) setchl(i uint32, l posetEdge) { po.nodes[i].l = l }
    func (po *poset) setchr(i uint32, r posetEdge) { po.nodes[i].r = r }
    func (po *poset) chl(i uint32) uint32          { return po.nodes[i].l.Target() }
    func (po *poset) chr(i uint32) uint32          { return po.nodes[i].r.Target() }
    func (po *poset) children(i uint32) (posetEdge, posetEdge) {
    	return po.nodes[i].l, po.nodes[i].r
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 04 17:23:05 UTC 2023
    - 37.2K bytes
    - Viewed (0)
  3. pkg/controller/volume/attachdetach/testing/testvolumespec.go

    		},
    	}
    }
    
    func attachVolumeToNode(nodes *v1.NodeList, volumeName, nodeName string, inUse bool) {
    	// if nodeName exists, get the object.. if not create node object
    	var node *v1.Node
    	for i := range nodes.Items {
    		curNode := &nodes.Items[i]
    		if curNode.ObjectMeta.Name == nodeName {
    			node = curNode
    			break
    		}
    	}
    	if node == nil {
    		nodes.Items = append(nodes.Items, v1.Node{
    			ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 17 08:48:30 UTC 2023
    - 16.5K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/devicemanager/manager.go

    	sort.Slice(nodes, func(i, j int) bool {
    		// If one or the other of nodes[i] or nodes[j] is in the 'hint's affinity set
    		if hint.NUMANodeAffinity.IsSet(nodes[i]) && hint.NUMANodeAffinity.IsSet(nodes[j]) {
    			return perNodeDevices[nodes[i]].Len() < perNodeDevices[nodes[j]].Len()
    		}
    		if hint.NUMANodeAffinity.IsSet(nodes[i]) {
    			return true
    		}
    		if hint.NUMANodeAffinity.IsSet(nodes[j]) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/cadvisor_stats_provider_test.go

    	assert.Equal(imageFsInfo.Capacity, *stats.CapacityBytes)
    	assert.Equal(imageStats.TotalStorageBytes, *stats.UsedBytes)
    	assert.Equal(imageFsInfo.InodesFree, stats.InodesFree)
    	assert.Equal(imageFsInfo.Inodes, stats.Inodes)
    	assert.Equal(*imageFsInfo.Inodes-*imageFsInfo.InodesFree, *stats.InodesUsed)
    }
    
    func TestCadvisorImagesFsStats(t *testing.T) {
    	ctx := context.Background()
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/attach_detach_controller_test.go

    	}
    
    	// Test the ActualStateOfWorld contains all the node volumes
    	nodes, err := adc.nodeLister.List(labels.Everything())
    	if err != nil {
    		t.Fatalf("Failed to list nodes in indexer. Expected: <no error> Actual: %v", err)
    	}
    
    	for _, node := range nodes {
    		nodeName := types.NodeName(node.Name)
    		inUseVolumes := sets.New(node.Status.VolumesInUse...)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  7. pkg/kubelet/apis/podresources/server_v1_test.go

    			DeviceIds:    []string{"dev0", "dev1"},
    			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",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  8. pkg/scheduler/schedule_one.go

    		for i := range nodes {
    			result = append(result, framework.NodePluginScores{
    				Name:       nodes[i].Node().Name,
    				TotalScore: 1,
    			})
    		}
    		return result, nil
    	}
    
    	// Run PreScore plugins.
    	preScoreStatus := fwk.RunPreScorePlugins(ctx, state, pod, nodes)
    	if !preScoreStatus.IsSuccess() {
    		return nil, preScoreStatus.AsError()
    	}
    
    	// Run the Score plugins.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  9. cluster/gce/config-default.sh

    # It is the primary range in the subnet and is the range used for node instance IPs.
    NODE_IP_RANGE="$(get-node-ip-range)"
    export NODE_IP_RANGE
    
    # NOTE: Avoid giving nodes empty scopes, because kubelet needs a service account
    # in order to initialize properly.
    NODE_SCOPES="${NODE_SCOPES:-monitoring,logging-write,storage-ro}"
    
    # Extra docker options for nodes.
    EXTRA_DOCKER_OPTS="${EXTRA_DOCKER_OPTS:-}"
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 20:16:32 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/preemption/preemption_test.go

    				nodeInfos = append(nodeInfos, ni)
    			}
    			nodes, _ := nodesWherePreemptionMightHelp(nodeInfos, tt.nodesStatuses)
    			if len(tt.expected) != len(nodes) {
    				t.Errorf("number of nodes is not the same as expected. exptectd: %d, got: %d. Nodes: %v", len(tt.expected), len(nodes), nodes)
    			}
    			for _, node := range nodes {
    				name := node.Node().Name
    				if _, found := tt.expected[name]; !found {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
Back to top