Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for seenNode (0.25 sec)

  1. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    		t.Run(test.name, func(t *testing.T) {
    			node := v1.Node{Status: v1.NodeStatus{Capacity: makeResources(10, 20, 32, 5, 20, 5), Allocatable: makeAllocatableResources(10, 20, 32, 5, 20, 5)}}
    			test.nodeInfo.SetNode(&node)
    
    			if test.args.ScoringStrategy == nil {
    				test.args.ScoringStrategy = defaultScoringStrategy
    			}
    
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/types.go

    			n.PVCRefCounts[key] += 1
    		} else {
    			n.PVCRefCounts[key] -= 1
    			if n.PVCRefCounts[key] <= 0 {
    				delete(n.PVCRefCounts, key)
    			}
    		}
    	}
    }
    
    // SetNode sets the overall node information.
    func (n *NodeInfo) SetNode(node *v1.Node) {
    	n.node = node
    	n.Allocatable = NewResource(node.Status.Allocatable)
    	n.Generation = nextGeneration()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    		},
    	}
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			nodeInfo := framework.NewNodeInfo()
    			nodeInfo.SetNode(test.node)
    			p, err := New(ctx, nil, nil, feature.Features{})
    			if err != nil {
    				t.Fatalf("creating plugin: %v", err)
    			}
    			gotStatus := p.(framework.FilterPlugin).Filter(ctx, nil, test.pod, nodeInfo)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/noderesources/fit.go

    func isFit(pod *v1.Pod, node *v1.Node) bool {
    	if node == nil {
    		return false
    	}
    	nodeInfo := framework.NewNodeInfo()
    	nodeInfo.SetNode(node)
    	return len(Fits(pod, nodeInfo)) == 0
    }
    
    // Filter invoked at the filter extension point.
    // Checks if a node has sufficient resources, such as cpu, memory, gpu, opaque int resources etc to run a pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/manager_test.go

    				// has no resource1 and two of resource2
    				v1.ResourceName(resourceName2): *resource.NewQuantity(int64(2), resource.DecimalSI),
    			},
    		},
    	}
    	nodeInfo := &schedulerframework.NodeInfo{}
    	nodeInfo.SetNode(cachedNode)
    
    	testManager.UpdatePluginResources(nodeInfo, &lifecycle.PodAdmitAttributes{Pod: pod})
    
    	allocatableScalarResources := nodeInfo.Allocatable.ScalarResources
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  6. src/cmd/go/internal/work/exec.go

    		return true
    	}
    
    	return false
    }
    
    // encodeArg encodes an argument for response file writing.
    func encodeArg(arg string) string {
    	// If there aren't any characters we need to reencode, fastpath out.
    	if !strings.ContainsAny(arg, "\\\n") {
    		return arg
    	}
    	var b strings.Builder
    	for _, r := range arg {
    		switch r {
    		case '\\':
    			b.WriteByte('\\')
    			b.WriteByte('\\')
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 14:46:37 UTC 2024
    - 105.6K bytes
    - Viewed (0)
Back to top