Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 80 for Erasure (0.06 seconds)

  1. cmd/erasure-metadata.go

    // 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 {
    	if fi.Deleted {
    		// Delete marker has no data, no need to check
    		// for erasure coding information
    		return true
    	}
    	dataBlocks := fi.Erasure.DataBlocks
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  2. cmd/erasure-object_test.go

    	_, err = xl.PutObject(ctx, "bucket", "dir/obj", mustGetPutObjReader(t, bytes.NewReader([]byte("abcd")), int64(len("abcd")), "", ""), ObjectOptions{})
    	if err != nil {
    		t.Fatalf("Erasure Object upload failed: <ERROR> %s", err)
    	}
    	for _, test := range testCases {
    		t.Run("", func(t *testing.T) {
    			_, err := xl.GetObjectInfo(ctx, "bucket", "dir/obj", ObjectOptions{})
    			if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  3. cmd/erasure-sets.go

    		return 0, 0, err
    	}
    
    	if format.Erasure.This == offlineDiskUUID {
    		return -1, -1, fmt.Errorf("DriveID: %s is offline", format.Erasure.This)
    	}
    
    	for i := range len(refFormat.Erasure.Sets) {
    		for j := 0; j < len(refFormat.Erasure.Sets[0]); j++ {
    			if refFormat.Erasure.Sets[i][j] == format.Erasure.This {
    				return i, j, nil
    			}
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  4. cmd/erasure-healing.go

    		errs, latestMeta, filterDisksByETag, bucket, object, scanMode)
    
    	var erasure Erasure
    	if !latestMeta.Deleted && !latestMeta.IsRemote() {
    		// Initialize erasure coding
    		erasure, err = NewErasure(ctx, latestMeta.Erasure.DataBlocks,
    			latestMeta.Erasure.ParityBlocks, latestMeta.Erasure.BlockSize)
    		if err != nil {
    			return result, err
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  5. cmd/erasure-multipart.go

    	case size >= fi.Erasure.BlockSize || size == -1:
    		if int64(globalBytePoolCap.Load().Width()) < fi.Erasure.BlockSize {
    			buffer = make([]byte, fi.Erasure.BlockSize, 2*fi.Erasure.BlockSize)
    		} else {
    			buffer = globalBytePoolCap.Load().Get()
    			defer globalBytePoolCap.Load().Put(buffer)
    		}
    	case size < fi.Erasure.BlockSize:
    		// No need to allocate fully fi.Erasure.BlockSize buffer if the incoming data is smaller.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  6. cmd/erasure-decode_test.go

    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(test.data), writeAlgorithm, erasure.ShardSize())
    		}
    		n, err := erasure.Encode(t.Context(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create erasure test file: %v", i, err)
    		}
    		if n != test.data {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 21K bytes
    - Click Count (0)
  7. cmd/erasure-encode_test.go

    			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(t.Context(), bytes.NewReader(data[test.offset:]), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil && !test.shouldFail {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  8. cmd/erasure-metadata_test.go

    		fi.Size = 1 << 20
    		metaArr := make([]FileInfo, N)
    		parities := make([]int, N)
    		for i := range N {
    			fi.Erasure.Index = i + 1
    			metaArr[i] = fi
    			parities[i] = parity
    			if i < agree {
    				continue
    			}
    			metaArr[i].Erasure.Index = 0 // creates invalid fi on remaining drives
    			parities[i] = -1             // invalid fi are assigned parity -1
    		}
    		res.metaArr = metaArr
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  9. cmd/erasure-healing-common.go

    	for i, meta := range partsMetadata {
    		if !meta.IsValid() {
    			// Since for majority of the cases erasure.Index matches with erasure.Distribution we can
    			// consider the offline disks as consistent.
    			continue
    		}
    		if !meta.Deleted {
    			if len(meta.Erasure.Distribution) != len(onlineDisks) {
    				// Erasure distribution seems to have lesser
    				// number of items than number of online disks.
    				inconsistent++
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  10. cmd/erasure-healing_test.go

    )
    
    // Tests isObjectDangling function
    func TestIsObjectDangling(t *testing.T) {
    	fi := newFileInfo("test-object", 2, 2)
    	fi.Erasure.Index = 1
    
    	ifi := newFileInfo("test-object", 2, 2)
    	ifi.SetInlineData()
    	ifi.Erasure.Index = 1
    
    	testCases := []struct {
    		name             string
    		metaArr          []FileInfo
    		errs             []error
    		dataErrs         map[int][]int
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 48.5K bytes
    - Click Count (0)
Back to Top