Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 101 for Quorum (0.18 sec)

  1. cmd/erasure-object.go

    func (er erasureObjects) getObjectInfoAndQuorum(ctx context.Context, bucket, object string, opts ObjectOptions) (objInfo ObjectInfo, wquorum int, err error) {
    	fi, _, _, err := er.getObjectFileInfo(ctx, bucket, object, opts, false)
    	if err != nil {
    		return objInfo, er.defaultWQuorum(), toObjectErr(err, bucket, object)
    	}
    
    	wquorum = fi.WriteQuorum(er.defaultWQuorum())
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  2. 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)
  3. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  4. 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  5. 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)
  6. cmd/erasure-object_test.go

    				t.Errorf("Expected %s, got %s", tt.expectedError, err)
    			}
    			if tt.expectedReadQuorum != actualReadQuorum {
    				t.Errorf("Expected Read Quorum %d, got %d", tt.expectedReadQuorum, actualReadQuorum)
    			}
    			if tt.expectedWriteQuorum != actualWriteQuorum {
    				t.Errorf("Expected Write Quorum %d, got %d", tt.expectedWriteQuorum, actualWriteQuorum)
    			}
    		})
    	}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2_test.go

    		name        string
    		input       [][]xlMetaV2ShallowVersion
    		quorum      int
    		reqVersions int
    		want        []xlMetaV2ShallowVersion
    	}{
    		{
    			name: "obj-on-one",
    			input: [][]xlMetaV2ShallowVersion{
    				0: {vDelMarker, vObj}, // disk 0
    				1: {vDelMarker},       // disk 1
    				2: {vDelMarker},       // disk 2
    			},
    			quorum:      2,
    			reqVersions: 0,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  8. .github/workflows/run-mint.sh

    sleep 1m
    
    docker system prune -f || true
    docker volume prune -f || true
    docker volume rm $(docker volume ls -q -f dangling=true) || true
    
    # Stop two nodes, one of each pool, to check that all S3 calls work while quorum is still there
    [ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio2
    [ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio6
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jan 20 14:49:07 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  9. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 27 09:47:58 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  10. 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.
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 26 09:25:50 UTC 2025
    - 8K bytes
    - Viewed (1)
Back to top