Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 95 for quorum (0.05 seconds)

  1. cmd/erasure-multipart.go

    		return fi, nil, errErasureReadQuorum
    	}
    
    	if writeQuorum < 0 {
    		return fi, nil, errErasureWriteQuorum
    	}
    
    	quorum := readQuorum
    	if write {
    		quorum = writeQuorum
    	}
    
    	// List all online disks.
    	_, modTime, etag := listOnlineDisks(storageDisks, partsMetadata, errs, quorum)
    
    	if write {
    		err = reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	} else {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  2. cmd/peer-s3-server.go

    	localDrives := cloneDrives(globalLocalDrivesMap)
    	globalLocalDrivesMu.RUnlock()
    
    	quorum := (len(localDrives) / 2)
    
    	buckets = make([]BucketInfo, 0, 32)
    	healBuckets := xsync.NewMapOf[string, VolInfo]()
    
    	// lists all unique buckets across drives.
    	if err := listAllBuckets(ctx, localDrives, healBuckets, quorum); err != nil {
    		return nil, err
    	}
    
    	// include deleted buckets in listBuckets output
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  3. 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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  4. 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":
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.7K bytes
    - Click Count (0)
  5. buildscripts/heal-manual.go

    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	opts := madmin.HealOpts{
    		Recursive: true,                  // recursively heal all objects at 'prefix'
    		Remove:    true,                  // remove content that has lost quorum and not recoverable
    		ScanMode:  madmin.HealNormalScan, // by default do not do 'deep' scanning
    	}
    
    	start, _, err := madmClnt.Heal(context.Background(), "healing-rewrite-bucket", "", opts, "", false, false)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 27 09:47:58 GMT 2024
    - 2.3K bytes
    - Click Count (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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  7. docs/distributed/DESIGN.md

    - Write and Read quorum are required to be satisfied only across the erasure set for an object. Healing is also done per object within the erasure set which contains the object.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 8K bytes
    - Click Count (2)
  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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  9. cmd/xl-storage-format-v2.go

    	if quorum <= 0 {
    		quorum = 1
    	}
    	if len(versions) < quorum || len(versions) == 0 {
    		return nil
    	}
    	if len(versions) == 1 {
    		return versions[0]
    	}
    	if quorum == 1 {
    		// No need for non-strict checks if quorum is 1.
    		strict = true
    	}
    	// Shallow copy input
    	versions = append(make([][]xlMetaV2ShallowVersion, 0, len(versions)), versions...)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  10. cmd/erasure-healing_test.go

    		disk := disks[n]
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    		return disk
    	}
    
    	// Remove 4 disks.
    	setDisks(nil, nil, nil, nil)
    
    	// Create delete marker under quorum.
    	objInfo, err := objLayer.DeleteObject(ctx, bucket, object, ObjectOptions{Versioned: true})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Restore...
    	setDisks(orgDisks[:4]...)
    
    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)
Back to Top