Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 3,604 for pcount (0.12 sec)

  1. pkg/scheduler/framework/cycle_state_test.go

    			return false
    		}
    
    		return true
    	})
    
    	if !isEqual {
    		return false, msg
    	}
    
    	countB := 0
    	b.storage.Range(func(k, _ interface{}) bool {
    		countB++
    		return true
    	})
    
    	if countA != countB {
    		return false, fmt.Sprintf("two Cyclestates have different numbers of data. A: %v, B: %v", countA, countB)
    	}
    
    	return true, ""
    }
    
    func TestCycleStateClone(t *testing.T) {
    	tests := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 14 15:26:20 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  2. test/heapsampling.go

    func scaleHeapSample(count, size, rate int64) (int64, int64) {
    	if count == 0 || size == 0 {
    		return 0, 0
    	}
    
    	if rate <= 1 {
    		// if rate==1 all samples were collected so no adjustment is needed.
    		// if rate<1 treat as unknown and skip scaling.
    		return count, size
    	}
    
    	avgSize := float64(size) / float64(count)
    	scale := 1 / (1 - math.Exp(-avgSize/float64(rate)))
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 27 21:36:06 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting_test.go

    	counter.Add(1) // account for unblocking receive on doneCh
    	cancel()
    	time.Sleep(time.Second) // give it a chance to misbehave
    	goGetAndExpect(t, clock, counter, wr, gots, aval)
    }
    
    func goGetExpectNotYet(t *testing.T, clk *testeventclock.Fake, grc counter.GoRoutineCounter, wr promise.WriteOnce, gots chan interface{}, trigger string) {
    	grc.Add(1) // count the following goroutine
    	go func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 10 14:37:53 UTC 2021
    - 4.6K bytes
    - Viewed (0)
  4. src/math/big/ratconv.go

    	// on the actual floating-point value.
    
    	// determine binary or decimal exponent contribution of radix point
    	var exp2, exp5 int64
    	if fcount < 0 {
    		// The mantissa has a radix point ddd.dddd; and
    		// -fcount is the number of digits to the right
    		// of '.'. Adjust relevant exponent accordingly.
    		d := int64(fcount)
    		switch base {
    		case 10:
    			exp5 = d
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 15 22:16:34 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  5. src/cmd/go/testdata/script/test_benchmark_chatty_success.txt

    # Run chatty tests. Assert on CONT lines.
    go test chatty_test.go -v -bench . chatty_bench
    
    # Sanity check that output happens. We don't provide -count because the amount
    # of output is variable.
    stdout 'this is sub-0'
    stdout 'this is sub-1'
    stdout 'this is sub-2'
    
    # Benchmarks should not print CONT.
    ! stdout CONT
    
    -- chatty_test.go --
    package chatty_bench
    
    import (
    	"testing"
    	"fmt"
    )
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 21 18:28:05 UTC 2020
    - 629 bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go

    				}
    				for plName, hr, nCount := cts.popHeldRequest(); hr != nil; plName, hr, nCount = cts.popHeldRequest() {
    					desired := desiredPLNames.Has(plName) || mandPLs[plName] != nil
    					if testDebugLogs {
    						t.Logf("Releasing held request %#+v, desired=%v, plName=%s, count:=%d", hr.rd, desired, plName, nCount)
    					}
    					close(hr.finishCh)
    				}
    				cts.requestWG.Wait()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 18.4K bytes
    - Viewed (0)
  7. tests/associations_many2many_test.go

    	}
    
    	count := 3
    
    	var languages []Language
    	for i := 0; i < count; i++ {
    		language := Language{Code: fmt.Sprintf("consurrent %d", i)}
    		db.Create(&language)
    		languages = append(languages, language)
    	}
    
    	user := User{}
    	db.Create(&user)
    	db.Preload("Languages").FirstOrCreate(&user)
    
    	var wg sync.WaitGroup
    	for i := 0; i < count; i++ {
    		wg.Add(1)
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Sat Jun 10 13:05:19 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  8. pkg/scheduler/internal/heap/heap_test.go

    	if *metricRecorder != 4 {
    		t.Errorf("expected count to be 4 but got %d", *metricRecorder)
    	}
    	if err := h.Delete(mkHeapObj("bar", 1)); err != nil {
    		t.Fatal(err)
    	}
    	if *metricRecorder != 3 {
    		t.Errorf("expected count to be 3 but got %d", *metricRecorder)
    	}
    	if _, err := h.Pop(); err != nil {
    		t.Fatal(err)
    	}
    	if *metricRecorder != 2 {
    		t.Errorf("expected count to be 2 but got %d", *metricRecorder)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 05 02:24:38 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/topologymanager/bitmask/bitmask.go

    // same number of bits are set in both masks, then the mask with more
    // lower-numbered bits set wins out.
    func (s *bitMask) IsNarrowerThan(mask BitMask) bool {
    	if s.Count() == mask.Count() {
    		return s.IsLessThan(mask)
    	}
    	return s.Count() < mask.Count()
    }
    
    // IsLessThan checks which bitmask has more lower-numbered bits set.
    func (s *bitMask) IsLessThan(mask BitMask) bool {
    	return *s < *mask.(*bitMask)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 09:45:09 UTC 2022
    - 5.1K bytes
    - Viewed (0)
  10. pkg/registry/certificates/certificates/storage/metrics.go

    			if !ok {
    				return
    			}
    			issuedCert := newCSR.Status.Certificate
    
    			// new CSR has no issued certificate yet so do not count it.
    			// note that this means that we will ignore CSRs that set a duration
    			// but never get approved/signed.  this is fine because the point
    			// of these metrics is to understand if the duration is honored
    			// by the signer.  we are not checking the behavior of the approver.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 18 21:41:43 UTC 2022
    - 4.9K bytes
    - Viewed (0)
Back to top