- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 350 for waitms (0.11 sec)
-
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
long waitMs = mostRecentEvent + timeout.toMillis() - clock.getCurrentTime(); if (waitMs < 0) { failure = new AssertionError("Timeout waiting request to block."); condition.signalAll(); throw failure; } try { condition.await(waitMs, TimeUnit.MILLISECONDS);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
src/runtime/netpoll_epoll.go
if epfd == -1 { return gList{}, 0 } var waitms int32 if delay < 0 { waitms = -1 } else if delay == 0 { waitms = 0 } else if delay < 1e6 { waitms = 1 } else if delay < 1e15 { waitms = int32(delay / 1e6) } else { // An arbitrary cap on how long to wait for a timer. // 1e9 ms == ~11.5 days. waitms = 1e9 } var events [128]syscall.EpollEvent retry:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 4.6K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java
} while (!handler.isReleased() && !state.isFailed() && !cancelled) { long waitMs = mostRecentEvent + timeoutMs - clock.getCurrentTime(); if (waitMs < 0) { ResponseProducer failure; if (waitingFor > 0) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 14.4K bytes - Viewed (0) -
src/internal/runtime/syscall/syscall_linux.go
} var _zero uintptr func EpollWait(epfd int32, events []EpollEvent, maxev, waitms int32) (n int32, errno uintptr) { var ev unsafe.Pointer if len(events) > 0 { ev = unsafe.Pointer(&events[0]) } else { ev = unsafe.Pointer(&_zero) } r1, _, e := Syscall6(SYS_EPOLL_PWAIT, uintptr(epfd), uintptr(ev), uintptr(maxev), uintptr(waitms), 0, 0) return int32(r1), e }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:26:21 UTC 2024 - 1.4K bytes - Viewed (0) -
src/sync/waitgroup.go
// Now there can't be concurrent mutations of state: // - Adds must not happen concurrently with Wait, // - Wait does not increment waiters if it sees counter == 0. // Still do a cheap sanity check to detect WaitGroup misuse. if wg.state.Load() != state { panic("sync: WaitGroup misuse: Add called concurrently with Wait") } // Reset waiters count to 0. wg.state.Store(0) for ; w != 0; w-- {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
netutil "k8s.io/apimachinery/pkg/util/net" "k8s.io/apimachinery/pkg/util/wait" clientset "k8s.io/client-go/kubernetes" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" "k8s.io/kubernetes/cmd/kubeadm/app/constants" ) // Waiter is an interface for waiting for criteria in Kubernetes to happen type Waiter interface { // WaitForControlPlaneComponents waits for all control plane components to report "ok" on /healthz
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/wait.go
} return nil } func init() { waitCmd.PersistentFlags().IntVar(&timeoutSeconds, "timeoutSeconds", 60, "maximum number of seconds to wait for Envoy to be ready") waitCmd.PersistentFlags().IntVar(&requestTimeoutMillis, "requestTimeoutMillis", 500, "number of milliseconds to wait for response") waitCmd.PersistentFlags().IntVar(&periodMillis, "periodMillis", 500, "number of milliseconds to wait between attempts")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.5K bytes - Viewed (0) -
src/sync/mutex.go
// the unlocking goroutine to the waiter at the front of the queue. // New arriving goroutines don't try to acquire the mutex even if it appears // to be unlocked, and don't try to spin. Instead they queue themselves at // the tail of the wait queue. // // If a waiter receives ownership of the mutex and sees that either // (1) it is the last waiter in the queue, or (2) it waited for less than 1 ms,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
} /** Performs a GAS operation on the {@link #waiters} field. */ @Override Waiter gasWaiters(AbstractFuture<?> future, Waiter update) { while (true) { Waiter waiter = future.waiters; if (update == waiter) { return waiter; } if (casWaiters(future, waiter, update)) { return waiter; } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
/** Non-volatile write of the thread to the {@link Waiter#thread} field. */ abstract void putThread(Waiter waiter, Thread newValue); /** Non-volatile write of the waiter to the {@link Waiter#next} field. */ abstract void putNext(Waiter waiter, @CheckForNull Waiter newValue); /** Performs a CAS operation on the {@link #waiters} field. */ abstract boolean casWaiters(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1)