- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for maxDuration (0.27 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/request/webhook_duration_test.go
} if wd.ValidatingWebhookTracker.GetLatency() != tc.MaxDuration { t.Errorf("expected validate duration: %q, but got: %q", tc.MaxDuration, wd.ValidatingWebhookTracker.GetLatency()) } if wd.APFQueueWaitTracker.GetLatency() != tc.MaxDuration { t.Errorf("expected priority & fairness duration: %q, but got: %q", tc.MaxDuration, wd.APFQueueWaitTracker.GetLatency()) } })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 09:15:20 UTC 2023 - 2.4K bytes - Viewed (0) -
cmd/dynamic-timeouts.go
dynamicTimeoutDecreaseThresholdPct = 0.10 // Lower threshold for failures in order to decrease timeout dynamicTimeoutLogSize = 16 maxDuration = math.MaxInt64 maxDynamicTimeout = 24 * time.Hour // Never set timeout bigger than this. ) // timeouts that are dynamically adapted based on actual usage results
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Aug 19 23:21:05 UTC 2022 - 4.5K bytes - Viewed (0) -
samples/ambient-argo/meta-application.yaml
include: application.yaml project: default syncPolicy: automated: prune: true selfHeal: true retry: limit: 2 backoff: duration: 5s maxDuration: 3m0s
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Nov 04 01:54:50 UTC 2023 - 630 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/request/webhook_duration.go
*/ package request import ( "context" "sync" "time" "k8s.io/utils/clock" ) func sumDuration(d1 time.Duration, d2 time.Duration) time.Duration { return d1 + d2 } func maxDuration(d1 time.Duration, d2 time.Duration) time.Duration { if d1 > d2 { return d1 } return d2 } // DurationTracker is a simple interface for tracking functions duration,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 22:15:37 UTC 2024 - 11.5K bytes - Viewed (0) -
src/time/time_test.go
want Duration }{ {0, 0}, {1, 1}, {-1, 1}, {1 * Minute, 1 * Minute}, {-1 * Minute, 1 * Minute}, {minDuration, maxDuration}, {minDuration + 1, maxDuration}, {minDuration + 2, maxDuration - 1}, {maxDuration, maxDuration}, {maxDuration - 1, maxDuration - 1}, } func TestDurationAbs(t *testing.T) { for _, tt := range durationAbsTests { if got := tt.d.Abs(); got != tt.want {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:13:47 UTC 2024 - 56.5K bytes - Viewed (0) -
src/time/sleep_test.go
// but without slowing down fast machines unnecessarily. // // (maxDuration is several orders of magnitude longer than we // expect this test to actually take on a fast, unloaded machine.) d := 1 * Millisecond const maxDuration = 10 * Second for { err := testReset(d) if err == nil { break } d *= 2 if d > maxDuration { t.Error(err) } t.Logf("%v; trying duration %v", err, d) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 16:33:57 UTC 2024 - 22.5K bytes - Viewed (0) -
src/runtime/proc_test.go
// wait until all goroutines have finished. for g := 0; g < nroutines; g++ { <-c } duration := time.Since(start) if duration > maxDuration { t.Errorf("timeout exceeded: %v (%v)", duration, maxDuration) } } } func TestPreemptionAfterSyscall(t *testing.T) { if runtime.GOOS == "plan9" { testenv.SkipFlaky(t, 41015) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.8K bytes - Viewed (0) -
src/time/mono_test.go
t.Errorf("Until(Now().Add(-30s)) = %v, want roughly 30s (25s to 30s)", d) } t0 := Now() t1 = t0.Add(Duration(1<<63 - 1)) if GetMono(&t1) != 0 { t.Errorf("Now().Add(maxDuration) has monotonic clock reading (%v => %v %d %d)", t0.String(), t1.String(), t0.Unix(), t1.Unix()) } t2 := t1.Add(-Duration(1<<63 - 1)) d = Since(t2) if d < -10*Second || 10*Second < d {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 19 17:10:49 UTC 2022 - 8.3K bytes - Viewed (0) -
src/time/time.go
return d - r } if d1 := d + m - r; d1 > d { return d1 } return maxDuration // overflow } // Abs returns the absolute value of d. // As a special case, [math.MinInt64] is converted to [math.MaxInt64]. func (d Duration) Abs() Duration { switch { case d >= 0: return d case d == minDuration: return maxDuration default: return -d } } // Add returns the time t+d.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 50.7K bytes - Viewed (0) -
pkg/kubelet/config/mux_test.go
channelOne := mux.ChannelWithContext(ctx, "one") if channelOne != mux.ChannelWithContext(ctx, "one") { t.Error("Didn't get the same muxuration channel back with the same name") } channelTwo := mux.ChannelWithContext(ctx, "two") if channelOne == channelTwo { t.Error("Got back the same muxuration channel for different names") } } type MergeMock struct { source string update interface{} t *testing.T }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 20:02:23 UTC 2024 - 2.5K bytes - Viewed (0)