Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 64 for dquorum (0.24 sec)

  1. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  2. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex.go

    	tolerance := len(restClnts) / 2
    
    	// Quorum is effectively = total clients subtracted with tolerance limit
    	quorum := len(restClnts) - tolerance
    	if !isReadLock {
    		// In situations for write locks, as a special case
    		// to avoid split brains we make sure to acquire
    		// quorum + 1 when tolerance is exactly half of the
    		// total locker clients.
    		if quorum == tolerance {
    			quorum++
    		}
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  5. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (3)
  6. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  8. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 78.5K bytes
    - Viewed (0)
  9. buildscripts/multipart-quorum-test.sh

    Krishnan Parthasarathi <******@****.***> 1725619883 -0700
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top