Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 325 for Connection (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt

     */
    interface Connection {
      /** Returns the route used by this connection. */
      fun route(): Route
    
      /**
       * Returns the socket that this connection is using. Returns an
       * [SSL socket][javax.net.ssl.SSLSocket] if this connection is HTTPS. If this is an HTTP/2
       * connection the socket may be shared by multiple concurrent calls.
       */
      fun socket(): Socket
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. docs/features/connections.md

    address may also share the same underlying TCP socket connection. Sharing a connection has substantial performance benefits: lower latency, higher throughput (due to [TCP slow start](https://www.igvita.com/2011/10/20/faster-web-vs-tcp-slow-start/)) and conserved battery. OkHttp uses a [ConnectionPool](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-connection-pool/) that automatically reuses HTTP/1.x connections and multiplexes HTTP/2 connections.
    
    In OkHttp some fields of the address come...
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectionListener.kt

        connection: Connection,
        route: Route,
        call: Call,
      ) {}
    
      /**
       * Invoked when a connection is released as no longer required.
       */
      open fun connectionClosed(connection: Connection) {}
    
      /**
       * Invoked when a call is assigned a particular connection.
       */
      open fun connectionAcquired(
        connection: Connection,
        call: Call,
      ) {}
    
      /**
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri May 30 21:28:20 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  4. src/main/java/jcifs/SmbTransportPool.java

         * Get transport connection
         *
         * @param tc
         *            context to use
         * @param address the server address
         * @param port the port number
         * @param exclusive
         *            whether to acquire an unshared connection
         * @param forceSigning
         *            whether to enforce SMB signing on this connection
         * @return a transport connection to the target
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  5. docs/contribute/concurrency.md

     * **ExchangeFinder** chooses which connection carries each exchange. Where possible it will use the same connection for all exchanges in a single call. It prefers reusing pooled connections over establishing new connections.      
    
    #### Per-Connection Locks
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcConnectionMonitorTarget.java

    /**
     * HcConnectionMonitorTarget is responsible for monitoring and managing HTTP client connections.
     * It implements the TimeoutTarget interface to handle connection expiration events.
     *
     * <p>This class uses an instance of HttpClientConnectionManager to manage the connections.
     * It closes expired connections and idle connections that have exceeded a specified timeout.
     * </p>
     *
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  7. internal/http/server.go

    	if err != nil {
    		return err
    	}
    
    	// Wait for opened connection to be closed up to Shutdown timeout.
    	return nil
    }
    
    // UseIdleTimeout configure idle connection timeout
    func (srv *Server) UseIdleTimeout(d time.Duration) *Server {
    	srv.IdleTimeout = d
    	return srv
    }
    
    // UseReadTimeout configure connection request read timeout.
    func (srv *Server) UseReadTimeout(d time.Duration) *Server {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt

     * limitations under the License.
     */
    package okhttp3.internal.connection
    
    /**
     * A policy for how the pool should treat a specific address.
     */
    class AddressPolicy(
      /**
       * How many concurrent calls should be possible to make at any time.
       * The pool will routinely try to pre-emptively open connections to satisfy this minimum.
       * Connections will still be closed if they idle beyond the keep-alive but will be replaced.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

              }
            } else {
              exchange.noRequestBody()
              if (!exchange.connection.isMultiplexed) {
                // If the "Expect: 100-continue" expectation wasn't met, prevent the HTTP/1 connection
                // from being reused. Otherwise we're still obligated to transmit the request body to
                // leave the connection in a consistent state.
                exchange.noNewExchangesOnConnection()
              }
            }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Oct 30 13:46:58 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt

       * That may happen later by the connection pool thread.
       */
      fun cancel()
    
      /**
       * Carries an exchange. This is usually a connection, but it could also be a connect plan for
       * CONNECT tunnels. Note that CONNECT tunnels are significantly less capable than connections.
       */
      interface Carrier {
        val route: Route
    
        fun trackFailure(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Jul 29 21:11:09 UTC 2025
    - 3.3K bytes
    - Viewed (0)
Back to top