Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 103 for Quorum (0.03 sec)

  1. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  3. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  4. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 27 09:47:58 UTC 2024
    - 2.3K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  6. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  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.
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Feb 26 09:25:50 UTC 2025
    - 8K bytes
    - Viewed (2)
  8. cmd/shared-lock.go

    			continue
    		}
    
    	keepLock:
    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case <-lkctx.Context().Done():
    				// The context of the lock is canceled, this can happen
    				// if one lock lost quorum due to cluster instability
    				// in that case, try to lock again.
    				break keepLock
    			case ld.lockContext <- lkctx:
    				// Send the lock context to anyone asking for it
    			}
    		}
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  9. 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  10. cmd/erasure.go

    	closeStorageDisks(er.getDisks()...)
    	return nil
    }
    
    // defaultWQuorum write quorum based on setDriveCount and defaultParityCount
    func (er erasureObjects) defaultWQuorum() int {
    	dataCount := er.setDriveCount - er.defaultParityCount
    	if dataCount == er.defaultParityCount {
    		return dataCount + 1
    	}
    	return dataCount
    }
    
    // defaultRQuorum read quorum based on setDriveCount and defaultParityCount
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.1K bytes
    - Viewed (0)
Back to top