- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 464 for reeds (0.02 sec)
-
cmd/erasure-encode.go
} writeErr := reduceWriteQuorumErrs(ctx, p.errs, objectOpIgnoredErrs, p.writeQuorum) return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers)) } // Encode reads from the reader, erasure-encodes the data and writes to the writers. func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) { writer := &multiWriter{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbRandomAccessFileTest.java
assertThrows(SmbEndOfFileException.class, () -> raf.readFully(new byte[4])); } @Test @DisplayName("readFully(): reads across multiple partial reads") void readFully_readsAll() throws Exception { SmbRandomAccessFile raf = spy(newInstance("r", false, false, false)); AtomicInteger calls = new AtomicInteger(); doAnswer(inv -> {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.1K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java
} } /** * Marks the current position in this input stream. A subsequent call to the reset method repositions this stream at the last marked position so that subsequent reads re-read the same bytes. * This method delegates to {@link FileInputStream#mark(int)}. * * @param readlimit the maximum limit of bytes that can be read before the mark position becomes invalid */
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 4.3K bytes - Viewed (0) -
dbflute_fess/dfprop/littleAdjustmentMap.dfprop
# o isAvailableDatabaseNativeJDBC: (NotRequired - Default false) # [true] # Use classes of database native JDBC on generated classes to get best performances of DB access. # Your project needs to refer to database native JDBC. # #; isAvailableDatabaseNativeJDBC = false # - - - - - - - - - -/ # /- - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 25 06:04:16 UTC 2015 - 8.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/AbstractTableTest.java
import java.util.Map; import org.jspecify.annotations.NonNull; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Test cases for a {@link Table} implementation supporting reads and writes. * * @author Jared Levy * @author Louis Wasserman */ @GwtCompatible @NullMarked public abstract class AbstractTableTest<C extends @Nullable Character> extends AbstractTableReadTest<C> {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 5.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/IteratorTester.java
* * <p>To use this class the concrete subclass must implement the {@link * IteratorTester#newTargetIterator()} method. This is because it's impossible to test an Iterator * without changing its state, so the tester needs a steady supply of fresh Iterators. * * <p>If your iterator supports modification through {@code remove()}, you may wish to override the * verify() method, which is called after each sequence and is guaranteed to be called
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 4.3K bytes - Viewed (0) -
guava/src/com/google/common/io/Files.java
* * @author Chris Nokleberg * @author Colin Decker * @since 1.0 */ @J2ktIncompatible @GwtIncompatible public final class Files { private Files() {} /** * Returns a buffered reader that reads from a file using the given character set. * * <p><b>{@link java.nio.file.Path} equivalent:</b> {@link * java.nio.file.Files#newBufferedReader(java.nio.file.Path, Charset)}. * * @param file the file to read from
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 32.9K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/SmbComOpenAndXTest.java
/** * Test writeParameterWordsWireFormat method. */ @Test void testWriteParameterWordsWireFormat() { smbComOpenAndX = new SmbComOpenAndX(fileName, access, 0, andx); // Buffer needs 26 bytes: 2+2+2+2+4+2+4+8 = 26 byte[] dst = new byte[26]; int result = smbComOpenAndX.writeParameterWordsWireFormat(dst, 0); assertEquals(26, result); } /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CollectionFuture.java
/* * We access this field racily but safely. For discussion of a similar situation, see the comments * on the fields of TimeoutFuture. This field is slightly different from the fields discussed * there: cancel() never reads this field, only writes to it. That makes the race here completely * harmless, rather than just 99.99% harmless. */ @LazyInit private @Nullable List<@Nullable Present<V>> values;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 3.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/url/-Url.kt
} i += Character.charCount(codePoint) } } /** * Returns a substring of `input` on the range `[pos..limit)` with the following * transformations: * * * Tabs, newlines, form feeds and carriage returns are skipped. * * * In queries, ' ' is encoded to '+' and '+' is encoded to "%2B". * * * Characters in `encodeSet` are percent-encoded. *
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 7.3K bytes - Viewed (0)