Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 360 for channels (0.23 seconds)

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

                long pending = channel.getRequestsPending();
                if (pending < minPending) {
                    minPending = pending;
                    leastLoadedChannel = channel;
                }
            }
            return leastLoadedChannel != null ? leastLoadedChannel : channels.iterator().next();
        }
    
        private ChannelInfo selectWeightedRandom(Collection<ChannelInfo> channels) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  2. src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java

            // Create channels with zero scores (failed state)
            channel1.setState(ChannelState.FAILED);
            channel2.setState(ChannelState.FAILED);
    
            when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2));
    
            // Should still select a channel even with zero scores
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/multichannel/Smb2ChannelCapabilities.java

        /**
         * Channel binding is preferred but not required
         */
        public static final int CHANNEL_BINDING_PREFERRED = 1;
    
        /**
         * Channel binding is required
         */
        public static final int CHANNEL_BINDING_REQUIRED = 2;
    
        /**
         * Default maximum number of channels per session
         */
        public static final int DEFAULT_MAX_CHANNELS = 4;
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  4. src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java

            ChannelInfo channel = new ChannelInfo("test-channel", mockTransport, localNic, remoteNic);
            channel.setState(ChannelState.ESTABLISHED);
    
            // Verify channel properties
            assertEquals("test-channel", channel.getChannelId());
            assertEquals(mockTransport, channel.getTransport());
            assertEquals(localNic, channel.getLocalInterface());
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java

            // Remove should not throw exception even if channel doesn't exist
            assertDoesNotThrow(() -> channelManager.removeChannel(channel));
        }
    
        @Test
        void testShutdown() {
            assertDoesNotThrow(() -> channelManager.shutdown());
    
            // Multiple shutdowns should be safe
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  6. build-tools-internal/src/main/resources/forbidden/es-server-signatures.txt

    java.lang.System#gc()
    
    @defaultMessage Use Channels.* methods to write to channels. Do not write directly.
    java.nio.channels.WritableByteChannel#write(java.nio.ByteBuffer)
    java.nio.channels.FileChannel#write(java.nio.ByteBuffer, long)
    java.nio.channels.GatheringByteChannel#write(java.nio.ByteBuffer[], int, int)
    java.nio.channels.GatheringByteChannel#write(java.nio.ByteBuffer[])
    java.nio.channels.ReadableByteChannel#read(java.nio.ByteBuffer)
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 08 16:53:28 GMT 2021
    - 7.6K bytes
    - Click Count (0)
  7. samples/slack/src/main/java/okhttp3/slack/RtmStartResponse.java

    import okhttp3.HttpUrl;
    
    /** See https://api.slack.com/methods/rtm.start. */
    public final class RtmStartResponse {
      HttpUrl url;
      Object self;
      Object team;
      List<Object> users;
      List<Object> channels;
      List<Object> groups;
      List<Object> mpims;
      List<Object> ims;
      List<Object> bots;
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Oct 23 15:24:22 GMT 2016
    - 943 bytes
    - Click Count (0)
  8. src/main/java/jcifs/ntlmssp/av/AvChannelBindings.java

     */
    package jcifs.ntlmssp.av;
    
    /**
     * NTLMSSP AV pair representing channel binding information for enhanced security.
     * Used to bind NTLM authentication to specific communication channels.
     *
     * @author mbechler
     */
    public class AvChannelBindings extends AvPair {
    
        /**
         * Constructs an AV channel bindings pair
         * @param channelBindingHash the channel binding hash value
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java

            when(mockLoadBalancer.selectChannel(mockOperation)).thenThrow(new ChannelLoadBalancer.NoAvailableChannelException("No channels"));
    
            IOException error = new IOException("Connection failed");
    
            // Should not throw exception even if no alternative channels
            assertDoesNotThrow(() -> failover.handleFailure(failedChannel, error));
    
            assertEquals(0, failedChannel.getRequestsPending());
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  10. ISSUES.md

    **Here's why we have this policy:** We want to focus on the work that benefits
    the whole community, e.g., fixing bugs and adding features. Individual support
    should be sought on Stack Overflow or other non-GitHub channels. It helps us to
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Feb 11 22:37:27 GMT 2021
    - 606 bytes
    - Click Count (0)
Back to Top