- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 875 for Millisecond (0.33 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/timing_ratio_histogram_test.go
func exerciseTimingRatioHistogram(t *testing.T, histogramName string, t0 time.Time, clk *testclock.FakePassiveClock, registry compbasemetrics.KubeRegistry, tro RatioedGauge) { samplingPeriod := time.Nanosecond steppingPeriod := time.Millisecond tro.Set(1) // `dt` is the admitted cumulative difference in fake time // since the start of the test. "admitted" means this is // never allowed to decrease, which matches the designed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 13 16:03:06 UTC 2022 - 8.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/expiring_test.go
c := NewExpiringWithClock(fc) c.Set("a", "a", time.Second) fc.Step(500 * time.Millisecond) if _, ok := c.Get("a"); !ok { t.Fatalf("we should have found a key") } fc.Step(time.Second) if _, ok := c.Get("a"); ok { t.Fatalf("we should not have found a key") } c.Set("a", "a", time.Second) fc.Step(500 * time.Millisecond) if _, ok := c.Get("a"); !ok { t.Fatalf("we should have found a key") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 22 15:51:23 UTC 2023 - 7.3K bytes - Viewed (0) -
src/time/tick_test.go
// To avoid flakes due to very long scheduling delays, // require 10 failures in a row before deciding something is wrong. for range 10 { start := Now() c := After(10 * Millisecond) Sleep(500 * Millisecond) dt := (<-c).Sub(start) if dt < 400*Millisecond { return } t.Logf("After(10ms) time is +%v, want <400ms", dt) } t.Errorf("not working") } func TestTickTimes(t *testing.T) { t.Parallel()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
pkg/controller/nodelifecycle/scheduler/rate_limited_queue_test.go
if !value.AddedAt.Equal(time.Unix(0, time.Millisecond.Nanoseconds())) { t.Fatalf("added time for %s is %v", value.Value, value.AddedAt) } case "second": if !value.AddedAt.Equal(time.Unix(0, 2*time.Millisecond.Nanoseconds())) { t.Fatalf("added time for %s is %v", value.Value, value.AddedAt) } if hasQueued { if !value.ProcessAt.Equal(time.Unix(0, 6*time.Millisecond.Nanoseconds())) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 17:40:33 UTC 2023 - 10K bytes - Viewed (0) -
src/net/tcpconn_keepalive_solaris_test.go
} if time.Duration(tcpKeepAliveThreshold)*time.Millisecond != cfg.Idle { t.Fatalf("TCP_KEEPIDLE: got %dms; want %v", tcpKeepAliveThreshold, cfg.Idle) } tcpKeepAliveAbortInterval, err := syscall.GetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPALIVE_ABORT_THRESHOLD) if err != nil { t.Fatal(err) } if time.Duration(tcpKeepAliveAbortInterval)*time.Millisecond != tcpKeepAliveAbortThreshold {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 5.7K bytes - Viewed (0) -
src/net/timeout_test.go
1 * time.Microsecond, 5 * time.Microsecond, 25 * time.Microsecond, 250 * time.Microsecond, 500 * time.Microsecond, 1 * time.Millisecond, 5 * time.Millisecond, 100 * time.Millisecond, 250 * time.Millisecond, 500 * time.Millisecond, 1 * time.Second, } { numRuns := 3 if testing.Short() { numRuns = 1 if timeout > 500*time.Microsecond { continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 18:06:55 UTC 2024 - 30K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator_test.go
if err != nil { t.Fatal(err) } r.addServiceCIDR(cidr) // wait for the cidr to be processed and set the informer synced err = wait.PollUntilContextTimeout(context.Background(), 100*time.Millisecond, 5*time.Second, true, func(ctx context.Context) (bool, error) { allocator, err := r.getAllocator(netutils.ParseIPSloppy("192.168.0.1")) if err != nil { t.Logf("unexpected error %v", err) return false, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 13.7K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
const successTimeout = 20 * time.Second for i := 0; i < dynamicTimeoutLogSize; i++ { rnd := f() duration := time.Duration(float64(successTimeout) * rnd) if duration < 100*time.Millisecond { duration = 100 * time.Millisecond } if duration >= time.Minute { timeout.LogFailure() } else { timeout.LogSuccess(duration) } } } func TestDynamicTimeoutAdjustExponential(t *testing.T) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Oct 14 10:08:40 UTC 2022 - 5.4K bytes - Viewed (0) -
src/net/dial_test.go
{now, now.Add(1900 * time.Millisecond), 999, now.Add(1900 * time.Millisecond), nil}, // Null deadline. {now, noDeadline, 1, noDeadline, nil}, // Step the clock forward and cross the deadline. {now.Add(-1 * time.Millisecond), now, 1, now, nil}, {now.Add(0 * time.Millisecond), now, 1, noDeadline, errTimeout}, {now.Add(1 * time.Millisecond), now, 1, noDeadline, errTimeout}, }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 30.3K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/cgo.go
}() } }() time.Sleep(time.Millisecond) start := time.Now() var times []time.Duration n := 64 if os.Getenv("RUNTIME_TEST_SHORT") != "" { n = 16 } for i := 0; i < n; i++ { go func() { runtime.LockOSThread() select {} }() go func() { runtime.LockOSThread() select {} }() time.Sleep(time.Millisecond) ping <- false select { case <-ping:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 13:20:27 UTC 2017 - 1.8K bytes - Viewed (0)