Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for selectChannel (0.08 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/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)
  4. 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)
  5. 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)
Back to top