Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 65 for dquorum (0.72 sec)

  1. cmd/storage-rest-common.go

    	storageRESTBitrotHash       = "bhash"
    	storageRESTDiskID           = "did"
    	storageRESTForceDelete      = "fdel"
    	storageRESTGlob             = "glob"
    	storageRESTMetrics          = "metrics"
    	storageRESTDriveQuorum      = "dquorum"
    	storageRESTOrigVolume       = "ovol"
    	storageRESTInclFreeVersions = "incl-fv"
    	storageRESTRange            = "rng"
    )
    
    type nsScannerOptions struct {
    	DiskID   string          `msg:"id"`
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. cmd/storage-datatypes.go

    }
    
    // WriteQuorum returns expected write quorum for this FileInfo
    func (fi FileInfo) WriteQuorum(dquorum int) int {
    	if fi.Deleted {
    		return dquorum
    	}
    	quorum := fi.Erasure.DataBlocks
    	if fi.Erasure.DataBlocks == fi.Erasure.ParityBlocks {
    		quorum++
    	}
    	return quorum
    }
    
    // ReadQuorum returns expected read quorum for this FileInfo
    func (fi FileInfo) ReadQuorum(dquorum int) int {
    	if fi.Deleted {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. cmd/server-main.go

    	// Initializing sub-systems needs a retry mechanism for
    	// the following reasons:
    	//  - Read quorum is lost just after the initialization
    	//    of the object layer.
    	//  - Write quorum not met when upgrading configuration
    	//    version is needed, migration is needed etc.
    	rquorum := InsufficientReadQuorum{}
    	wquorum := InsufficientWriteQuorum{}
    
    	// One of these retriable errors shall be retried.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  7. 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)
  8. cmd/object-api-errors.go

    func isErrReadQuorum(err error) bool {
    	var rquorum InsufficientReadQuorum
    	return errors.As(err, &rquorum)
    }
    
    // isErrWriteQuorum check if the error type is InsufficientWriteQuorum
    func isErrWriteQuorum(err error) bool {
    	var rquorum InsufficientWriteQuorum
    	return errors.As(err, &rquorum)
    }
    
    // isErrObjectNotFound - Check if error type is ObjectNotFound.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  9. buildscripts/multipart-quorum-test.sh

    Krishnan Parthasarathi <******@****.***> 1725619883 -0700
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Sep 06 10:51:23 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. 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)
Back to top