Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 67 for Erasure (0.17 sec)

  1. cmd/erasure.go

    	// Shuffle buckets to ensure total randomness of buckets, being scanned.
    	// Otherwise same set of buckets get scanned across erasure sets always.
    	// at any given point in time. This allows different buckets to be scanned
    	// in different order per erasure set, this wider spread is needed when
    	// there are lots of buckets with different order of objects in them.
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  2. cmd/format-erasure.go

    	formatV2.Format = formatBackendErasure
    	formatV2.Erasure.Version = formatErasureVersionV2
    	formatV2.Erasure.DistributionAlgo = formatErasureVersionV2DistributionAlgoV1
    	formatV2.Erasure.This = formatV1.Erasure.Disk
    	formatV2.Erasure.Sets = make([][]string, 1)
    	formatV2.Erasure.Sets[0] = make([]string, len(formatV1.Erasure.JBOD))
    	copy(formatV2.Erasure.Sets[0], formatV1.Erasure.JBOD)
    
    	return json.Marshal(formatV2)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  3. 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
    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)
  4. cmd/erasure-multipart.go

    	case size < fi.Erasure.BlockSize:
    		// No need to allocate fully fi.Erasure.BlockSize buffer if the incoming data is smaller.
    		buffer = make([]byte, size, 2*size+int64(fi.Erasure.ParityBlocks+fi.Erasure.DataBlocks-1))
    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    		buffer = buffer[:fi.Erasure.BlockSize]
    	}
    	writers := make([]io.Writer, len(onlineDisks))
    	for i, disk := range onlineDisks {
    		if disk == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    		errs, latestMeta, 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
    		}
    	}
    
    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)
  6. 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 := 0; i < len(refFormat.Erasure.Sets); i++ {
    		for j := 0; j < len(refFormat.Erasure.Sets[0]); j++ {
    			if refFormat.Erasure.Sets[i][j] == format.Erasure.This {
    				return i, j, nil
    			}
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  7. 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 {
    		test := test
    		t.Run("", func(t *testing.T) {
    			_, err := xl.GetObjectInfo(ctx, "bucket", "dir/obj", ObjectOptions{})
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  8. cmd/format-erasure_test.go

    		t.Fatal(err)
    	}
    	if formatV3.Erasure.This != m.Erasure.Disk {
    		t.Fatalf("expected drive uuid: %s, got: %s", m.Erasure.Disk, formatV3.Erasure.This)
    	}
    	if len(formatV3.Erasure.Sets) != 1 {
    		t.Fatalf("expected single set after migrating from v1 to v3, but found %d", len(formatV3.Erasure.Sets))
    	}
    	if !reflect.DeepEqual(formatV3.Erasure.Sets[0], m.Erasure.JBOD) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  9. cmd/erasure-decode_test.go

    			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 {
    			t.Fatalf("Test %d: failed to create erasure test file: %v", i, err)
    		}
    		if n != test.data {
    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)
  10. cmd/erasure-metadata-utils.go

    			continue
    		}
    		// check if erasure distribution order matches the index
    		// position if this is not correct we discard the disk
    		// and move to collect others
    		if distribution[i] != meta.Erasure.Index {
    			inconsistent++ // keep track of inconsistent entries
    			continue
    		}
    		shuffledDisks[meta.Erasure.Index-1] = disks[i]
    		shuffledPartsMetadata[meta.Erasure.Index-1] = metaArr[i]
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 11.3K bytes
    - Viewed (0)
Back to top