Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 136 for happen (0.16 sec)

  1. src/reflect/all_test.go

    			}
    		}
    
    		// Blocking recv.
    		if x.Maybe() {
    			ch, val := newop(len(cases), 0)
    			cases = append(cases, SelectCase{
    				Dir:  SelectRecv,
    				Chan: ch,
    			})
    			// Let it execute?
    			if x.Maybe() {
    				f := func() { ch.Send(val) }
    				info = append(info, caseInfo{desc: "blocking recv", recv: val, helper: f})
    			} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 218.8K bytes
    - Viewed (0)
  2. pkg/kubelet/eviction/eviction_manager_test.go

    	vol := newVolume("local-volume", v1.VolumeSource{
    		EmptyDir: &v1.EmptyDirVolumeSource{
    			SizeLimit: resource.NewQuantity(requests.Memory().Value(), resource.BinarySI),
    		},
    	})
    	var vols []v1.Volume
    	vols = append(vols, vol)
    	pod := newPod(name, priority, []v1.Container{
    		newContainer(name, requests, limits),
    	}, vols)
    
    	var podStats statsapi.PodStats
    	switch name {
    	case "empty-dir":
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  3. pkg/config/validation/validation.go

    	if len(rule.Issuer) == 0 {
    		errs = multierror.Append(errs, errors.New("issuer must be set"))
    	}
    	for _, audience := range rule.Audiences {
    		if len(audience) == 0 {
    			errs = multierror.Append(errs, errors.New("audience must be non-empty string"))
    		}
    	}
    
    	if len(rule.JwksUri) != 0 {
    		if _, err := security.ParseJwksURI(rule.JwksUri); err != nil {
    			errs = multierror.Append(errs, err)
    		}
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:33 UTC 2024
    - 107.2K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/runtime/framework_test.go

    		r[bindPlugin] = newBindPlugin
    	}
    
    	if len(profile.Plugins.QueueSort.Enabled) == 0 {
    		profile.Plugins.QueueSort.Enabled = append(profile.Plugins.QueueSort.Enabled, config.Plugin{Name: queueSortPlugin})
    	}
    	if len(profile.Plugins.Bind.Enabled) == 0 {
    		profile.Plugins.Bind.Enabled = append(profile.Plugins.Bind.Enabled, config.Plugin{Name: bindPlugin})
    	}
    	return NewFramework(ctx, r, &profile, opts...)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  5. pkg/scheduler/internal/queue/scheduling_queue_test.go

    			}
    			err = q.AddUnschedulableIfNotPresent(logger, podInfo, int64(i))
    			if err != nil {
    				t.Fatalf("unexpected error from AddUnschedulableIfNotPresent: %v", err)
    			}
    
    			// An event happens.
    			q.MoveAllToActiveOrBackoffQueue(logger, UnschedulableTimeout, nil, nil, nil)
    
    			if _, ok, _ := q.podBackoffQ.Get(podInfo); !ok {
    				t.Errorf("pod %v is not in the backoff queue", podID)
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/admissionregistration/v1/generated.pb.go

    			}
    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			m.ResourceRules = append(m.ResourceRules, NamedRuleWithOperations{})
    			if err := m.ResourceRules[len(m.ResourceRules)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 4:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 200.5K bytes
    - Viewed (0)
  7. tensorflow/compiler/mlir/lite/stablehlo/transforms/legalize_hlo.cc

    // Appends all elements in `range` to `values`.
    template <typename ValueT, typename Range>
    void Append(llvm::SmallVectorImpl<ValueT>& values, Range&& range) {
      values.insert(values.end(), range.begin(), range.end());
    }
    
    // Appends all elements in `range` to `values`.
    template <typename ValueT, typename Range, typename... RangeTs>
    void Append(llvm::SmallVectorImpl<ValueT>& values, Range&& range,
                RangeTs&&... ranges) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 154.9K bytes
    - Viewed (0)
  8. pkg/scheduler/schedule_one_test.go

    		nodeName := fmt.Sprintf("node%d", i)
    		initialNodes = append(initialNodes, st.MakeNode().Name(nodeName).UID(nodeName).Obj())
    	}
    	// Randomly scatter initial pods onto nodes.
    	for i := 0; i < initialPodNumber; i++ {
    		podName := fmt.Sprintf("scheduled-pod%d", i)
    		assignedNodeName := fmt.Sprintf("node%d", random.Intn(initialNodeNumber))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/admissionregistration/v1beta1/generated.pb.go

    			}
    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			m.ResourceRules = append(m.ResourceRules, NamedRuleWithOperations{})
    			if err := m.ResourceRules[len(m.ResourceRules)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 4:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 187.9K bytes
    - Viewed (0)
  10. pkg/controller/podautoscaler/horizontal_test.go

    						Name: "qps",
    					},
    					Value: *resource.NewMilliQuantity(int64(level), resource.DecimalSI),
    				}
    				metrics.Items = append(metrics.Items, podMetric)
    			}
    
    			return true, metrics, nil
    		}
    
    		name := getForAction.GetName()
    		mapper := testrestmapper.TestOnlyStaticRESTMapper(legacyscheme.Scheme)
    		metrics := &cmapi.MetricValueList{}
    		var matchedTarget *autoscalingv2.MetricSpec
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 199.3K bytes
    - Viewed (0)
Back to top