Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 516 for ensure (0.04 seconds)

  1. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  2. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  3. cmd/erasure-sets_test.go

    	if err != errInvalidArgument {
    		t.Fatalf("Expecting error, got %s", err)
    	}
    
    	// Initializes all erasure disks
    	storageDisks, format, err := waitForFormatErasure(true, endpoints, 1, 1, 16, "")
    	if err != nil {
    		t.Fatalf("Unable to format drives for erasure, %s", err)
    	}
    
    	ep := PoolEndpoints{Endpoints: endpoints}
    
    	parity, err := ecDrivesNoConfig(16)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  4. docs/screenshots/erasure-code.svg

    erasure-code.svg...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Apr 15 00:21:57 GMT 2017
    - 17.4K bytes
    - Click Count (0)
  5. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  6. cmd/erasure-encode.go

    	return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers))
    }
    
    // Encode reads from the reader, erasure-encodes the data and writes to the writers.
    func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) {
    	writer := &multiWriter{
    		writers:     writers,
    		writeQuorum: quorum,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 15 00:11:04 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  7. 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]
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  8. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 48.5K bytes
    - Click Count (0)
  9. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  10. cmd/sts-handlers_test.go

    		{serverType: "ErasureSD", signer: signerV4},
    		// Init and run test on ErasureSD backend, with tls enabled.
    		{serverType: "ErasureSD", signer: signerV4, secure: true},
    		// Init and run test on Erasure backend.
    		{serverType: "Erasure", signer: signerV4},
    		// Init and run test on ErasureSet backend.
    		{serverType: "ErasureSet", signer: signerV4},
    	}
    	testCases := []*TestSuiteIAM{}
    	for _, bt := range baseTestCases {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 103.4K bytes
    - Click Count (1)
Back to Top