- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 131 for skipLen (0.06 sec)
-
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 dataRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.2K bytes - Viewed (0) -
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) -
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) -
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) -
.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) -
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) -
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) -
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) -
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) -
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)