Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 111 for connectionsOf (0.06 sec)

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

        //
        //  2. EVICTABLE: Connections not required by any address policy. This matches connections that
        //     don't participate in any policy, plus connections whose policies won't be violated if the
        //     connection is closed. We only close these if the idle connection limit is exceeded.
        //
        // Also count the evictable connections to find out if we must close an EVICTABLE connection
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

            if (!nonPooled) {
                int currentSize = this.connections.size();
                if (currentSize >= maxPoolSize) {
                    // Try to remove idle connections
                    removeIdleConnections();
    
                    // If still at limit, throw exception
                    if (this.connections.size() >= maxPoolSize) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  3. 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: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionPool.kt

      /** Returns the number of idle connections in the pool. */
      fun idleConnectionCount(): Int = delegate.idleConnectionCount()
    
      /** Returns total number of connections in the pool. */
      fun connectionCount(): Int = delegate.connectionCount()
    
      internal val connectionListener: ConnectionListener
        get() = delegate.connectionListener
    
      /** Close and remove all idle connections in the pool. */
      fun evictAll() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb/SmbTransportPoolImplTest.java

            when(address.getHostAddress()).thenReturn("192.168.1.100");
        }
    
        @Test
        @DisplayName("Should distinguish between pooled and non-pooled connections")
        void testPooledVsNonPooledConnections() {
            // When: Create pooled and non-pooled connections
            SmbTransportImpl pooled = pool.getSmbTransport(ctx, address, 445, false);
            SmbTransportImpl nonPooled = pool.getSmbTransport(ctx, address, 445, true);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 19.2K bytes
    - Viewed (0)
  6. cmd/grid.go

    var globalLockGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    var globalLockGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/WinErrorTest.java

                    Arguments.of(WinError.ERROR_ACCESS_DENIED, "Access is denied."),
                    Arguments.of(WinError.ERROR_REQ_NOT_ACCEP,
                            "No more connections can be made to this remote computer at this time because there are already as many connections as the computer can accept."),
                    Arguments.of(WinError.ERROR_BAD_PIPE, "The pipe state is invalid."),
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/AddressPolicy.kt

     */
    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.
       */
      @JvmField val minimumConcurrentCalls: Int = 0,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

            maxIdleConnections = 2,
          )
        val c1 = factory.newConnection(pool, routeA1, 50L)
        val c2 = factory.newConnection(pool, routeB1, 75L)
    
        // With 2 connections, there's no need to evict until the connections time out.
        assertThat(pool.closeConnections(100L)).isEqualTo(50L)
        assertThat(pool.connectionCount()).isEqualTo(2)
        assertThat(c1.socket().isClosed).isFalse()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

         *   increase availability of multi-homed services.
         *
         * * **Stale pooled connections.** The [ConnectionPool] reuses sockets
         *   to decrease request latency, but these connections will occasionally time out.
         *
         * * **Unreachable proxy servers.** A [ProxySelector] can be used to
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
Back to top