- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 1,019 for readFn (0.07 seconds)
-
docs/config/README.md
By default, parity for objects with standard storage class is set to `N/2`, and parity for objects with reduced redundancy storage class objects is set to `2`. Read more about storage class support in MinIO server [here](https://github.com/minio/minio/blob/master/docs/erasure/storage-class/README.md). ``` KEY: storage_class define object level redundancy ARGS:
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 18.1K bytes - Click Count (1) -
cmd/bitrot-streaming.go
} return nil } func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) { var err error if offset%b.shardSize != 0 { // Offset should always be aligned to b.shardSize // Can never happen unless there are programmer bugs return 0, errUnexpected } if b.rc == nil { // For the first ReadAt() call we need to open the stream for reading. b.currOffset = offsetCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jan 17 19:19:30 GMT 2025 - 6.2K bytes - Click Count (0) -
internal/s3select/jstream/README.md
--- | --- | --- | --- regular | standard | 97 | 3.6MB regular | jstream | 175 | 2.1MB large | standard | 92 | 305MB large | jstream | 404 | 69MB In a real world scenario, including initialization and reader overhead from varying blob sizes, performance can be expected as below:
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 3.2K bytes - Click Count (0) -
cmd/bitrot.go
defer xioutil.ODirectPoolSmall.Put(bufp) for left > 0 { // Read expected hash... h.Reset() n, err := io.ReadFull(r, hashBuf) if err != nil { // Read's failed for object with right size, file is corrupt. return err } // Subtract hash length.. left -= int64(n) if left < shardSize { shardSize = left } read, err := io.CopyBuffer(h, io.LimitReader(r, shardSize), *bufp)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.7K bytes - Click Count (0) -
src/main/java/jcifs/pac/PacDataInputStream.java
*/ public String readString() throws IOException, PACDecodingException { final int totalChars = readInt(); final int unusedChars = readInt(); final int usedChars = readInt(); if (unusedChars > totalChars || usedChars > totalChars - unusedChars) { throw new PACDecodingException("Malformed string in PAC"); }Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 8.9K bytes - Click Count (0) -
cmd/bitrot_test.go
bw.Close() } reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10) b := make([]byte, 10) if _, err = reader.ReadAt(b, 0); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b, 10); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b, 20); err != nil { t.Fatal(err) } if _, err = reader.ReadAt(b[:5], 30); err != nil { t.Fatal(err) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 2K bytes - Click Count (0) -
src/bytes/reader_test.go
{"Seek", func(r *Reader) { r.Seek(0, io.SeekCurrent) }}, {"WriteTo", func(r *Reader) { r.WriteTo(&Buffer{}) }}, } func TestUnreadRuneError(t *testing.T) { for _, tt := range UnreadRuneErrorTests { reader := NewReader([]byte("0123456789")) if _, _, err := reader.ReadRune(); err != nil { // should not happen t.Fatal(err) } tt.f(reader) err := reader.UnreadRune()Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 13 18:45:54 GMT 2021 - 8K bytes - Click Count (0) -
lib/time/README
For more information, see https://www.iana.org/time-zones ftp://ftp.iana.org/tz/code/tz-link.html https://datatracker.ietf.org/doc/html/rfc6557
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Sun Aug 15 02:18:46 GMT 2021 - 390 bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Serialization.java
K key = (K) stream.readObject(); Collection<V> values = multimap.get(key); int valueCount = stream.readInt(); for (int j = 0; j < valueCount; j++) { @SuppressWarnings("unchecked") // reading data stored by writeMultimap V value = (V) stream.readObject(); values.add(value); } } }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Dec 09 15:58:48 GMT 2025 - 6.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/SuggestHelper.java
final ESSourceReader reader = new ESSourceReader(ComponentUtil.getSearchEngineClient(), suggester.settings(), fessConfig.getIndexDocumentSearchIndex()); reader.setScrollSize(fessConfig.getSuggestSourceReaderScrollSizeAsInteger()); reader.setLimitDocNumPercentage(fessConfig.getSuggestUpdateContentsLimitNumPercentage());
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 22.3K bytes - Click Count (0)