Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 56 for Wouters (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt

        // Compute the next set of routes to attempt.
        val routes = mutableListOf<Route>()
        while (hasNextProxy()) {
          // Postponed routes are always tried last. For example, if we have 2 proxies and all the
          // routes for proxy1 should be postponed, we'll move to proxy2. Only after we've exhausted
          // all the good routes will we attempt the postponed routes.
          val proxy = nextProxy()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        queue.addListener(listener, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener, 1));
        queue.enqueue(incrementingEvent(counters, listener, 2));
        queue.enqueue(incrementingEvent(counters, listener, 3));
        queue.enqueue(incrementingEvent(counters, listener, 4));
        assertEquals(0, counters.size());
        queue.dispatch();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        queue.addListener(listener, directExecutor());
    
        Multiset<Object> counters = ConcurrentHashMultiset.create();
        queue.enqueue(incrementingEvent(counters, listener, 1));
        queue.enqueue(incrementingEvent(counters, listener, 2));
        queue.enqueue(incrementingEvent(counters, listener, 3));
        queue.enqueue(incrementingEvent(counters, listener, 4));
        assertEquals(0, counters.size());
        queue.dispatch();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/internal/RecordingOkAuthenticator.kt

      val responses = mutableListOf<Response>()
      val routes = mutableListOf<Route>()
    
      fun onlyResponse() = responses.single()
    
      fun onlyRoute() = routes.single()
    
      @Throws(IOException::class)
      override fun authenticate(
        route: Route?,
        response: Response,
      ): Request? {
        if (route == null) throw NullPointerException("route == null")
        responses += response
        routes += route
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        planToReplace: ConnectPlan? = null,
        routes: List<Route>? = null,
      ): ReusePlan? {
        val result =
          connectionPool.callAcquirePooledConnection(
            doExtensiveHealthChecks = connectionUser.doExtensiveHealthChecks(),
            address = address,
            connectionUser = connectionUser,
            routes = routes,
            requireMultiplexed = planToReplace != null && planToReplace.isReady,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 12K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/RouteSelectorTest.kt

        val selection = routeSelector.next()
        dns.assertRequests(uriHost)
        val routes = selection.routes
        assertRoute(routes[0], address, Proxy.NO_PROXY, dns.lookup(uriHost, 0), uriPort)
        assertRoute(routes[1], address, Proxy.NO_PROXY, dns.lookup(uriHost, 1), uriPort)
        assertThat(selection.next()).isSameAs(routes[0])
        assertThat(selection.next()).isSameAs(routes[1])
        assertThat(selection.hasNext()).isFalse()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

          pingIntervalMillis = pingIntervalMillis,
          retryOnConnectionFailure = retryOnConnectionFailure,
          user = user,
          routePlanner = routePlanner,
          route = route,
          routes = routes,
          attempt = attempt,
          tunnelRequest = tunnelRequest,
          connectionSpecIndex = connectionSpecIndex,
          isTlsFallback = isTlsFallback,
        )
    
      override fun connectTcp(): ConnectResult {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

       *
       * If [routes] is non-null these are the resolved routes (ie. IP addresses) for the connection.
       * This is used to coalesce related domains to the same HTTP/2 connection, such as `square.com`
       * and `square.ca`.
       */
      fun callAcquirePooledConnection(
        doExtensiveHealthChecks: Boolean,
        address: Address,
        connectionUser: ConnectionUser,
        routes: List<Route>?,
        requireMultiplexed: Boolean,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/base/CaseFormatTest.java

            .isEqualTo("fooBar");
      }
    
      public void testConverter_nullConversions() {
        for (CaseFormat outer : CaseFormat.values()) {
          for (CaseFormat inner : CaseFormat.values()) {
            assertThat(outer.converterTo(inner).convert(null)).isNull();
            assertThat(outer.converterTo(inner).reverse().convert(null)).isNull();
          }
        }
      }
    
      public void testConverter_toString() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

        // https://daniel.haxx.se/blog/2016/08/18/http2-connection-coalescing/
    
        // 1. This connection must be HTTP/2.
        if (http2Connection == null) return false
    
        // 2. The routes must share an IP address.
        if (routes == null || !routeMatchesAny(routes)) return false
    
        // 3. This connection's server certificates must cover the new host.
        if (address.hostnameVerifier !== OkHostnameVerifier) return false
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
Back to top