Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for selector (0.18 sec)

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

        dns[uriHost] = dns.allocate(1)
        var selection = routeSelector.next()
        val route = selection.next()
        routeDatabase.failed(route)
        routeSelector = newRouteSelector(address)
        selection = routeSelector.next()
        assertRoute(selection.next(), address, Proxy.NO_PROXY, dns.lookup(uriHost, 0), uriPort)
        assertThat(selection.hasNext()).isFalse()
        assertFailsWith<NoSuchElementException> {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Mar 06 17:33:38 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

      internal fun connectFailed(
        client: OkHttpClient,
        failedRoute: Route,
        failure: IOException,
      ) {
        // Tell the proxy selector when we fail to connect on a fresh connection.
        if (failedRoute.proxy.type() != Proxy.Type.DIRECT) {
          val address = failedRoute.address
          address.proxySelector.connectFailed(
            address.url.toUri(),
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  3. docs/changelogs/changelog_4x.md

     *  New: Build with Kotlin 1.3.41, BouncyCastle 1.62, and Conscrypt 2.2.1.
     *  Fix: Recover gracefully when a coalesced connection immediately goes unhealthy.
     *  Fix: Defer the `SecurityException` when looking up the default proxy selector.
     *  Fix: Don't use brackets formatting IPv6 host names in MockWebServer.
     *  Fix: Don't permit cache iterators to remove entries that are being written.
    
    
    ## Version 4.0.1
    
    _2019-07-10_
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/EventListener.kt

      /**
       * Invoked after proxy selection.
       *
       * Note that the list of proxies is never null, but it may be a list containing
       * only [Proxy.NO_PROXY]. This comes up in several situations:
       *
       * * If neither a proxy nor proxy selector is configured.
       * * If the proxy is configured explicitly as [Proxy.NO_PROXY].
       * * If the proxy selector returns only [Proxy.NO_PROXY].
       * * If the proxy selector returns an empty list or null.
       *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 15.2K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        // 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.
        val localRouteSelector = routeSelector ?: return true
    
        // If we do have a route selector, use its routes.
        return localRouteSelector.hasNext()
      }
    
      /**
    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)
  6. okhttp/src/test/java/okhttp3/OkHttpClientTest.kt

      private var server: MockWebServer? = null
    
      @BeforeEach fun setUp(server: MockWebServer?) {
        this.server = server
      }
    
      @AfterEach fun tearDown() {
        ProxySelector.setDefault(DEFAULT_PROXY_SELECTOR)
        CookieManager.setDefault(DEFAULT_COOKIE_HANDLER)
        ResponseCache.setDefault(DEFAULT_RESPONSE_CACHE)
      }
    
      @Test fun durationDefaults() {
        val client = clientTestRule.newClient()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

         *
         * ## The buffer
         *
         * In this case the bytes are immediately copied into [sink] and the number of bytes copied is
         * returned.
         *
         * If upstream would be selected but another thread is already reading upstream this will
         * block until that read completes. It is possible to time out while waiting for that.
         */
        @Throws(IOException::class)
        override fun read(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 11.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt

        if (!isRecoverable(e, requestSendStarted)) return false
    
        // No more routes to attempt.
        if (!call.retryAfterFailure()) return false
    
        // For failure recovery, use the same route selector with a new connection.
        return true
      }
    
      private fun requestIsOneShot(
        e: IOException,
        userRequest: Request,
      ): Boolean {
        val requestBody = userRequest.body
    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)
  9. okhttp/src/main/kotlin/okhttp3/Cache.kt

       * (unless they were already returned).
       *
       * The iterator supports [MutableIterator.remove]. Removing a URL from the iterator evicts the
       * corresponding response from the cache. Use this to evict selected responses.
       */
      @Throws(IOException::class)
      fun urls(): MutableIterator<String> {
        return object : MutableIterator<String> {
          private val delegate: MutableIterator<DiskLruCache.Snapshot> = cache.snapshots()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

      vararg args: Any,
    ): String {
      return String.format(Locale.US, format, *args)
    }
    
    @Throws(IOException::class)
    internal fun BufferedSource.readBomAsCharset(default: Charset): Charset {
      return when (select(UNICODE_BOMS)) {
        0 -> UTF_8
        1 -> UTF_16BE
        2 -> UTF_16LE
        3 -> UTF_32BE
        4 -> UTF_32LE
        -1 -> default
        else -> throw AssertionError()
      }
    }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 10.5K bytes
    - Viewed (0)
Back to top