Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for dquorum (0.04 sec)

  1. cmd/metacache-entries_test.go

    			// We get the both versions, since we only request quorum 1
    			wantSelected: &inputSerialized[2],
    			wantOk:       true,
    		},
    		{
    			name:         "additional version, quorum two",
    			m:            metaCacheEntries{inputSerialized[0], inputSerialized[0], inputSerialized[0], inputSerialized[2]},
    			r:            metadataResolutionParams{dirQuorum: 2, objQuorum: 2, strict: true},
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 31.6K bytes
    - Viewed (0)
  2. cmd/erasure-healing-common_test.go

    					}
    					f.WriteString("oops") // Will cause bitrot error
    					f.Close()
    					break
    				}
    			}
    
    			rQuorum := len(errs) - z.serverPools[0].sets[0].defaultParityCount
    			onlineDisks, modTime, _ := listOnlineDisks(erasureDisks, partsMetadata, test.errs, rQuorum)
    			if !modTime.Equal(test.expectedTime) {
    				t.Fatalf("Expected modTime to be equal to %v but was found to be %v",
    					test.expectedTime, modTime)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    		return objInfo, wquorum, toObjectErr(errMethodNotAllowed, bucket, object)
    	}
    
    	if fi.Deleted {
    		if opts.VersionID == "" || opts.DeleteMarker {
    			return objInfo, wquorum, toObjectErr(errFileNotFound, bucket, object)
    		}
    		// Make sure to return object info to provide extra information.
    		return objInfo, wquorum, toObjectErr(errMethodNotAllowed, bucket, object)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  4. cmd/peer-s3-client.go

    		for i, client := range sys.peerClients {
    			if slices.Contains(client.GetPools(), poolIdx) {
    				perPoolErrs = append(perPoolErrs, errs[i])
    			}
    		}
    		quorum := len(perPoolErrs) / 2
    		poolErrs = append(poolErrs, reduceWriteQuorumErrs(ctx, perPoolErrs, bucketOpIgnoredErrs, quorum))
    	}
    
    	if !opts.Recreate {
    		// when there is no force recreate look for pool
    		// errors to recreate the bucket on all pools.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  5. cmd/erasure-metadata.go

    	return 0, 0, InvalidRange{}
    }
    
    func findFileInfoInQuorum(ctx context.Context, metaArr []FileInfo, modTime time.Time, etag string, quorum int) (FileInfo, error) {
    	// with less quorum return error.
    	if quorum < 1 {
    		return FileInfo{}, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInsufficientOnlineDrives}
    	}
    	metaHashes := make([]string, len(metaArr))
    	h := sha256.New()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  6. cmd/local-locker_test.go

    	wResources := make([]string, 1000)
    	rResources := make([]string, 1000)
    	quorum := 0
    	l := newLocker()
    	ctx := t.Context()
    	for i := range wResources {
    		arg := dsync.LockArgs{
    			UID:       mustGetUUID(),
    			Resources: []string{mustGetUUID()},
    			Source:    t.Name(),
    			Owner:     "owner",
    			Quorum:    &quorum,
    		}
    		ok, err := l.Lock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  7. cmd/erasure-metadata-utils.go

    // GetValueWithQuorum returns the first key which occurs >= quorum number of times.
    func (c counterMap[T]) GetValueWithQuorum(quorum int) (T, bool) {
    	var zero T
    	for x, count := range c {
    		if count >= quorum {
    			return x, true
    		}
    	}
    	return zero, false
    }
    
    // figure out the most commonVersions across disk that satisfies
    // the 'writeQuorum' this function returns "" if quorum cannot
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    func isObjectDangling(metaArr []FileInfo, errs []error, dataErrsByPart map[int][]int) (validMeta FileInfo, ok bool) {
    	// We can consider an object data not reliable
    	// when xl.meta is not found in read quorum disks.
    	// or when xl.meta is not readable in read quorum disks.
    	notFoundMetaErrs, nonActionableMetaErrs := danglingMetaErrsCount(errs)
    
    	notFoundPartsErrs, nonActionablePartsErrs := 0, 0
    	for _, dataErrs := range dataErrsByPart {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    		}
    
    		if isErrReadQuorum(pinfo.Err) && !opts.MetadataChg {
    			// read quorum is returned when the object is visibly
    			// present but its unreadable, we simply ask the writes to
    			// schedule to this pool instead. If there is no quorum
    			// it will fail anyways, however if there is quorum available
    			// with enough disks online but sufficiently inconsistent to
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  10. cmd/metacache-set.go

    				return entries, io.EOF
    			}
    			partN++
    			retries = 0
    		}
    	}
    }
    
    // getListQuorum interprets list quorum values and returns appropriate
    // acceptable quorum expected for list operations
    func getListQuorum(quorum string, driveCount int) int {
    	switch quorum {
    	case "disk":
    		return 1
    	case "reduced":
    		return 2
    	case "optimal":
    		return (driveCount + 1) / 2
    	case "auto":
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
Back to top