- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 465 for Timeouts (0.21 sec)
-
cmd/dynamic-timeouts.go
// We are hitting the timeout relatively few times, // so decrease the timeout towards 25 % of maximum time spent. max = max * 125 / 100 timeout := atomic.LoadInt64(&dt.timeout) if max < time.Duration(timeout) { // Move 50% toward the max. timeout = (int64(max) + timeout) / 2 } if timeout < dt.minimum { timeout = dt.minimum } atomic.StoreInt64(&dt.timeout, timeout) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
timeout := newDynamicTimeout(time.Minute, time.Second) initial := timeout.Timeout() for i := 0; i < dynamicTimeoutLogSize; i++ { timeout.LogFailure() } adjusted := timeout.Timeout() for i := 0; i < dynamicTimeoutLogSize; i++ { timeout.LogFailure() } adjustedAgain := timeout.Timeout() if initial >= adjusted || adjusted >= adjustedAgain { t.Errorf("Failure to increase timeout multiple times")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 5.4K bytes - Viewed (0) -
internal/dsync/drwmutex.go
drwMutexInfinite = 1<<63 - 1 ) // Timeouts are timeouts for specific operations. type Timeouts struct { // Acquire - tolerance limit to wait for lock acquisition before. Acquire time.Duration // RefreshCall - timeout for the refresh call RefreshCall time.Duration // UnlockCall - timeout for the unlock call UnlockCall time.Duration // ForceUnlockCall - timeout for the force unlock call
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
FUTURE(Timeout.SMALL, Timeout.MAX), SMALL(Timeout.SMALL), FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL), INFINITE(Timeout.LARGE, Timeout.MAX); final ImmutableList<Timeout> timeouts; TimeoutsToUse(Timeout... timeouts) { this.timeouts = ImmutableList.copyOf(timeouts); } } /** Possible outcomes of calling any of the methods under test. */
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 14:48:57 GMT 2023 - 27.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
Future<V> future, long timeout, TimeUnit unit) throws ExecutionException, TimeoutException { boolean interrupted = false; try { long remainingNanos = unit.toNanos(timeout); long end = System.nanoTime() + remainingNanos; while (true) { try { // Future treats negative timeouts just like zero. return future.get(remainingNanos, NANOSECONDS);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 14.4K bytes - Viewed (0) -
internal/dsync/dsync.go
// authenticated clients, used to initiate lock REST calls. type Dsync struct { // List of rest client objects, one per lock server. GetLockers func() ([]NetLocker, string) // Timeouts to apply. Timeouts Timeouts
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 01 19:14:28 GMT 2022 - 1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" } return copy(readTimeoutMillis = checkDuration("readTimeout", timeout.toLong(), unit)) } override fun writeTimeoutMillis(): Int = writeTimeoutMillis override fun withWriteTimeout( timeout: Int, unit: TimeUnit, ): Interceptor.Chain { check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
FUTURE(Timeout.SMALL, Timeout.MAX), SMALL(Timeout.SMALL), FINITE(Timeout.MIN, Timeout.MINUS_SMALL, Timeout.ZERO, Timeout.SMALL), INFINITE(Timeout.LARGE, Timeout.MAX); final ImmutableList<Timeout> timeouts; TimeoutsToUse(Timeout... timeouts) { this.timeouts = ImmutableList.copyOf(timeouts); } } /** Possible outcomes of calling any of the methods under test. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 17 14:48:57 GMT 2023 - 26.1K bytes - Viewed (0) -
doc/next/6-stdlib/99-minor/net/63116.md
The [DNSError] type now wraps errors caused by timeouts or cancellation. For example, `errors.Is(someDNSErr, context.DeadlineExceedeed)`
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Apr 24 13:37:36 GMT 2024 - 198 bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
* Fix: Honor read timeout when parsing SPDY headers. ## Version 1.2.1 _2013-08-23_ * Resolve issue with 'jar-with-dependencies' artifact creation. * Fix: Support empty SPDY header values. ## Version 1.2.0 _2013-08-11_ * New APIs on OkHttpClient to set default timeouts for connect and read. * Fix bug when caching SPDY responses.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 6.4K bytes - Viewed (0)