- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newStreamingBitrotReader (0.19 sec)
-
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) -
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)