- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 130 for timediv (0.6 sec)
-
pkg/kubelet/pluginmanager/reconciler/reconciler_test.go
if plugin.SocketPath == socketPath && plugin.Timestamp.After(previousTimestamp) { return true, nil } } return false, nil }, ) if err != nil { t.Fatalf("Timed out waiting for plugin to be registered:\n%s.", socketPath) } } func waitForUnregistration( t *testing.T, socketPath string, asw cache.ActualStateOfWorld) { err := retryWithExponentialBackOff(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
src/context/x_test.go
n := runtime.Stack(buf, true) t.Fatalf("timed out after %v waiting for <-ctx.Done(); stacks:\n%s", d, buf[:n]) } } // Wait for all the cancel functions to return. done := make(chan struct{}) go func() { wg.Wait() close(done) }() select { case <-done: case <-stuck: buf := make([]byte, 10<<10) n := runtime.Stack(buf, true)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0) -
src/runtime/sys_linux_ppc64x.s
MOVD sevp+8(FP), R4 MOVD timerid+16(FP), R5 SYSCALL $SYS_timer_create MOVW R3, ret+24(FP) RET TEXT runtime·timer_settime(SB),NOSPLIT,$0-28 MOVW timerid+0(FP), R3 MOVW flags+4(FP), R4 MOVD new+8(FP), R5 MOVD old+16(FP), R6 SYSCALL $SYS_timer_settime MOVW R3, ret+24(FP) RET TEXT runtime·timer_delete(SB),NOSPLIT,$0-12 MOVW timerid+0(FP), R3 SYSCALL $SYS_timer_delete
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 18:17:17 UTC 2024 - 18.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
// } public static long SHORT_DELAY_MS; public static long SMALL_DELAY_MS; public static long MEDIUM_DELAY_MS; public static long LONG_DELAY_MS; /** * Returns the shortest timed delay. This could be reimplemented to use for example a Property. */ protected long getShortDelay() { return 50; } /** Sets delays as multiples of SHORT_DELAY. */ protected void setDelays() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
// } public static long SHORT_DELAY_MS; public static long SMALL_DELAY_MS; public static long MEDIUM_DELAY_MS; public static long LONG_DELAY_MS; /** * Returns the shortest timed delay. This could be reimplemented to use for example a Property. */ protected long getShortDelay() { return 50; } /** Sets delays as multiples of SHORT_DELAY. */ protected void setDelays() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
src/runtime/mgcscavenge_test.go
if !s.BlockUntilParked(2e9 /* 2 seconds */) { t.Fatal("timed out waiting for scavenger to run to completion") } // Run a check. verifyScavengerState(t, totalWork) // Now let's do it again and see what happens when we have no work to do. // It should've gone right back to sleep. s.Wake() if !s.BlockUntilParked(2e9 /* 2 seconds */) { t.Fatal("timed out waiting for scavenger to run to completion") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 25.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
defer c.queue.ShutDown() defer klog.Info("Shutting down DiscoveryController") klog.Info("Starting DiscoveryController") if !cache.WaitForCacheSync(stopCh, c.crdsSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // initially sync all group versions to make sure we serve complete discovery if err := wait.PollImmediateUntil(time.Second, func() (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
} } if len(relevantHooks) == 0 { // no matching hooks return nil } // Check if the request has already timed out before spawning remote calls select { case <-ctx.Done(): // parent context is canceled or timed out, no point in continuing return apierrors.NewTimeoutError("request did not complete within requested timeout", 0) default: } wg := sync.WaitGroup{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
src/net/http/responsecontroller_test.go
if err == nil { t.Errorf("client reading from truncated request body: got nil error, want non-nil") } err = <-errc // io.Copy error if !errors.Is(err, os.ErrDeadlineExceeded) { t.Errorf("server timed out writing request body: got err %v; want os.ErrDeadlineExceeded", err) } } func TestResponseControllerSetPastReadDeadline(t *testing.T) { run(t, testResponseControllerSetPastReadDeadline) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 06 19:20:31 UTC 2024 - 10.2K bytes - Viewed (0) -
src/runtime/os_darwin.go
// handler: the sigsend function. The signal handler code does not require // all the features of notes: it does not need to do a timed wait. // This is a separate implementation of notes, based on a pipe, that does // not support timed waits but is async-signal-safe. func sigNoteSetup(*note) { if sigNoteRead != 0 || sigNoteWrite != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 11.9K bytes - Viewed (0)