Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for getHealthyChannels (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top