- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for getChannelForTransport (0.88 sec)
-
src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java
assertDoesNotThrow(() -> channelManager.establishReplacementChannel()); } @Test void testGetChannelForTransport() { ChannelInfo result = channelManager.getChannelForTransport(mockTransport); assertNull(result); // No channels registered yet } @Test void testChannelManagerLifecycle() { // Test complete lifecycle
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
} /** * Get channel for specific transport * * @param transport transport instance * @return corresponding channel or null */ public ChannelInfo getChannelForTransport(SmbTransport transport) { return channels.values().stream().filter(c -> c.getTransport() == transport).findFirst().orElse(null); } /** * Remove a channel *
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
try { selectedTransport.send(message); } catch (IOException e) { if (channelManager != null) { // Handle channel failure ChannelInfo channel = channelManager.getChannelForTransport(selectedTransport); channelManager.handleChannelFailure(channel, e); // Retry on different channel SmbTransport alternativeTransport = selectTransport(message);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 39.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
// Handle potential multi-channel failure if (isUseMultiChannel() && trans != this.transport) { ChannelInfo channel = channelManager.getChannelForTransport(trans); if (channel != null) { channelManager.handleChannelFailure(channel, e); // Retry with primary transport
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 68.9K bytes - Viewed (0)