- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 36 for healthy (0.08 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
// Make sure this connection is healthy & eligible for new exchanges. If it's no longer needed // then we're on the hook to close it. val healthy = candidate.isHealthy(doExtensiveHealthChecks) var noNewExchangesEvent = false val toClose: Socket? = candidate.withLock { when { !healthy -> { noNewExchangesEvent = !candidate.noNewExchangesCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
* This is for covering a case where the ServiceManager would behave strangely if constructed with * no service under management. Listeners would never fire because the ServiceManager was healthy * and stopped at the same time. This test ensures that listeners fire and isHealthy makes sense. */ public void testEmptyServiceManager() { Logger logger = Logger.getLogger(ServiceManager.class.getName()); logger.setLevel(Level.FINEST);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
public void decrementConnections() { activeConnections.decrementAndGet(); } public boolean isHealthy() { return isHealthy; } public void setHealthy(boolean healthy) { this.isHealthy = healthy; this.lastHealthCheck = System.currentTimeMillis(); } public long getLastHealthCheck() {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 20.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt
} } private fun makeSimpleCall() { server.enqueue(MockResponse(body = "healthy")) val callB = client.newCall(Request(server.url("/"))) callB.execute().use { response -> assertThat(response.body.string()).isEqualTo("healthy") } } private fun enableProtocol(protocol: Protocol) { enableTls() client = client
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 11:54:15 GMT 2026 - 10.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
true } } } if (!acquired) continue // Confirm the connection is healthy and return it. if (connection.isHealthy(doExtensiveHealthChecks)) return connection // In the second synchronized block, release the unhealthy acquired connection. We're also on // the hook to close this connection if it's no longer in use. val noNewExchangesEvent: BooleanCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 11.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
* This is for covering a case where the ServiceManager would behave strangely if constructed with * no service under management. Listeners would never fire because the ServiceManager was healthy * and stopped at the same time. This test ensures that listeners fire and isHealthy makes sense. */ public void testEmptyServiceManager() { Logger logger = Logger.getLogger(ServiceManager.class.getName()); logger.setLevel(Level.FINEST);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 25.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
return channels.values(); } /** * Get healthy channels only * * @return collection of healthy channels */ public Collection<ChannelInfo> getHealthyChannels() { return channels.values() .stream() .filter(ChannelInfo::isHealthy)
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 20K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt
}.also { expected -> assertThat(expected).hasMessage("timeout") } } /** * This test reproduces a crash where OkHttp attempted to use a deferred connection when the call * already had a healthy connection. It sets up a deferred connection by stalling the IPv6 * connect, and it sets up a same-connection retry with [ErrorCode.REFUSED_STREAM]. * * https://github.com/square/okhttp/pull/7190 */ @TestCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 10.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
List<CommonServerMessageBlock> operationsCopy = List.copyOf(pendingOps); // Clear the failed channel's pending operations first failedChannel.clearPendingOperations(); // Redistribute to healthy channels for (CommonServerMessageBlock op : operationsCopy) { try { ChannelInfo alternativeChannel = manager.getLoadBalancer().selectChannel(op);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 11.6K bytes - Click Count (0) -
docs/smb3-features/03-multi-channel-design.md
Collection<ChannelInfo> availableChannels = manager.getHealthyChannels(); if (availableChannels.isEmpty()) { throw new NoAvailableChannelException("No healthy channels available"); } if (availableChannels.size() == 1) { return availableChannels.iterator().next(); } switch (strategy) {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 39.6K bytes - Click Count (0)