- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 141 for connectionsOf (0.05 sec)
-
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) -
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) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (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> *
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.3K bytes - Viewed (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() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jun 03 17:10:08 UTC 2025 - 4.8K bytes - Viewed (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);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 19.2K bytes - Viewed (0) -
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) -
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) -
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) -
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)