Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for selectChannel (0.35 sec)

  1. src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java

            ChannelInfo selected = loadBalancer.selectChannel(mockMessage);
            assertEquals(channel1, selected);
        }
    
        @Test
        void testNoChannelsAvailable() {
            when(mockChannelManager.getHealthyChannels()).thenReturn(Collections.emptyList());
    
            assertThrows(ChannelLoadBalancer.NoAvailableChannelException.class, () -> loadBalancer.selectChannel(mockMessage));
        }
    
        @Test
    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/ChannelFailoverTest.java

            verify(mockLoadBalancer).selectChannel(mockOperation);
            verify(alternativeChannel).addPendingOperation(mockOperation);
        }
    
        @Test
        void testFailureWithNoAlternativeChannels() throws Exception {
            failedChannel.addPendingOperation(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)
  3. src/main/java/jcifs/smb/MultiChannelManager.java

         */
        public ChannelInfo selectChannel(String sessionId) {
            ChannelGroup channelGroup = sessionChannels.get(sessionId);
            if (channelGroup == null) {
                log.warn("No channel group found for session {}", sessionId);
                return null;
            }
    
            ChannelInfo selected = channelGroup.selectChannel(loadBalancingStrategy);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  4. docs/smb3-features/03-multi-channel-design.md

            } catch (NoSuchAlgorithmException e) {
                throw new IOException("SHA-256 not available", e);
            }
        }
        
        public ChannelInfo selectChannel(SMBMessage message) {
            return loadBalancer.selectChannel(message);
        }
        
        public void handleChannelFailure(ChannelInfo channel, Exception error) {
            failover.handleFailure(channel, error);
        }
        
    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/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java

            // For now, just test the empty case
            assertEquals(0, channelManager.getHealthyChannels().size());
        }
    
        @Test
        void testChannelSelection() {
            try {
                channelManager.selectChannel(mockMessage);
                fail("Should throw exception when no channels available");
            } catch (Exception e) {
                // Expected - no channels available
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

        /**
         * Select a channel for the given message
         *
         * @param message message to send
         * @return selected channel
         */
        public ChannelInfo selectChannel(CommonServerMessageBlock message) {
            return loadBalancer.selectChannel(message);
        }
    
        /**
         * Handle channel failure
         *
         * @param channel failed channel
         * @param error error that caused failure
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 20K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java

         *
         * @param message SMB message to send
         * @return selected channel
         * @throws NoAvailableChannelException if no healthy channels available
         */
        public ChannelInfo selectChannel(CommonServerMessageBlock message) throws NoAvailableChannelException {
            Collection<ChannelInfo> availableChannels = manager.getHealthyChannels();
    
            if (availableChannels.isEmpty()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java

            when(mockRequest.getTreeId()).thenReturn(123);
    
            // Should throw NoAvailableChannelException when no healthy channels
            assertThrows(ChannelLoadBalancer.NoAvailableChannelException.class, () -> loadBalancer.selectChannel(mockRequest),
                    "Should throw exception when no healthy channels available");
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

            // Redistribute to healthy channels
            for (CommonServerMessageBlock op : operationsCopy) {
                try {
                    ChannelInfo alternativeChannel = manager.getLoadBalancer().selectChannel(op);
                    alternativeChannel.addPendingOperation(op);
                    // Operation would be resent on alternative channel
                    // For now, skip actual send implementation
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/SmbSessionImpl.java

         */
        public SmbTransportImpl selectTransport(CommonServerMessageBlockRequest message) {
            if (isUseMultiChannel()) {
                try {
                    ChannelInfo channel = channelManager.selectChannel(message);
                    return (SmbTransportImpl) channel.getTransport();
                } catch (Exception e) {
                    log.debug("Multi-channel selection failed, using primary transport", e);
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 68.9K bytes
    - Viewed (0)
Back to top