- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for selectChannel (0.35 sec)
-
src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java
ChannelInfo selected = loadBalancer.selectChannel(mockMessage); assertEquals(channel1, selected); } @Test void testNoChannelsAvailable() { when(mockChannelManager.getHealthyChannels()).thenReturn(Collections.emptyList()); assertThrows(ChannelLoadBalancer.NoAvailableChannelException.class, () -> loadBalancer.selectChannel(mockMessage)); } @Test
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
verify(mockLoadBalancer).selectChannel(mockOperation); verify(alternativeChannel).addPendingOperation(mockOperation); } @Test void testFailureWithNoAlternativeChannels() throws Exception { failedChannel.addPendingOperation(mockOperation);
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/main/java/jcifs/smb/MultiChannelManager.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 20.5K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
} catch (NoSuchAlgorithmException e) { throw new IOException("SHA-256 not available", e); } } public ChannelInfo selectChannel(SMBMessage message) { return loadBalancer.selectChannel(message); } public void handleChannelFailure(ChannelInfo channel, Exception error) { failover.handleFailure(channel, error); }
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/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java
// For now, just test the empty case assertEquals(0, channelManager.getHealthyChannels().size()); } @Test void testChannelSelection() { try { channelManager.selectChannel(mockMessage); fail("Should throw exception when no channels available"); } catch (Exception e) { // Expected - no channels available
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/ChannelManager.java
/** * Select a channel for the given message * * @param message message to send * @return selected channel */ public ChannelInfo selectChannel(CommonServerMessageBlock message) { return loadBalancer.selectChannel(message); } /** * Handle channel failure * * @param channel failed channel * @param error error that caused failure */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java
* * @param message SMB message to send * @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()) {
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
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/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
// Redistribute to healthy channels for (CommonServerMessageBlock op : operationsCopy) { try { ChannelInfo alternativeChannel = manager.getLoadBalancer().selectChannel(op); alternativeChannel.addPendingOperation(op); // Operation would be resent on alternative channel // For now, skip actual send implementation
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 11.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
*/ public SmbTransportImpl selectTransport(CommonServerMessageBlockRequest message) { if (isUseMultiChannel()) { try { ChannelInfo channel = channelManager.selectChannel(message); return (SmbTransportImpl) channel.getTransport(); } catch (Exception e) { log.debug("Multi-channel selection failed, using primary transport", e); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 68.9K bytes - Viewed (0)