- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 495 for DELAY (0.04 sec)
-
pkg/kubelet/nodeshutdown/systemd/inhibit_linux_test.go
"org.freedesktop.login1.Manager.InhibitDelayMaxUSec": uint64(thirtySeconds / time.Microsecond), }, }, }, } delay, err := bus.CurrentInhibitDelay() assert.NoError(t, err) assert.Equal(t, thirtySeconds, delay) } func TestInhibitShutdown(t *testing.T) { var fakeFd uint32 = 42 bus := DBusCon{ SystemBus: &fakeSystemDBus{ fakeDBusObject: &fakeDBusObject{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 19:50:06 UTC 2023 - 4.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
notifyStopped(); } } /* * A NoOp service that will delay the startup and shutdown notification for a configurable amount * of time. */ private static class NoOpDelayedService extends NoOpService { private long delay; public NoOpDelayedService(long delay) { this.delay = delay; } @Override protected void doStart() { new Thread() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 02 17:20:27 UTC 2023 - 23.2K bytes - Viewed (0) -
src/runtime/retry.go
// license that can be found in the LICENSE file. //go:build unix package runtime // retryOnEAGAIN retries a function until it does not return EAGAIN. // It will use an increasing delay between calls, and retry up to 20 times. // The function argument is expected to return an errno value, // and retryOnEAGAIN will return any errno value other than EAGAIN.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 10 20:44:45 UTC 2022 - 760 bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
crawlerContext.intervalController.delay(IntervalController.NO_URL_IN_QUEUE); } threadCheckCount++; } // interval if (crawlerContext.intervalController != null) { crawlerContext.intervalController.delay(IntervalController.WAIT_NEW_URL); } }
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 15.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go
lifecycle of the apiserver. We also identify each event with a name so we can refer to it. Events: - ShutdownInitiated: KILL signal received - AfterShutdownDelayDuration: shutdown delay duration has passed - InFlightRequestsDrained: all in flight request(s) have been drained - HasBeenReady is signaled when the readyz endpoint succeeds for the first time
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop.go
// true, or the condition returns an error. If sliding is true, the period is computed // after condition runs. If it is false then period includes the runtime for condition. // If immediate is false the first delay happens before any call to condition, if // immediate is true the condition will be invoked before waiting and guarantees that // the condition is invoked at least once, regardless of whether the context has been
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:47:00 UTC 2023 - 2.8K bytes - Viewed (0) -
src/net/http/httputil/dump_test.go
timeout = time.Until(deadline) timeout -= time.Second * 2 // Leave 2 seconds to report failures. } for i := 0; i < 1000; i++ { delay := time.Duration(rand.Intn(5)) * time.Millisecond ctx, cancel := context.WithTimeout(context.Background(), delay) defer cancel() r := bytes.NewBuffer(make([]byte, 10000)) req, err := http.NewRequestWithContext(ctx, http.MethodPost, "http://example.com", r)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 17:34:07 UTC 2022 - 12.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
notifyStopped(); } } /* * A NoOp service that will delay the startup and shutdown notification for a configurable amount * of time. */ private static class NoOpDelayedService extends NoOpService { private long delay; public NoOpDelayedService(long delay) { this.delay = delay; } @Override protected void doStart() { new Thread() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Oct 02 17:20:27 UTC 2023 - 23.9K bytes - Viewed (0) -
cmd/batch-expire.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 13:50:53 UTC 2024 - 21.1K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_internal_test.go
func TestTranslateFault(t *testing.T) { cases := []struct { name string fault *networking.HTTPFaultInjection want *xdshttpfault.HTTPFault }{ { name: "http delay", fault: &networking.HTTPFaultInjection{ Delay: &networking.HTTPFaultInjection_Delay{ HttpDelayType: &networking.HTTPFaultInjection_Delay_FixedDelay{ FixedDelay: &durationpb.Duration{ Seconds: int64(3), },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 11 02:47:57 UTC 2024 - 18.2K bytes - Viewed (0)