Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 420 for attempt (0.18 sec)

  1. 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.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  2. 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))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  3. 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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  4. .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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  5. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

       * proxy server can issue an auth challenge and then close the connection.
       *
       * @return the next plan to attempt, or null if no further attempt should be made either because
       *     we've successfully connected or because no further attempts should be made.
       */
      @Throws(IOException::class)
      internal fun connectTunnel(): ConnectResult {
        val nextTunnelRequest =
          createTunnel()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  7. 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)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  8. 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()) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  9. 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
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 13 15:42:21 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  10. 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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top