- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for getChannels (0.28 sec)
-
src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java
} @Test void testConstructor() { assertNotNull(channelManager); assertFalse(channelManager.isUseMultiChannel()); assertEquals(0, channelManager.getChannels().size()); assertNotNull(channelManager.getLoadBalancer()); } @Test void testInitializationWithoutMultiChannelSupport() throws IOException {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
public ChannelGroup(String sessionId) { this.sessionId = sessionId; } public String getSessionId() { return sessionId; } public List<ChannelInfo> getChannels() { return new ArrayList<>(channels); } public void addChannel(ChannelInfo channel) { channels.add(channel); if (primaryChannel == null) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 20.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java
} @Test void testMultiChannelInitialization() throws Exception { // Test that ChannelManager initializes properly assertNotNull(channelManager); assertNotNull(channelManager.getChannels()); // Note: isUseMultiChannel() checks if actual multi-channel is negotiated with server // In mock environment, this will be false until we mock successful negotiationRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 8.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
return loadBalancer; } /** * Get all channels * * @return collection of all channels */ public Collection<ChannelInfo> getChannels() { return channels.values(); } /** * Get healthy channels only * * @return collection of healthy channels */Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
assertEquals(ChannelState.FAILED, channel.getState()); // Verify recovery attempted Thread.sleep(2000); assertTrue(channel.getState() == ChannelState.ESTABLISHED || manager.getChannels().isEmpty()); } ``` ### 7.2 Integration Tests ```java @Test public void testMultiChannelThroughput() throws Exception { // Requires multi-NIC test environment
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/org/codelibs/core/io/FileUtil.java
assertArgumentNotNull("file", file); final FileInputStream is = InputStreamUtil.create(file); try { final FileChannel channel = is.getChannel(); final long fileSize = ChannelUtil.size(channel); if (fileSize > maxSize) {
Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat Nov 22 11:21:59 UTC 2025 - 13.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/CopyUtil.java
* @return the number of bytes copied */ protected static int copyInternal(final FileInputStream in, final FileOutputStream out) { final FileChannel ic = in.getChannel(); final FileChannel oc = out.getChannel(); return (int) ChannelUtil.transfer(ic, oc); } /** * Copies the contents of a reader to a writer. * <p>Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 45.2K bytes - Viewed (0)