Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 179 for channel2 (0.19 seconds)

  1. 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)
  2. 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)
  3. docs/SMB3_IMPLEMENTATION_PLAN.md

    - [ ] Create channel synchronization mechanism
    - [ ] Implement channel failure detection
    - [ ] Add automatic channel recovery
    - [ ] Create channel performance monitoring
    
    #### 3.3 Integration Points
    - Modify `SmbTransportPool` for multiple connections per session
    - Update `SmbSession` for multi-channel awareness
    - Enhance `SmbTransport` for channel management
    
    ---
    
    ### Phase 4: Directory Leasing
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 10.7K bytes
    - Click Count (0)
  4. src/main/java/jcifs/internal/smb2/multichannel/LoadBalancingStrategy.java

    /**
     * Load balancing strategies for multi-channel connections
     */
    public enum LoadBalancingStrategy {
        /**
         * Round-robin selection through available channels
         */
        ROUND_ROBIN,
    
        /**
         * Select the least busy channel based on pending operations
         */
        LEAST_LOADED,
    
        /**
         * Weighted random selection based on channel scores
         */
        WEIGHTED_RANDOM,
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  5. 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)
  6. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java

          return endpoint;
        }
    
        @Override public Socket accept() throws IOException {
          try {
            UnixSocketChannel channel = serverSocketChannel.accept();
            return new TunnelingUnixSocket(path, channel, endpoint);
          } catch (ClosedChannelException e) {
            SocketException exception = new SocketException();
            exception.initCause(e);
            throw exception;
          }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 12 16:33:52 GMT 2019
    - 3.1K bytes
    - Click Count (0)
  7. src/test/java/jcifs/config/MultiChannelConfigurationTest.java

    import jcifs.CIFSException;
    
    /**
     * Unit tests for Multi-Channel configuration properties
     */
    class MultiChannelConfigurationTest {
    
        @Test
        void testDefaultMultiChannelSettings() throws CIFSException {
            PropertyConfiguration config = new PropertyConfiguration(new Properties());
    
            assertTrue(config.isUseMultiChannel(), "Multi-channel should be enabled by default");
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  8. src/main/java/jcifs/Configuration.java

         */
        int getMaxChannels();
    
        /**
         * Channel binding policy
         *
         * Property {@code jcifs.smb.client.channelBindingPolicy} (String, default "preferred")
         * Values: "disabled", "preferred", "required"
         *
         * @return channel binding policy
         */
        int getChannelBindingPolicy();
    
        /**
         * Load balancing strategy for multi-channel
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/ByteStreams.java

       * <ol>
       *   <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output
       *       channel have their own file descriptors. Generally this only happens when both channels
       *       are files or sockets. This performs zero copies - the bytes never enter userspace.
       *   <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 31.1K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/io/Files.java

        try {
          RandomAccessFile raf =
              closer.register(new RandomAccessFile(file, mode == MapMode.READ_ONLY ? "r" : "rw"));
          FileChannel channel = closer.register(raf.getChannel());
          return channel.map(mode, 0, size == -1 ? channel.size() : size);
        } catch (Throwable e) {
          throw closer.rethrow(e);
        } finally {
          closer.close();
        }
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Jan 05 22:13:21 GMT 2026
    - 32.8K bytes
    - Click Count (0)
Back to Top