- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for NoAvailableChannelException (0.66 sec)
-
src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java
* @return selected channel * @throws NoAvailableChannelException if no healthy channels available */ public ChannelInfo selectChannel(CommonServerMessageBlock message) throws NoAvailableChannelException { Collection<ChannelInfo> availableChannels = manager.getHealthyChannels(); if (availableChannels.isEmpty()) { throw new NoAvailableChannelException("No healthy channels available"); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 8.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java
ServerMessageBlock2Request mockRequest = mock(ServerMessageBlock2Request.class); when(mockRequest.getTreeId()).thenReturn(123); // Should throw NoAvailableChannelException when no healthy channels assertThrows(ChannelLoadBalancer.NoAvailableChannelException.class, () -> loadBalancer.selectChannel(mockRequest), "Should throw exception when no healthy channels available"); }
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/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java
} @Test void testNoChannelsAvailable() { when(mockChannelManager.getHealthyChannels()).thenReturn(Collections.emptyList()); assertThrows(ChannelLoadBalancer.NoAvailableChannelException.class, () -> loadBalancer.selectChannel(mockMessage)); } @Test void testRoundRobinStrategy() { loadBalancer.setStrategy(LoadBalancingStrategy.ROUND_ROBIN);
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/ChannelFailoverTest.java
void testFailureWithNoAlternativeChannels() throws Exception { failedChannel.addPendingOperation(mockOperation); when(mockLoadBalancer.selectChannel(mockOperation)).thenThrow(new ChannelLoadBalancer.NoAvailableChannelException("No channels")); IOException error = new IOException("Connection failed"); // Should not throw exception even if no alternative channels
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java
fail("Should throw exception when no channels available"); } catch (Exception e) { // Expected - no channels available assertTrue(e instanceof ChannelLoadBalancer.NoAvailableChannelException); } } @Test void testRemoveChannel() throws UnknownHostException { InetAddress addr = InetAddress.getByName("192.168.1.100");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.6K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
public ChannelInfo selectChannel(SMBMessage message) { 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) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 39.6K bytes - Viewed (0)