Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 1,019 for readFn (0.07 seconds)

  1. 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)
  2. 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 = offset
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 17 19:19:30 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top