Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ADAPTIVE (0.9 sec)

  1. src/test/java/jcifs/config/MultiChannelConfigurationTest.java

            assertEquals(1, config.getChannelBindingPolicy(), "Default binding policy should be preferred");
            assertEquals("adaptive", config.getLoadBalancingStrategy(), "Default strategy should be adaptive");
            assertEquals(10, config.getChannelHealthCheckInterval(), "Default health check interval should be 10");
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java

            }
        }
    
        @Test
        void testAdaptiveStrategyLargeTransfer() throws Exception {
            loadBalancer.setStrategy(LoadBalancingStrategy.ADAPTIVE);
    
            Smb2ReadRequest largeRead = mock(Smb2ReadRequest.class);
            when(largeRead.getReadLength()).thenReturn(2 * 1024 * 1024); // 2MB
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/multichannel/LoadBalancingStrategy.java

         */
        WEIGHTED_RANDOM,
    
        /**
         * Affinity-based selection for related operations
         */
        AFFINITY_BASED,
    
        /**
         * Adaptive selection based on operation type and performance
         */
        ADAPTIVE
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java

         *
         * @param manager channel manager
         */
        public ChannelLoadBalancer(ChannelManager manager) {
            this.manager = manager;
            this.strategy = LoadBalancingStrategy.ADAPTIVE;
            this.roundRobinCounter = new AtomicInteger(0);
        }
    
        /**
         * Get current load balancing strategy
         *
         * @return current strategy
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java

            props.setProperty("jcifs.smb.client.useMultiChannel", "true");
            props.setProperty("jcifs.smb.client.maxChannels", "4");
            props.setProperty("jcifs.smb.client.loadBalancingStrategy", "adaptive");
            props.setProperty("jcifs.smb.client.channelHealthCheckInterval", "5");
    
            multiConfig = new PropertyConfiguration(props);
    
            // Mock context and session for ChannelManager
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java

            when(mockConfig.getMaxChannels()).thenReturn(4);
            when(mockConfig.getChannelBindingPolicy()).thenReturn(1); // preferred
            when(mockConfig.getLoadBalancingStrategy()).thenReturn("adaptive");
            when(mockConfig.getChannelHealthCheckInterval()).thenReturn(10);
    
            channelManager = new ChannelManager(mockContext, mockSession);
        }
    
        @Test
        void testConstructor() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 7.6K bytes
    - Viewed (0)
Back to top