Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for tillOffset (0.16 sec)

  1. cmd/bitrot-whole.go

    // Returns whole-file bitrot reader.
    func newWholeBitrotReader(disk StorageAPI, volume, filePath string, algo BitrotAlgorithm, tillOffset int64, sum []byte) *wholeBitrotReader {
    	return &wholeBitrotReader{
    		disk:       disk,
    		volume:     volume,
    		filePath:   filePath,
    		verifier:   &BitrotVerifier{algo, sum},
    		tillOffset: tillOffset,
    		buf:        nil,
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  2. cmd/erasure-decode_test.go

    		bitrotReaders := make([]io.ReaderAt, len(disks))
    		for index, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			tillOffset := erasure.ShardFileOffset(test.offset, test.length, test.data)
    
    			bitrotReaders[index] = newBitrotReader(disk, nil, "testbucket", "object", tillOffset, writeAlgorithm, bitrotWriterSum(writers[index]), erasure.ShardSize())
    		}
    
    		writer := bytes.NewBuffer(nil)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 21.1K bytes
    - Viewed (1)
  3. 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.
    func closeBitrotReaders(rs []io.ReaderAt) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.6K bytes
    - Viewed (0)
  4. cmd/bitrot-streaming.go

    func newStreamingBitrotReader(disk StorageAPI, data []byte, volume, filePath string, tillOffset int64, algo BitrotAlgorithm, shardSize int64) *streamingBitrotReader {
    	h := algo.New()
    	return &streamingBitrotReader{
    		disk:       disk,
    		data:       data,
    		volume:     volume,
    		filePath:   filePath,
    		tillOffset: ceilFrac(tillOffset, shardSize)*int64(h.Size()) + tillOffset,
    		h:          h,
    		shardSize:  shardSize,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  5. cmd/erasure-coding.go

    	shardSize := e.ShardSize()
    	shardFileSize := e.ShardFileSize(totalLength)
    	endShard := (startOffset + length) / e.blockSize
    	tillOffset := endShard*shardSize + shardSize
    	if tillOffset > shardFileSize {
    		tillOffset = shardFileSize
    	}
    	return tillOffset
    }
    
    // erasureSelfTest performs a self-test to ensure that erasure
    // algorithms compute expected erasure codes. If any algorithm
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 8.6K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    			partModTime := latestMeta.Parts[partIndex].ModTime
    			partNumber := latestMeta.Parts[partIndex].Number
    			partIdx := latestMeta.Parts[partIndex].Index
    			partChecksums := latestMeta.Parts[partIndex].Checksums
    			tillOffset := erasure.ShardFileOffset(0, partSize, partSize)
    			readers := make([]io.ReaderAt, len(latestDisks))
    			prefer := make([]bool, len(latestDisks))
    			checksumAlgo := erasureInfo.GetChecksumInfo(partNumber).Algorithm
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    		// partLength should be adjusted so that we don't write more data than what was requested.
    		if partLength > (length - totalBytesRead) {
    			partLength = length - totalBytesRead
    		}
    
    		tillOffset := erasure.ShardFileOffset(partOffset, partLength, partSize)
    		// Get the checksums of the current part.
    		readers := make([]io.ReaderAt, len(onlineDisks))
    		prefer := make([]bool, len(onlineDisks))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
Back to top