- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for getChannel (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
guava-tests/test/com/google/common/io/ByteStreamsTest.java
try (FileOutputStream fos = new FileOutputStream(testFile)) { for (int i = 0; i < 500; i++) { fos.write(dummyData); } } try (ReadableByteChannel inChannel = new RandomAccessFile(testFile, "r").getChannel()) { ByteStreams.copy(inChannel, outChannel); } byte[] actual = out.toByteArray(); for (int i = 0; i < 500 * chunkSize; i += chunkSize) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 22K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/ByteStreamsTest.java
try (FileOutputStream fos = new FileOutputStream(testFile)) { for (int i = 0; i < 500; i++) { fos.write(dummyData); } } try (ReadableByteChannel inChannel = new RandomAccessFile(testFile, "r").getChannel()) { ByteStreams.copy(inChannel, outChannel); } byte[] actual = out.toByteArray(); for (int i = 0; i < 500 * chunkSize; i += chunkSize) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 22K bytes - Click Count (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>Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Jul 31 08:16:49 GMT 2025 - 45.2K bytes - Click Count (0) -
android/guava/src/com/google/common/io/Files.java
@Override public byte[] read() throws IOException { Closer closer = Closer.create(); try { FileInputStream in = closer.register(openStream()); return ByteStreams.toByteArray(in, in.getChannel().size()); } catch (Throwable e) { throw closer.rethrow(e); } finally { closer.close(); } } @Override public String toString() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Jan 05 22:13:21 GMT 2026 - 32.8K bytes - Click Count (0) -
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 {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 7.6K bytes - Click Count (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 negotiationCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 8.2K bytes - Click Count (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 */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 20K bytes - Click Count (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
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 39.6K bytes - Click Count (0)