Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/bitrot.go

    }
    
    func newBitrotWriter(disk StorageAPI, origvolume, volume, filePath string, length int64, algo BitrotAlgorithm, shardSize int64) io.Writer {
    	if algo == HighwayHash256S {
    		return newStreamingBitrotWriter(disk, origvolume, volume, filePath, length, algo, shardSize)
    	}
    	return newWholeBitrotWriter(disk, volume, filePath, algo, shardSize)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  2. cmd/bitrot-streaming.go

    	return &streamingBitrotWriter{iow: ioutil.NopCloser(w), h: algo.New(), shardSize: shardSize, canClose: nil, closeWithErr: func(err error) {}}
    }
    
    // Returns streaming bitrot writer implementation.
    func newStreamingBitrotWriter(disk StorageAPI, origvolume, volume, filePath string, length int64, algo BitrotAlgorithm, shardSize int64) io.Writer {
    	h := algo.New()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/erasure-decode.go

    	}
    	bufs := make([][]byte, len(readers))
    	shardSize := int(e.ShardSize())
    	var b []byte
    
    	// We should always have enough capacity, but older objects may be bigger
    	// we do not need stashbuffer for them.
    	if globalBytePoolCap.Load().WidthCap() >= len(readers)*shardSize {
    		// Fill buffers
    		b = globalBytePoolCap.Load().Get()
    		// Seed the buffers.
    		for i := range bufs {
    			bufs[i] = b[i*shardSize : (i+1)*shardSize]
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. cmd/erasure-coding.go

    	return numShards*e.ShardSize() + lastShardSize
    }
    
    // ShardFileOffset - returns the effective offset where erasure reading begins.
    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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. cmd/bitrot-whole.go

    	return nil
    }
    
    // Returns whole-file bitrot writer.
    func newWholeBitrotWriter(disk StorageAPI, volume, filePath string, algo BitrotAlgorithm, shardSize int64) io.WriteCloser {
    	return &wholeBitrotWriter{disk, volume, filePath, shardSize, algo.New()}
    }
    
    // Implementation to verify bitrot for the whole file.
    type wholeBitrotReader struct {
    	disk       StorageAPI
    	volume     string
    	filePath   string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. cmd/erasure-heal_test.go

    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize())
    		}
    		_, err = erasure.Encode(context.Background(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top