Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,460 for connections (0.54 sec)

  1. 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)
  2. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

            }
    
            // Close all connections without synchronization - concurrent collections are thread-safe
            connections.forEach(conn -> {
                try {
                    conn.disconnect(true, true);
                } catch (Exception e) {
                    log.debug("Error closing connection: {}", e.getMessage());
                }
            });
            connections.clear();
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt

     * avoiding these options entirely, this class allows a connection to be attempted with modern
     * options and then retried without them should the attempt fail.
     *
     * ## Connection Reuse
     *
     * Each connection can carry a varying number of streams, depending on the underlying protocol being
     * used. HTTP/1.x connections can carry either zero or one streams. HTTP/2 connections can carry any
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. 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)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

      }
    
      fun put(connection: RealConnection) {
        connection.assertLockHeld()
    
        connections.add(connection)
    //    connection.queueEvent { connectionListener.connectEnd(connection) }
        scheduleCloser()
      }
    
      /**
       * Notify this pool that [connection] has become idle. Returns true if the connection has been
       * removed from the pool and should be closed.
       */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Oct 08 03:50:05 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcConnectionMonitorTarget.java

     * idleConnectionTimeout the timeout duration (in milliseconds) for idle connections
     *
     * <p>Methods:</p>
     * <ul>
     *   <li>{@link #expired()}: Handles the expiration of connections by closing expired and idle connections.</li>
     * </ul>
     *
     * <p>Logging:</p>
     * <ul>
     *   <li>Logs a warning if the clientConnectionManager is null.</li>
     *   <li>Logs a warning if an exception occurs during connection monitoring.</li>
    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. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionPool.kt

    import okhttp3.internal.connection.ConnectionListener
    import okhttp3.internal.connection.RealConnectionPool
    
    /**
     * Manages reuse of HTTP and HTTP/2 connections for reduced network latency. HTTP requests that
     * share the same [Address] may share a [Connection]. This class implements the policy
     * of which connections to keep open for future use.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb/SmbTransportPoolImplTest.java

        @DisplayName("Should close all connections and return in-use status")
        void testCloseAllConnections() throws Exception {
            // Given: Create pooled and non-pooled connections
            SmbTransportImpl pooled = pool.getSmbTransport(ctx, address, 445, false);
            SmbTransportImpl nonPooled = pool.getSmbTransport(ctx, address, 445, true);
    
            // Use reflection to access concurrent collections
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 19.2K bytes
    - Viewed (0)
  9. src/test/java/jcifs/http/NtlmHttpURLConnectionTest.java

            private final List<HttpURLConnection> connections = new ArrayList<>();
            private int currentIndex = 0;
    
            void addConnection(HttpURLConnection conn) {
                connections.add(conn);
            }
    
            @Override
            protected URLConnection openConnection(URL u) throws IOException {
                if (currentIndex < connections.size()) {
                    return connections.get(currentIndex++);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/graph/StandardMutableNetwork.java

        }
    
        if (connectionsU == null) {
          connectionsU = addNodeInternal(nodeU);
        }
        connectionsU.addOutEdge(edge, nodeV);
        NetworkConnections<N, E> connectionsV = nodeConnections.get(nodeV);
        if (connectionsV == null) {
          connectionsV = addNodeInternal(nodeV);
        }
        connectionsV.addInEdge(edge, nodeU, isSelfLoop);
        edgeToReferenceNode.put(edge, nodeU);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top