Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for Channel (0.05 sec)

  1. docs/smb3-features/03-multi-channel-design.md

                        handleChannelFailure(channel, e);
                    }
                }
                
                // Check error rate
                if (channel.getErrorRate() > 0.1) {
                    log.warn("High error rate on channel {}: {}", 
                        channel.getChannelId(), channel.getErrorRate());
                    // Consider removing channel
                }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

         */
        public ChannelInfo getChannelForTransport(SmbTransport transport) {
            return channels.values().stream().filter(c -> c.getTransport() == transport).findFirst().orElse(null);
        }
    
        /**
         * Remove a channel
         *
         * @param channel channel to remove
         */
        public void removeChannel(ChannelInfo channel) {
            channels.remove(channel.getChannelId());
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 20K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/MultiChannelManager.java

                return new ArrayList<>(channels);
            }
    
            public void addChannel(ChannelInfo channel) {
                channels.add(channel);
                if (primaryChannel == null) {
                    primaryChannel = channel;
                }
            }
    
            public void removeChannel(ChannelInfo channel) {
                channels.remove(channel);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 20.5K bytes
    - Viewed (0)
  4. 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: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java

        private final AtomicLong errors;
    
        // Channel binding
        private byte[] bindingHash;
        private boolean isPrimary;
    
        // Pending operations
        private final List<CommonServerMessageBlock> pendingOperations;
    
        /**
         * Create channel information
         *
         * @param channelId unique channel identifier
         * @param transport SMB transport for this channel
         * @param localInterface local network interface
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

            } catch (Exception e) {
                log.warn("Failed to recover channel {}: {}", channel.getChannelId(), e.getMessage());
    
                // Schedule next retry or remove
                handleFailure(channel, e);
            }
        }
    
        private void removeChannel(ChannelInfo channel) {
            log.info("Removing failed channel {} after max retries", channel.getChannelId());
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  7. guava/src/com/google/common/io/ByteStreams.java

          to.write(buf, 0, r);
          total += r;
        }
        return total;
      }
    
      /**
       * Copies all bytes from the readable channel to the writable channel. Does not close or flush
       * either channel.
       *
       * @param from the readable channel to read from
       * @param to the writable channel to write to
       * @return the number of bytes copied
       * @throws IOException if an I/O error occurs
       */
      @J2ktIncompatible
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (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
         *
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb2/io/Smb2ReadRequestTest.java

            }
    
            @Test
            @DisplayName("Should handle read request with RDMA channel")
            void testReadRequestWithRdmaChannel() {
                request.setReadLength(65536);
                request.setOffset(0L);
                // Note: channel is private and not settable via public API
                // This test documents that channel defaults to SMB2_CHANNEL_NONE
    
                byte[] buffer = new byte[256];
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 24.8K bytes
    - Viewed (0)
  10. src/main/java/jcifs/config/BaseConfiguration.java

        // Multi-channel configuration fields
        /**
         * Whether to use SMB3 multi-channel support for improved performance and redundancy
         */
        protected boolean useMultiChannel;
        /**
         * Maximum number of SMB3 channels to establish per session
         */
        protected int maxChannels;
        /**
         * Channel binding policy: -1=not set, 0=disabled, 1=preferred, 2=required
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 36.5K bytes
    - Viewed (0)
Back to top