Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for shardSize (0.2 sec)

  1. cmd/erasure-decode.go

    	// Fill buffers
    	b := globalBytePoolCap.Load().Get()
    	shardSize := int(e.ShardSize())
    	if cap(b) < len(readers)*shardSize {
    		// We should always have enough capacity, but older objects may be bigger.
    		globalBytePoolCap.Load().Put(b)
    		b = nil
    	} else {
    		// Seed the buffers.
    		for i := range bufs {
    			bufs[i] = b[i*shardSize : (i+1)*shardSize]
    		}
    	}
    
    	return &parallelReader{
    		readers:       readers,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  2. cmd/erasure-metadata.go

    	lastBlockSize := totalLength % e.BlockSize
    	lastShardSize := ceilFrac(lastBlockSize, int64(e.DataBlocks))
    	return numShards*e.ShardSize() + lastShardSize
    }
    
    // ShardSize - returns actual shared size from erasure blockSize.
    func (e ErasureInfo) ShardSize() int64 {
    	return ceilFrac(e.BlockSize, int64(e.DataBlocks))
    }
    
    // IsValid - tells if erasure info fields are valid.
    func (fi FileInfo) IsValid() bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  3. cmd/erasure-healing.go

    					defer grid.PutByteBuffer(buf)
    
    					writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    				} else {
    					writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, partPath,
    						tillOffset, DefaultBitrotAlgorithm, erasure.ShardSize())
    				}
    			}
    
    			// Heal each part. erasure.Heal() will write the healed
    			// part to .minio/tmp/uuid/ which needs to be renamed
    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)
  4. cmd/erasure-object.go

    			defer grid.PutByteBuffer(buf)
    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    			continue
    		}
    
    		writers[i] = newBitrotWriter(disk, bucket, minioMetaTmpBucket, tempErasureObj, shardFileSize, DefaultBitrotAlgorithm, erasure.ShardSize())
    	}
    
    	toEncode := io.Reader(data)
    	if data.Size() >= bigFileThreshold {
    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)
  5. cmd/xl-storage.go

    	s.deleteFile(srcVolumeDir, parentDir, false, false)
    
    	return nil
    }
    
    func (s *xlStorage) bitrotVerify(ctx context.Context, partPath string, partSize int64, algo BitrotAlgorithm, sum []byte, shardSize int64) error {
    	// Open the file for reading.
    	file, err := OpenFile(partPath, readMode, 0o666)
    	if err != nil {
    		return osErrToFileErr(err)
    	}
    
    	// Close the file descriptor.
    	defer file.Close()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  6. cmd/erasure-multipart.go

    	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.
    		// We use 2 buffers, so we always have a full buffer of input.
    		pool := globalBytePoolCap.Load()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
Back to top