Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 131 for skipLen (0.06 sec)

  1. src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java

            // Skip uses read internally, which may throw IOException when it tries to read the next header
            try {
                long skipped = sis.skip(10);
                // If it doesn't throw, it should only skip what's available
                assertEquals(3, skipped);
            } catch (IOException e) {
                // This is also acceptable behavior - skip may fail when it runs out of data
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  2. cmd/background-newdisks-heal-ops.go

    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Object = object
    }
    
    func (h *healingTracker) updateProgress(success, skipped bool, bytes uint64) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	switch {
    	case success:
    		h.ItemsHealed++
    		h.BytesDone += bytes
    	case skipped:
    		h.ItemsSkipped++
    		h.BytesSkipped += bytes
    	default:
    		h.ItemsFailed++
    		h.BytesFailed += bytes
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java

         * Skips over and discards {@code n} bytes of data from this input stream.
         * This method delegates to {@link FileInputStream#skip(long)}.
         *
         * @param n the number of bytes to be skipped
         * @return the actual number of bytes skipped
         * @throws IOException if an I/O error occurs.
         */
        @Override
        public long skip(final long n) throws IOException {
            return fileInputStream.skip(n);
        }
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

              if (forgetMeNot == null || skipMe == null) {
                forgetMeNot = new ArrayDeque<>();
                skipMe = new ArrayList<>(3);
              }
              if (!foundAndRemovedExactReference(skipMe, moved.toTrickle)) {
                forgetMeNot.add(moved.toTrickle);
              }
              if (!foundAndRemovedExactReference(forgetMeNot, moved.replaced)) {
                skipMe.add(moved.replaced);
              }
            }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 33.9K bytes
    - Viewed (0)
  5. .ci/dockerOnLinuxExclusions

    # This file specifies the Linux OS versions on which we can't build and
    # test Docker images for some reason. These values correspond to ID and
    # VERSION_ID from /etc/os-release, and a matching value will cause the
    # Docker tests to be skipped on that OS. If /etc/os-release doesn't exist
    # (as is the case on centos-6, for example) then that OS will again be
    # excluded.
    debian-8
    opensuse-leap-15.1
    ol-7.7
    sles-12.3 # older version used in Vagrant image
    sles-12.5
    Registered: Sun Dec 21 06:47:06 UTC 2025
    - Last Modified: Thu Jul 29 23:07:12 UTC 2021
    - 615 bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildStep.java

        public static final int PLANNING = 1;
        public static final int SCHEDULED = 2;
        public static final int EXECUTED = 3;
        public static final int FAILED = 4;
        public static final int SKIPPED = 5;
    
        public static final String PLAN = "$plan$";
        public static final String SETUP = "$setup$";
        public static final String TEARDOWN = "$teardown$";
    
        @Nonnull
        final MavenProject project;
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Apr 30 16:21:08 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java

            inputStream.reset();
        }
    
        /**
         * Skips over and discards n bytes of data from this input stream.
         *
         * @param n the number of bytes to be skipped
         * @return the actual number of bytes skipped
         * @throws IOException if an I/O error occurs
         */
        @Override
        public long skip(final long n) throws IOException {
            return inputStream.skip(n);
        }
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStreamTest.java

            InputStream underlyingStream = new ByteArrayInputStream(data);
            IgnoreCloseInputStream stream = new IgnoreCloseInputStream(underlyingStream);
    
            long skipped = stream.skip(5);
            assertEquals(5, skipped);
            assertEquals('5', stream.read());
        }
    
        public void test_markSupported_delegatesToUnderlying() {
            // Test that markSupported() delegates to underlying stream
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  9. cmd/global-heal.go

    	status.SCParity[storageclass.RRS] = backendInfo.RRSCParity
    
    	return status, true
    }
    
    type healEntryResult struct {
    	bytes     uint64
    	success   bool
    	skipped   bool
    	entryDone bool
    	name      string
    }
    
    // healErasureSet lists and heals all objects in a specific erasure set
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/TemporaryFileInputStreamTest.java

                fos.write("0123456789".getBytes());
            }
    
            try (TemporaryFileInputStream stream = new TemporaryFileInputStream(tempFile)) {
                long skipped = stream.skip(5);
                assertEquals(5, skipped);
                assertEquals('5', stream.read());
                assertEquals('6', stream.read());
            }
        }
    
        public void test_markAndReset() throws Exception {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 7.2K bytes
    - Viewed (0)
Back to top