- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 115 for connectionsOf (0.1 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) -
guava/src/com/google/common/graph/ImmutableGraph.java
for (N node : graph.nodes()) { nodeConnections.put(node, connectionsOf(graph, node)); } return nodeConnections.buildOrThrow(); } @SuppressWarnings("unchecked") private static <N> GraphConnections<N, Presence> connectionsOf(Graph<N> graph, N node) { Function<N, Presence> edgeValueFn =
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 7.2K bytes - Click Count (0) -
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) ->
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) -
guava/src/com/google/common/graph/StandardValueGraph.java
GraphConnections<N, V> connectionsU = nodeConnections.get(nodeU); return (connectionsU != null) && connectionsU.successors().contains(nodeV); } private final @Nullable V edgeValueOrDefaultInternal(N nodeU, N nodeV, @Nullable V defaultValue) { GraphConnections<N, V> connectionsU = nodeConnections.get(nodeU); V value = (connectionsU == null) ? null : connectionsU.value(nodeV);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 07 15:57:03 GMT 2025 - 6K 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/internal/connection/RealConnectionPool.kt
fun closeConnections(now: Long): Long { // Find the longest-idle connections in 2 categories: // // 1. OLD: Connections that have been idle for at least keepAliveDurationNs. We close these if // we find them, regardless of what the address policies need. // // 2. EVICTABLE: Connections not required by any address policy. This matches connections that
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Oct 08 03:50:05 GMT 2025 - 11.1K 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) -
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."),
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 8.4K bytes - Click Count (0) -
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,
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Jun 03 17:10:08 GMT 2025 - 1.3K bytes - Click Count (0)