Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ChannelLoadBalancer (0.38 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/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)
  4. 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)
  5. 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)
  6. docs/smb3-features/03-multi-channel-design.md

        
        manager.addChannel(channel1);
        manager.addChannel(channel2);
        
        // Test load balancer selection
        ChannelLoadBalancer balancer = new ChannelLoadBalancer(manager);
        
        // Large transfer should prefer high-bandwidth channel
        Smb2ReadRequest largeRead = new Smb2ReadRequest();
        largeRead.setLength(10485760);  // 10MB
        
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

        private final List<NetworkInterfaceInfo> localInterfaces;
        private final List<NetworkInterfaceInfo> remoteInterfaces;
        private final ScheduledExecutorService scheduler;
        private final ChannelLoadBalancer loadBalancer;
        private final ChannelFailover failover;
    
        private volatile boolean multiChannelEnabled;
        private final int maxChannels;
        private final AtomicInteger channelCounter;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 20K bytes
    - Viewed (0)
  8. docs/SMB3_IMPLEMENTATION_PLAN.md

    ├── ChannelBinding.java           - Channel binding and security
    ├── ChannelSequence.java          - Request sequencing across channels
    ├── NetworkInterfaceInfo.java     - Network interface discovery
    ├── ChannelLoadBalancer.java      - Load distribution logic
    └── ChannelFailover.java         - Channel failure handling
    ```
    
    #### 3.2 Implementation Tasks
    - [ ] Implement FSCTL_QUERY_NETWORK_INTERFACE_INFO
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 10.7K bytes
    - Viewed (0)
Back to top