Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 40 for seenNode (0.3 sec)

  1. pkg/scheduler/testing/framework/framework_helpers.go

    func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo {
    	res := make([]*framework.NodeInfo, len(nodes))
    	for i := 0; i < len(nodes); i++ {
    		res[i] = framework.NewNodeInfo()
    		res[i].SetNode(nodes[i])
    	}
    	return res
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/graph/DirectedGraphConnections.java

              Set<N> seenNodes = new HashSet<>();
              return new AbstractIterator<N>() {
                @Override
                @CheckForNull
                protected N computeNext() {
                  while (nodeConnections.hasNext()) {
                    NodeConnection<N> nodeConnection = nodeConnections.next();
                    boolean added = seenNodes.add(nodeConnection.node);
                    if (added) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 20 17:00:05 UTC 2024
    - 18K bytes
    - Viewed (0)
  3. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerCertificatesTest.kt

        val encoded = CertificateAdapters.time.toDer(decoded)
    
        assertThat(decoded).isEqualTo(date("1949-12-31T23:59:59.000+0000").time)
        assertThat(encoded).isEqualTo(generalizedTimeDer)
      }
    
      @Test
      fun `reencode golden EC certificate`() {
        val certificateByteString =
          (
            "MIIBkjCCATmgAwIBAgIBETAKBggqhkjOPQQDAjAwMRYwFAYDVQQLDA1HZW5lIFJ" +
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 43.9K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/cache/snapshot.go

    	for _, node := range nodes {
    		if _, ok := nodeNameToInfo[node.Name]; !ok {
    			nodeNameToInfo[node.Name] = framework.NewNodeInfo()
    		}
    		nodeInfo := nodeNameToInfo[node.Name]
    		nodeInfo.SetNode(node)
    		nodeInfo.ImageStates = getNodeImageStates(node, imageExistenceMap)
    	}
    	return nodeNameToInfo
    }
    
    func createUsedPVCSet(pods []*v1.Pod) sets.Set[string] {
    	usedPVCSet := sets.New[string]()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  5. src/net/http/httputil/reverseproxy.go

    	errc <- err
    }
    
    func cleanQueryParams(s string) string {
    	reencode := func(s string) string {
    		v, _ := url.ParseQuery(s)
    		return v.Encode()
    	}
    	for i := 0; i < len(s); {
    		switch s[i] {
    		case ';':
    			return reencode(s)
    		case '%':
    			if i+2 >= len(s) || !ishex(s[i+1]) || !ishex(s[i+2]) {
    				return reencode(s)
    			}
    			i += 3
    		default:
    			i++
    		}
    	}
    	return s
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 23:37:42 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  6. 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)
  7. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/resolve/ResolveTestFixture.groovy

                return result
            }
    
            private visitEdges(NodeBuilder node, Set<NodeBuilder> seenNodes, Set<EdgeBuilder> edges) {
                for (EdgeBuilder edge : node.deps) {
                    edges.add(edge)
                    if (seenNodes.add(edge.selected)) {
                        visitEdges(edge.selected, seenNodes, edges)
                    }
                }
            }
    
            /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 37.8K bytes
    - Viewed (0)
  8. pkg/scheduler/eventhandlers_test.go

    			},
    			want: []bool{false, true, false, false},
    		},
    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			nodeInfo := framework.NewNodeInfo(tt.existingPods...)
    			nodeInfo.SetNode(tt.nodeFn())
    			preCheckFn := preCheckForNode(nodeInfo)
    
    			var got []bool
    			for _, pod := range tt.pods {
    				got = append(got, preCheckFn(pod))
    			}
    
    			if diff := cmp.Diff(tt.want, got); diff != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 10 14:38:54 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/nodeports/node_ports_test.go

    			}
    		})
    	}
    }
    
    func TestPreFilterDisabled(t *testing.T) {
    	_, ctx := ktesting.NewTestContext(t)
    	pod := &v1.Pod{}
    	nodeInfo := framework.NewNodeInfo()
    	node := v1.Node{}
    	nodeInfo.SetNode(&node)
    	p, err := New(ctx, nil, nil)
    	if err != nil {
    		t.Fatalf("creating plugin: %v", err)
    	}
    	cycleState := framework.NewCycleState()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 11:02:11 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  10. pkg/kubelet/lifecycle/predicate.go

    			Reason:  "PodOSNotSupported",
    			Message: "Failed to admit pod as the OS field doesn't match node OS",
    		}
    	}
    
    	pods := attrs.OtherPods
    	nodeInfo := schedulerframework.NewNodeInfo(pods...)
    	nodeInfo.SetNode(node)
    
    	// TODO: Remove this after the SidecarContainers feature gate graduates to GA.
    	if !utilfeature.DefaultFeatureGate.Enabled(features.SidecarContainers) {
    		for _, c := range admitPod.Spec.InitContainers {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 00:47:50 UTC 2023
    - 10.9K bytes
    - Viewed (0)
Back to top