Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for getChannel (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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 negotiation
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 11:13:46 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  7. 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)
  8. 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)
Back to Top