- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for isHealthy (0.08 sec)
-
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() {Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 20.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java
assertFalse(channelInfo.isHealthy()); channelInfo.setState(ChannelState.ESTABLISHED); assertEquals(ChannelState.ESTABLISHED, channelInfo.getState()); assertTrue(channelInfo.isHealthy()); channelInfo.setState(ChannelState.ACTIVE); assertTrue(channelInfo.isHealthy()); channelInfo.setState(ChannelState.FAILED);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java
assertEquals(localNic, channel.getLocalInterface()); assertEquals(remoteNic, channel.getRemoteInterface()); assertEquals(ChannelState.ESTABLISHED, channel.getState()); assertTrue(channel.isHealthy()); // Test metrics channel.incrementRequestsSent(); channel.addBytesSent(1024); channel.updateActivity(); assertEquals(1, channel.getRequestsSent());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 8.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java
return System.currentTimeMillis() - lastActivityTime; } /** * Check if channel is in healthy state * * @return true if healthy */ public boolean isHealthy() { return state == ChannelState.ACTIVE || state == ChannelState.ESTABLISHED; } /** * Get channel binding hash * * @return binding hash bytes */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 10.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
* * @return collection of healthy channels */ public Collection<ChannelInfo> getHealthyChannels() { return channels.values() .stream() .filter(ChannelInfo::isHealthy) .collect(ArrayList::new, (list, item) -> list.add(item), (list1, list2) -> list1.addAll(list2)); } /** * Select a channel for the given message *Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
this.lastActivityTime = System.currentTimeMillis(); } public long getIdleTime() { return System.currentTimeMillis() - lastActivityTime; } public boolean isHealthy() { return state == ChannelState.ACTIVE || state == ChannelState.ESTABLISHED; } public double getErrorRate() { long total = requestsSent.get(); if (total == 0) return 0.0;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 39.6K bytes - Viewed (0)