Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 134 for channel1 (0.07 sec)

  1. src/main/java/org/codelibs/core/nio/ChannelUtil.java

            assertArgumentNotNull("channel", channel);
    
            try {
                return channel.size();
            } catch (final IOException e) {
                throw new IORuntimeException(e);
            }
        }
    
        /**
         * Reads the contents of the file channel into a byte buffer.
         *
         * @param channel
         *            The file channel. Must not be {@literal null}.
         * @param buffer
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 5.6K bytes
    - Viewed (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());
    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. 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
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  4. 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;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 2.4K bytes
    - Viewed (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
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  6. 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,
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/FileOperator.kt

    import java.io.IOException
    import java.nio.channels.FileChannel
    import okio.Buffer
    
    /**
     * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)`
     * this class offers:
     *
     *  * **Read/write:** read and write using the same operator.
     *  * **Random access:** access any position within the file.
     *  * **Shared channels:** read and write a file channel that's shared between
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  8. 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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  9. 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;
          }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 3.1K bytes
    - Viewed (0)
  10. 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");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 8.3K bytes
    - Viewed (0)
Back to top