Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for shardFileSize (0.19 sec)

  1. cmd/erasure-coding.go

    func (e *Erasure) ShardFileOffset(startOffset, length, totalLength int64) int64 {
    	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
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  2. cmd/erasure-decode.go

    	}
    
    	return &parallelReader{
    		readers:       readers,
    		orgReaders:    readers,
    		dataBlocks:    e.dataBlocks,
    		offset:        (offset / e.blockSize) * e.ShardSize(),
    		shardSize:     e.ShardSize(),
    		shardFileSize: e.ShardFileSize(totalLength),
    		buf:           make([][]byte, len(readers)),
    		readerToBuf:   r2b,
    		stashBuffer:   b,
    	}
    }
    
    // Done will release any resources used by the parallelReader.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 21 14:36:21 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. cmd/erasure-heal_test.go

    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    		for i, disk := range disks {
    			shardFilesize := erasure.ShardFileSize(test.size)
    			readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize())
    		}
    
    		// setup stale disks for the test case
    		staleDisks := make([]StorageAPI, len(disks))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top