- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 482 for attempt (0.26 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// auth credentials. rawSocket?.closeQuietly() val nextAttempt = attempt + 1 return when { nextAttempt < MAX_TUNNEL_ATTEMPTS -> { user.callConnectEnd(route, null) ConnectResult( plan = this, nextPlan = copy( attempt = nextAttempt, tunnelRequest = nextTunnelRequest, ), ) }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
.github/workflows/multipart/migrate.sh
exit 1 else echo "Outputs are inconsistent. Waiting for $wait_interval seconds (attempt $attempt/$max_wait_attempts)." sleep $wait_interval fi ((attempt++)) done status=$(./mc admin group info site1 site-replication-issue-group --json | jq .groupStatus | tr -d '"') if [[ $status == "enabled" ]]; then echo "Success" else
Shell Script - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 15:54:24 GMT 2024 - 4.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* * 3. Attempt plans from prior connect attempts for this call. These occur as either follow-ups to * failed connect attempts (such as trying the next [ConnectionSpec]), or as attempts that lost * a race in fast follow-up. * * 4. If there's no existing connection, make a list of routes (which may require blocking DNS
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
docs/features/connections.md
With fast fallback, OkHttp attempts to connect to multiple web servers concurrently. It keeps whichever route connects first and cancels all of the others. Its rules are: * Prefer to alternate IP addresses from different address families, (IPv6 / IPv4), starting with IPv6. * Don't start a new attempt until 250 ms after the most recent attempt was started.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Feb 21 03:33:59 GMT 2022 - 5.4K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
} } errChan <- nil }() closer := func() { cmd.Process.Kill() <-errChan } // Dial localhost:3222 to ensure the proxy is ready. delay := time.Second / 4 for attempt := 0; attempt < 5; attempt++ { conn, err := net.DialTimeout("tcp", "localhost:3222", 5*time.Second) if err == nil { conn.Close() return closer, nil } select { case <-time.After(delay): delay *= 2
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
internal/rest/client.go
// Protect against integer overflow panic("unit cannot exceed one hour") } return func(attempt uint) time.Duration { if attempt > 16 { // Protect against integer overflow attempt = 16 } // sleep = random_between(unit, min(cap, base * 2 ** attempt)) sleep := unit * time.Duration(1<<attempt) if sleep > cap { sleep = cap } sleep -= time.Duration(r.Float64() * float64(sleep-unit))
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0) -
cmd/xl-storage_unix_test.go
if err != nil { t.Fatalf("Initializing xlStorage failed with %s.", err) } // Attempt to create a volume to verify the permissions later. // MakeVol creates directory with 0777 perms. if err = disk.MakeVol(context.Background(), testCase.volName); err != nil { t.Fatalf("Creating a volume failed with %s expected to pass.", err) } // Attempt to create a file to verify the permissions later. // AppendFile creates file with 0666 perms.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 3.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
* * <p>If the target method call finishes before the limit is reached, the return value or * exception is propagated to the caller exactly as-is. If, on the other hand, the time limit is * reached, the proxy will attempt to abort the call to the target, and will throw an {@link * UncheckedTimeoutException} to the caller. * * <p>It is important to note that the primary purpose of the proxy object is to return control to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 8.3K bytes - Viewed (0) -
internal/dsync/utils.go
if unit > time.Hour { // Protect against integer overflow panic("unit cannot exceed one hour") } return func(r *rand.Rand, attempt uint) time.Duration { sleep := min sleep += unit * time.Duration(attempt) if sleep > cap { sleep = cap } sleep -= time.Duration(r.Float64() * float64(sleep)) return sleep }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat May 13 15:42:21 GMT 2023 - 1.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
) val call = client.newCall(Request(url)) val response = call.execute() assertThat(response.body.string()).isEqualTo("hello from IPv6") // In the process we made one successful connection attempt. assertThat(listener.recordedEventTypes().filter { it == "ConnectStart" }).hasSize(1) assertThat(listener.recordedEventTypes().filter { it == "ConnectFailed" }).hasSize(0) } @Test
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0)