Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for We (0.21 sec)

  1. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

       *
       * We get plan0 and plan1 from the route planner.
       * We get plan2 as a follow-up to plan1, typically retry the same IP but different TLS.
       * We get plan3 as a retry of plan0, which was canceled when it lost the race.
       *
       * This test confirms that we prefer to do the TLS follow-up (plan2) before the TCP retry (plan3).
       * It also confirms we enforce the 250 ms delay in each race.
       */
      @Test
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

        lock.assertHeld()
    
        // If this connection is not accepting new exchanges, we're done.
        if (calls.size >= allocationLimit || noNewExchanges) return false
    
        // If the non-host fields of the address don't overlap, we're done.
        if (!this.route.address.equalsNonHost(address)) return false
    
        // If the host exactly matches, we're done: this connection can carry the address.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

          if (retryRoute != null) {
            // Lock in the route because retryRoute() is racy and we don't want to call it twice.
            nextRouteToTry = retryRoute
            return true
          }
        }
    
        // If we have a routes left, use 'em.
        if (routeSelection?.hasNext() == true) return true
    
        // If we haven't initialized the route selector yet, assume it'll have at least one route.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        //     we find them, regardless of what the address policies need.
        //
        //  2. EVICTABLE: Connections not required by any address policy. This matches connections that
        //     don't participate in any policy, plus connections whose policies won't be violated if the
        //     connection is closed. We only close these if the idle connection limit is exceeded.
        //
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

            }
    
            if (errorExceptionToDeliver != null) {
              // We defer throwing the exception until now so that we can refill the connection
              // flow-control window. This is necessary because we don't transmit window updates until
              // the application reads the data. If we throw this prior to updating the connection
              // flow-control window, we risk having it go to 0 preventing the server from sending data.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

         *
         * We need to apply the settings and ack them atomically. This is because some HTTP/2
         * implementations (nghttp2) forbid peers from taking advantage of settings before they have
         * acknowledged! In particular, we shouldn't send frames that assume a new `initialWindowSize`
         * until we send the frame that acknowledges this new size.
         *
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

              return tunnelResult
            }
          }
    
          if (route.address.sslSocketFactory != null) {
            // Assume the server won't send a TLS ServerHello until we send a TLS ClientHello. If
            // that happens, then we will have buffered bytes that are needed by the SSLSocket!
            // This check is imperfect: it doesn't tell us whether a handshake will succeed, just
    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)
  8. cmd/config-current.go

    		if errors.Is(err, kes.ErrNotAllowed) {
    			return // If we don't have permission to compute the HMAC, don't change the cred.
    		}
    		if err != nil {
    			logger.Fatal(err, "Unable to generate root access key using KMS")
    		}
    
    		sKey, err := manager.HMAC(GlobalContext, stat.DefaultKey, []byte("root secret key"))
    		if err != nil {
    			// Here, we must have permission. Otherwise, we would have failed earlier.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 30.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/Equivalence.java

     *
     * <p><b>For users targeting Android API level 24 or higher:</b> This class will eventually
     * implement {@code BiPredicate<T, T>} (as it does in the main Guava artifact), but we currently
     * target a lower API level. In the meantime, if you have support for method references you can use
     * an equivalence as a bi-predicate like this: {@code myEquivalence::equivalent}.
     *
     * @author Bob Lee
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 24 01:41:50 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  10. cmd/endpoint.go

    							endpoints[i].Hostname()), endpoints[i].Hostname(), logger.ErrorKind)
    					}
    
    					continue
    				}
    
    				// return err if not Docker or Kubernetes
    				// We use IsDocker() to check for Docker environment
    				// We use IsKubernetes() to check for Kubernetes environment
    				isLocal, err := isLocalHost(endpoints[i].Hostname(),
    					endpoints[i].Port(),
    					globalMinioPort,
    				)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
Back to top