- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for getHealthyChannels (0.53 sec)
-
src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java
void testSingleChannelSelection() { when(mockChannelManager.getHealthyChannels()).thenReturn(Collections.singletonList(channel1)); ChannelInfo selected = loadBalancer.selectChannel(mockMessage); assertEquals(channel1, selected); } @Test void testNoChannelsAvailable() { when(mockChannelManager.getHealthyChannels()).thenReturn(Collections.emptyList());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 7.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java
manager.initializeMultiChannel(); assertFalse(manager.isUseMultiChannel()); } @Test void testGetHealthyChannels() throws UnknownHostException { assertTrue(channelManager.getHealthyChannels().isEmpty()); // Add a healthy channel manually for testing InetAddress addr = InetAddress.getByName("192.168.1.100"); NetworkInterfaceInfo localInterface = new NetworkInterfaceInfo(addr, 1000);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java
*/ public ChannelInfo selectChannel(CommonServerMessageBlock message) throws NoAvailableChannelException { Collection<ChannelInfo> availableChannels = manager.getHealthyChannels(); if (availableChannels.isEmpty()) { throw new NoAvailableChannelException("No healthy channels available"); } if (availableChannels.size() == 1) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 8.2K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
this.strategy = LoadBalancingStrategy.ADAPTIVE; } public ChannelInfo selectChannel(SMBMessage message) { Collection<ChannelInfo> availableChannels = manager.getHealthyChannels(); if (availableChannels.isEmpty()) { throw new NoAvailableChannelException("No healthy channels available"); } if (availableChannels.size() == 1) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 39.6K bytes - Viewed (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)
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0)