- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 296 for attempt (0.17 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 May 03 11:42:14 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 May 05 19:28:20 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 May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K 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 May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K 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 May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt
} /** * Returns true if there's another set of routes to attempt. Every address has at least one route. */ operator fun hasNext(): Boolean = hasNextProxy() || postponedRoutes.isNotEmpty() @Throws(IOException::class) operator fun next(): Selection { if (!hasNext()) throw NoSuchElementException() // Compute the next set of routes to attempt. val routes = mutableListOf<Route>() while (hasNextProxy()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
throw IOException("Canceled") } try { response = realChain.proceed(request) newRoutePlanner = true } catch (e: IOException) { // An attempt to communicate with a server failed. The request may have been sent. if (!recover(e, call, request, requestSendStarted = e !is ConnectionShutdownException)) { throw e.withSuppressed(recoveredFailures)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12.1K bytes - Viewed (4) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
val reuseCallConnection = planReuseCallConnection() if (reuseCallConnection != null) return reuseCallConnection // Attempt to get a connection from the pool. val pooled1 = planReusePooledConnection() if (pooled1 != null) return pooled1 // Attempt a deferred plan before new routes. if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Authenticator.kt
* response will be returned to the caller that triggered it. * * Implementations should check if the initial request already included an attempt to * authenticate. If so it is likely that further attempts will not be useful and the authenticator * should give up. * * When reactive authentication is requested by an origin web server, the response code is 401
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/prepare-storage.go
return nil } // connect to list of endpoints and load all Erasure disk formats, validate the formats are correct // and are in quorum, if no formats are found attempt to initialize all of them for the first // time. additionally make sure to close all the disks used in this attempt.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0)