Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for ShardFileSize (0.22 sec)

  1. 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))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  2. 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
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 8.6K bytes
    - Viewed (0)
  3. 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.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  4. cmd/erasure-decode_test.go

    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(test.data), writeAlgorithm, erasure.ShardSize())
    		}
    		n, err := erasure.Encode(context.Background(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 21.1K bytes
    - Viewed (1)
  5. cmd/erasure-encode_test.go

    		}
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(int64(len(data[test.offset:]))), test.algorithm, erasure.ShardSize())
    		}
    		n, err := erasure.Encode(context.Background(), bytes.NewReader(data[test.offset:]), writers, buffer, erasure.dataBlocks+1)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    	shardFileSize := erasure.ShardFileSize(data.Size())
    	inlineBlock := globalStorageClass.InlineBlock()
    	if inlineBlock <= 0 {
    		inlineBlock = 128 * humanize.KiByte
    	}
    
    	writers := make([]io.Writer, len(onlineDisks))
    	var inlineBuffers []*bytes.Buffer
    	if shardFileSize >= 0 {
    		if !opts.Versioned && shardFileSize < inlineBlock {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 76.3K bytes
    - Viewed (2)
  7. cmd/erasure-metadata.go

    		if sum.PartNumber == partNumber {
    			// Return the checksum
    			return sum
    		}
    	}
    	return ChecksumInfo{Algorithm: DefaultBitrotAlgorithm}
    }
    
    // ShardFileSize - returns final erasure size from original size.
    func (e ErasureInfo) ShardFileSize(totalLength int64) int64 {
    	if totalLength == 0 {
    		return 0
    	}
    	if totalLength == -1 {
    		return -1
    	}
    	numShards := totalLength / e.BlockSize
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19K bytes
    - Viewed (1)
  8. cmd/erasure-healing-common.go

    			checksumInfo := meta.Erasure.GetChecksumInfo(meta.Parts[0].Number)
    			dataErrs[i] = bitrotVerify(bytes.NewReader(meta.Data),
    				int64(len(meta.Data)),
    				meta.Erasure.ShardFileSize(meta.Size),
    				checksumInfo.Algorithm,
    				checksumInfo.Hash, meta.Erasure.ShardSize())
    			if dataErrs[i] == nil {
    				// All parts verified, mark it as all data available.
    				availableDisks[i] = onlineDisk
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    	}
    	writers := make([]io.Writer, len(onlineDisks))
    	for i, disk := range onlineDisks {
    		if disk == nil {
    			continue
    		}
    		writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, tmpPartPath, erasure.ShardFileSize(data.Size()), DefaultBitrotAlgorithm, erasure.ShardSize())
    	}
    
    	toEncode := io.Reader(data)
    	if data.Size() > bigFileThreshold {
    		// Add input readahead.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 42.4K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    					}
    				}
    			}
    			return osErrToFileErr(err)
    		}
    		if st.Mode().IsDir() {
    			return errFileNotFound
    		}
    		// Check if shard is truncated.
    		if st.Size() < fi.Erasure.ShardFileSize(part.Size) {
    			return errFileCorrupt
    		}
    	}
    
    	return nil
    }
    
    // deleteFile deletes a file or a directory if its empty unless recursive
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 82.4K bytes
    - Viewed (0)
Back to top