Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ChannelLoadBalancer (0.12 sec)

  1. src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java

    /**
     * Load balancer for SMB3 Multi-Channel connections
     */
    public class ChannelLoadBalancer {
    
        private final ChannelManager manager;
        private LoadBalancingStrategy strategy;
        private final AtomicInteger roundRobinCounter;
    
        /**
         * Create channel load balancer
         *
         * @param manager channel manager
         */
        public ChannelLoadBalancer(ChannelManager manager) {
            this.manager = manager;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java

        @Mock
        private CommonServerMessageBlock mockMessage;
    
        private ChannelLoadBalancer loadBalancer;
        private ChannelInfo channel1;
        private ChannelInfo channel2;
    
        @BeforeEach
        void setUp() throws UnknownHostException {
            loadBalancer = new ChannelLoadBalancer(mockChannelManager);
    
            InetAddress addr1 = InetAddress.getByName("192.168.1.100");
    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/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java

        }
    
        @Test
        void testLoadBalancingStrategies() throws Exception {
            // Test different load balancing strategies
            ChannelLoadBalancer loadBalancer = new ChannelLoadBalancer(channelManager);
    
            // Test setting different strategies
            LoadBalancingStrategy[] strategies = { LoadBalancingStrategy.ROUND_ROBIN, LoadBalancingStrategy.LEAST_LOADED,
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java

     */
    @ExtendWith(MockitoExtension.class)
    @MockitoSettings(strictness = Strictness.LENIENT)
    class ChannelFailoverTest {
    
        @Mock
        private ChannelManager mockChannelManager;
    
        @Mock
        private ChannelLoadBalancer mockLoadBalancer;
    
        @Mock
        private SmbTransport mockTransport;
    
        @Mock
        private SmbTransport mockNewTransport;
    
        @Mock
        private CommonServerMessageBlock 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)
  5. 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)
Back to top