Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. android/guava/src/com/google/common/graph/ImmutableValueGraph.java

        for (N node : graph.nodes()) {
          nodeConnections.put(node, connectionsOf(graph, node));
        }
        return nodeConnections.buildOrThrow();
      }
    
      private static <N, V> GraphConnections<N, V> connectionsOf(ValueGraph<N, V> graph, N node) {
        Function<N, V> successorNodeToValueFn =
            (N successorNode) ->
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionSpec.kt

        }
    
        fun allEnabledCipherSuites() =
          apply {
            require(tls) { "no cipher suites for cleartext connections" }
            this.cipherSuites = null
          }
    
        fun cipherSuites(vararg cipherSuites: CipherSuite): Builder =
          apply {
            require(tls) { "no cipher suites for cleartext connections" }
            val strings = cipherSuites.map { it.javaName }.toTypedArray()
            return cipherSuites(*strings)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. mkdocs.yml

    plugins:
      - search
      - redirects:
          redirect_maps:
            # Redirect all feature pages to features/*
            'caching.md': 'features/caching.md'
            'calls.md': 'features/calls.md'
            'connections.md': 'features/connections.md'
            'events.md': 'features/events.md'
            'https.md': 'features/events.md'
            'interceptors.md': 'features/interceptors.md'
            'r8_proguard.md': 'features/r8_proguard.md'
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Nov 21 07:19:31 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  9. 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)
  10. android/guava-tests/test/com/google/common/graph/GraphEquivalenceTest.java

      }
    
      // Node/edge sets are the same, but node/edge connections differ due to edge type.
      @Test
      public void equivalent_directedVsUndirected() {
        graph.putEdge(N1, N2);
    
        MutableGraph<Integer> g2 = createGraph(oppositeType(edgeType));
        g2.putEdge(N1, N2);
    
        assertThat(graph).isNotEqualTo(g2);
      }
    
      // Node/edge sets and node/edge connections are the same, but directedness differs.
      @Test
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top