Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 72 for connect (0.21 sec)

  1. 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)
  2. docs/features/connections.md

     2. It attempts to retrieve a connection with that address from the **connection pool**.
     3. If it doesn't find a connection in the pool, it selects a **route** to attempt. This usually means making a DNS request to get the server's IP addresses. It then selects a TLS version and proxy server if necessary.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Feb 21 03:33:59 GMT 2022
    - 5.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

    import okio.BufferedSource
    import okio.buffer
    import okio.sink
    import okio.source
    
    /**
     * A single attempt to connect to a remote server, including these steps:
     *
     *  * [TCP handshake][connectSocket]
     *  * Optional [CONNECT tunnels][connectTunnel]. When using an HTTP proxy to reach an HTTPS server
     *    we must send a `CONNECT` request, and handle authorization challenges from the proxy.
     *  * Optional [TLS handshake][connectTls].
     *
    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)
  4. okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt

            }
            else -> {
              events += "plan $id TCP connected"
              connectState = ConnectState.TCP_CONNECTED
              ConnectResult(this)
            }
          }
        }
    
        override fun connectTlsEtc(): ConnectResult {
          check(connectState == ConnectState.TCP_CONNECTED)
          events += "plan $id TLS connecting..."
    
          taskFaker.sleep(tlsConnectDelayNanos)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  5. docs/changelogs/changelog_4x.md

        two addresses are encoded differently, such as `192.168.1.1` and `0::0:0:FFFF:C0A8:101`. Note
        that OkHttp incorrectly rejected valid certificates resulting in a failure to connect; at no
        point were invalid certificates accepted.
     *  New: `OkHttpClient.Builder.minWebSocketMessageToCompress()` configures a threshold for
    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)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        val connect = planConnect()
    
        // Now that we have a set of IP addresses, make another attempt at getting a connection from
        // the pool. We have a better chance of matching thanks to connection coalescing.
        val pooled2 = planReusePooledConnection(connect, connect.routes)
        if (pooled2 != null) return pooled2
    
        return connect
      }
    
      /**
    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)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt

        delegate!!.bind(localAddr)
      }
    
      @Throws(IOException::class)
      override fun connect(remoteAddr: SocketAddress) {
        delegate!!.connect(remoteAddr)
      }
    
      @Throws(IOException::class)
      override fun connect(
        remoteAddr: SocketAddress,
        timeout: Int,
      ) {
        delegate!!.connect(remoteAddr, timeout)
      }
    
      override fun isInputShutdown(): Boolean {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/SpecificHostSocketFactory.kt

        return object : Socket() {
          override fun connect(
            endpoint: SocketAddress?,
            timeout: Int,
          ) {
            val requested = (endpoint as InetSocketAddress)
            val inetSocketAddress = hostMapping[requested.address] ?: defaultAddress ?: requested
            Platform.get().log("Socket connection to: $inetSocketAddress was: $requested")
            super.connect(inetSocketAddress, timeout)
          }
        }
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/UtilTest.kt

    class UtilTest {
      @Test
      fun socketIsHealthy() {
        val localhost = InetAddress.getLoopbackAddress()
        val serverSocket = ServerSocket(0, 1, localhost)
    
        val socket = Socket()
        socket.connect(serverSocket.localSocketAddress)
        val socketSource = socket.source().buffer()
    
        assertThat(socket.isHealthy(socketSource)).isTrue()
    
        serverSocket.close()
        assertThat(socket.isHealthy(socketSource)).isFalse()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *     possible for shared exchanges to make requests to different host names! See
     *     [RealConnection.isEligible] for details.
     *
     *  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.
     *
    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)
Back to top