- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for ChannelLoadBalancer (0.38 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)