Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 100 for leastOf (0.23 sec)

  1. pkg/volume/testing/testing.go

    		actualCallCount := attacher.GetAttachCallCount()
    		if actualCallCount != 0 {
    			return fmt.Errorf(
    				"At least one attacher has non-zero AttachCallCount: <%v>.",
    				actualCallCount)
    		}
    	}
    
    	return nil
    }
    
    // VerifyWaitForAttachCallCount ensures that at least one of the Mounters for
    // this plugin has the expectedWaitForAttachCallCount number of calls. Otherwise
    // it returns an error.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/apps/v1/types.go

    }
    
    type DeploymentConditionType string
    
    // These are valid conditions of a deployment.
    const (
    	// Available means the deployment is available, ie. at least the minimum available
    	// replicas required are up and running for at least minReadySeconds.
    	DeploymentAvailable DeploymentConditionType = "Available"
    	// Progressing means the deployment is progressing. Progress for a deployment is
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 49.1K bytes
    - Viewed (0)
  3. pkg/apis/admissionregistration/validation/validation.go

    		allErrors = append(allErrors, field.Required(fldPath.Child("validations"), "validations or auditAnnotations must contain at least one item"))
    		allErrors = append(allErrors, field.Required(fldPath.Child("auditAnnotations"), "validations or auditAnnotations must contain at least one item"))
    	} else {
    		for i, validation := range spec.Validations {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 56.6K bytes
    - Viewed (0)
  4. pkg/controller/daemon/daemon_controller.go

    	// dsStoreSynced returns true if the daemonset store has been synced at least once.
    	// Added as a member to the struct to allow injection for testing.
    	dsStoreSynced cache.InformerSynced
    	// historyLister get list/get history from the shared informers's store
    	historyLister appslisters.ControllerRevisionLister
    	// historyStoreSynced returns true if the history store has been synced at least once.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  5. src/runtime/pprof/pprof_test.go

    	// We used to always require at least ideal/4 samples,
    	// but that is too hard to guarantee on a loaded system.
    	// Now we accept 10 or more samples, which we take to be
    	// enough to show that at least some profiling is occurring.
    	if ideal := uintptr(duration * 100 / time.Second); samples == 0 || (samples < ideal/4 && samples < 10) {
    		t.Logf("too few samples; got %d, want at least %d, ideally %d", samples, ideal/4, ideal)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  6. src/crypto/tls/conn.go

    		return c.in.setErrorLocked(errors.New("tls: too many ignored records"))
    	}
    	return c.readRecordOrCCS(expectChangeCipherSpec)
    }
    
    // atLeastReader reads from R, stopping with EOF once at least N bytes have been
    // read. It is different from an io.LimitedReader in that it doesn't cut short
    // the last Read call, and in that it considers an early EOF an error.
    type atLeastReader struct {
    	R io.Reader
    	N int64
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  7. tensorflow/compiler/mlir/tensorflow/transforms/sparsecore/embedding_pipelining.cc

                             TF::StatefulPartitionedCallOp& caller) {
      const std::string name = "start_step_0";
    
      AddAssertion(builder, loc, cond_value,
                   "[StartStep0] Auto-pipelining requires at least two steps.");
      auto insertion_point = builder.saveInsertionPoint();
    
      func::FuncOp orig_parent_func =
          callers.backward->getParentOfType<func::FuncOp>();
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  8. src/runtime/mgcscavenge.go

    	// ensure that we scavenge at least minPages each time, aligned
    	// to minPages*pageSize.
    	minPages := physPageSize / pageSize
    	if minPages < 1 {
    		minPages = 1
    	}
    
    	lock(p.mheapLock)
    	if p.summary[len(p.summary)-1][ci].max() >= uint(minPages) {
    		// We only bother looking for a candidate if there at least
    		// minPages free pages at all.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:48:45 UTC 2024
    - 52.3K bytes
    - Viewed (0)
  9. src/runtime/mheap.go

    	// h->mapcache needs no init
    
    	for i := range h.central {
    		h.central[i].mcentral.init(spanClass(i))
    	}
    
    	h.pages.init(&h.lock, &memstats.gcMiscSys, false)
    }
    
    // reclaim sweeps and reclaims at least npage pages into the heap.
    // It is called before allocating npage pages to keep growth in check.
    //
    // reclaim implements the page-reclaimer half of the sweeper.
    //
    // h.lock must NOT be held.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 78K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/validation/validation.go

    	if len(storedVersions) == 0 {
    		return field.ErrorList{field.Invalid(fldPath, storedVersions, "must have at least one stored version")}
    	}
    	allErrs := field.ErrorList{}
    	storedVersionsMap := map[string]int{}
    	for i, v := range storedVersions {
    		storedVersionsMap[v] = i
    	}
    	for _, v := range versions {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 82.6K bytes
    - Viewed (0)
Back to top