Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newStreamingBitrotReader (0.19 sec)

  1. cmd/bitrot.go

    }
    
    func newBitrotReader(disk StorageAPI, data []byte, bucket string, filePath string, tillOffset int64, algo BitrotAlgorithm, sum []byte, shardSize int64) io.ReaderAt {
    	if algo == HighwayHash256S {
    		return newStreamingBitrotReader(disk, data, bucket, filePath, tillOffset, algo, shardSize)
    	}
    	return newWholeBitrotReader(disk, bucket, filePath, algo, tillOffset, sum)
    }
    
    // Close all the readers.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 26 19:26:13 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  2. cmd/bitrot-streaming.go

    	if !bytes.Equal(b.h.Sum(nil), b.hashBytes) {
    		return 0, errFileCorrupt
    	}
    	b.currOffset += int64(len(buf))
    	return len(buf), nil
    }
    
    // Returns streaming bitrot reader implementation.
    func newStreamingBitrotReader(disk StorageAPI, data []byte, volume, filePath string, tillOffset int64, algo BitrotAlgorithm, shardSize int64) *streamingBitrotReader {
    	h := algo.New()
    	return &streamingBitrotReader{
    		disk:       disk,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 17 19:19:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
Back to top