- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 3,604 for pcount (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)