Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 464 for reeds (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top