Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 233 for connectionsOf (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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) ->
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  2. docs/features/connections.md

    In OkHttp some fields of the address come from the URL (scheme, hostname, port) and the rest come from the [OkHttpClient](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-ok-http-client/).
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Feb 21 03:33:59 GMT 2022
    - 5.4K bytes
    - Click Count (0)
  3. 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);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 5.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/graph/StandardNetwork.java

      }
    
      final NetworkConnections<N, E> checkedConnections(N node) {
        NetworkConnections<N, E> connections = nodeConnections.get(node);
        if (connections == null) {
          checkNotNull(node);
          throw new IllegalArgumentException(String.format(NODE_NOT_IN_GRAPH, node));
        }
        return connections;
      }
    
      final N checkedReferenceNode(E edge) {
        N referenceNode = edgeToReferenceNode.get(edge);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 6.9K bytes
    - Click Count (0)
  5. guava/src/com/google/common/graph/StandardNetwork.java

      }
    
      final NetworkConnections<N, E> checkedConnections(N node) {
        NetworkConnections<N, E> connections = nodeConnections.get(node);
        if (connections == null) {
          checkNotNull(node);
          throw new IllegalArgumentException(String.format(NODE_NOT_IN_GRAPH, node));
        }
        return connections;
      }
    
      final N checkedReferenceNode(E edge) {
        N referenceNode = edgeToReferenceNode.get(edge);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 6.9K bytes
    - Click Count (0)
  6. 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) {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 33.4K bytes
    - Click Count (0)
  7. 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>
     *
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Jul 06 02:13:03 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  8. 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() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  9. 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);
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 19.2K bytes
    - Click Count (0)
  10. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 3.7K bytes
    - Click Count (0)
Back to Top