- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 233 for connectionsOf (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
docs/features/connections.md
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) -
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) -
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) -
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) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
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) -
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) -
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) -
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) -
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)