- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for Channel (0.05 sec)
-
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) -
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) -
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) -
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) -
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 interfaceRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 10.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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=requiredRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 36.5K bytes - Viewed (0)