Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for DataBlocks (0.18 sec)

  1. cmd/erasure-heal_test.go

    		}
    
    		// create some test data
    		setup, err := newErasureTestSetup(t, test.dataBlocks, test.disks-test.dataBlocks, test.blocksize)
    		if err != nil {
    			t.Fatalf("Test %d: failed to setup Erasure environment: %v", i, err)
    		}
    		disks := setup.disks
    		erasure, err := NewErasure(context.Background(), test.dataBlocks, test.disks-test.dataBlocks, test.blocksize)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  2. cmd/erasure_test.go

    var erasureEncodeDecodeTests = []struct {
    	dataBlocks, parityBlocks   int
    	missingData, missingParity int
    	reconstructParity          bool
    	shouldFail                 bool
    }{
    	{dataBlocks: 2, parityBlocks: 2, missingData: 0, missingParity: 0, reconstructParity: true, shouldFail: false},
    	{dataBlocks: 3, parityBlocks: 3, missingData: 1, missingParity: 0, reconstructParity: true, shouldFail: false},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 25 19:37:26 GMT 2022
    - 4.8K bytes
    - Viewed (0)
  3. cmd/storage-datatypes_test.go

    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 9.4K bytes
    - Viewed (0)
  4. cmd/erasure-decode_test.go

    	for i, test := range erasureDecodeTests {
    		setup, err := newErasureTestSetup(t, test.dataBlocks, test.onDisks-test.dataBlocks, test.blocksize)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create test setup: %v", i, err)
    		}
    		erasure, err := NewErasure(context.Background(), test.dataBlocks, test.onDisks-test.dataBlocks, test.blocksize)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    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)
  5. cmd/storage-datatypes.go

    // newFileInfo - initializes new FileInfo, allocates a fresh erasure info.
    func newFileInfo(object string, dataBlocks, parityBlocks int) (fi FileInfo) {
    	fi.Erasure = ErasureInfo{
    		Algorithm:    erasureAlgorithm,
    		DataBlocks:   dataBlocks,
    		ParityBlocks: parityBlocks,
    		BlockSize:    blockSizeV2,
    		Distribution: hashOrder(object, dataBlocks+parityBlocks),
    	}
    	return fi
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    	lastPartIndex, _, err := fi.ObjectToPartOffset(ctx, endOffset)
    	if err != nil {
    		return InvalidRange{startOffset, length, fi.Size}
    	}
    
    	var totalBytesRead int64
    	erasure, err := NewErasure(ctx, fi.Erasure.DataBlocks, fi.Erasure.ParityBlocks, fi.Erasure.BlockSize)
    	if err != nil {
    		return toObjectErr(err, bucket, object)
    	}
    
    	var healOnce sync.Once
    
    	for ; partIndex <= lastPartIndex; partIndex++ {
    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)
  7. cmd/erasure-utils.go

    	// Offset and out size cannot be negative.
    	if offset < 0 || length < 0 {
    		return 0, errUnexpected
    	}
    
    	// Do we have enough blocks?
    	if len(enBlocks) < dataBlocks {
    		return 0, reedsolomon.ErrTooFewShards
    	}
    
    	// Do we have enough data?
    	if int64(getDataBlockLen(enBlocks, dataBlocks)) < length {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 3.1K bytes
    - Viewed (0)
  8. cmd/erasure-metadata.go

    		// for erasure coding information
    		return true
    	}
    	dataBlocks := fi.Erasure.DataBlocks
    	parityBlocks := fi.Erasure.ParityBlocks
    	correctIndexes := (fi.Erasure.Index > 0 &&
    		fi.Erasure.Index <= dataBlocks+parityBlocks &&
    		len(fi.Erasure.Distribution) == (dataBlocks+parityBlocks))
    	return ((dataBlocks >= parityBlocks) &&
    		(dataBlocks > 0) && (parityBlocks >= 0) &&
    		correctIndexes)
    }
    
    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)
  9. cmd/erasure-server-pool-rebalance.go

    	if fi.IsLatest {
    		rs.NumObjects++
    	}
    
    	rs.NumVersions++
    	onDiskSz := int64(0)
    	if !fi.Deleted {
    		onDiskSz = fi.Size * int64(fi.Erasure.DataBlocks+fi.Erasure.ParityBlocks) / int64(fi.Erasure.DataBlocks)
    	}
    	rs.Bytes += uint64(onDiskSz)
    	rs.Bucket = bucket
    	rs.Object = fi.Name
    }
    
    type rstats []*rebalanceStats
    
    //go:generate stringer -type=rebalStatus -trimprefix=rebal $GOFILE
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  10. cmd/erasure-healing-common_test.go

    			latestFileInfo = partsMetadata[index]
    			count++
    		}
    	}
    
    	if !latestFileInfo.IsValid() {
    		return FileInfo{}, errErasureReadQuorum
    	}
    
    	if count < latestFileInfo.Erasure.DataBlocks {
    		return FileInfo{}, errErasureReadQuorum
    	}
    
    	return latestFileInfo, nil
    }
    
    // validates functionality provided to find most common
    // time occurrence from a list of time.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 23K bytes
    - Viewed (1)
Back to top