Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 83 for dquorum (0.06 seconds)

  1. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 27 09:47:58 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  2. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 8K bytes
    - Click Count (2)
  3. cmd/metacache-entries.go

    			selected = prefer
    			objsAgree++
    			continue
    		}
    	}
    
    	// Return dir entries, if enough...
    	if selected != nil && selected.isDir() && dirExists >= r.dirQuorum {
    		return selected, true
    	}
    
    	// If we would never be able to reach read quorum.
    	if objsValid < r.objQuorum {
    		return nil, false
    	}
    
    	// If all objects agree.
    	if selected != nil && objsAgree == objsValid {
    		return selected, true
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  4. 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
    			}
    		}
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Feb 13 09:26:38 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  5. cmd/erasure-server-pool-rebalance.go

    	listingQuorum := (set.setDriveCount + 1) / 2
    
    	// How to resolve partial results.
    	resolver := metadataResolutionParams{
    		dirQuorum: listingQuorum, // make sure to capture all quorum ratios
    		objQuorum: listingQuorum, // make sure to capture all quorum ratios
    		bucket:    bucketName,
    	}
    
    	err := listPathRaw(ctx, listPathRawOptions{
    		disks:          disks,
    		bucket:         bucketName,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  6. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  7. internal/config/api/help.go

    			Optional:    true,
    			Type:        "duration",
    		},
    		config.HelpKV{
    			Key:         apiListQuorum,
    			Description: `set the acceptable quorum expected for list operations e.g. "optimal", "reduced", "disk", "strict", "auto"` + defaultHelpPostfix(apiListQuorum),
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 16 08:43:49 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  8. 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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 48.5K bytes
    - Click Count (0)
  9. cmd/format-erasure_test.go

    		for j := range setDriveCount {
    			newFormat := format.Clone()
    			newFormat.Erasure.This = format.Erasure.Sets[i][j]
    			formats[i*setDriveCount+j] = newFormat
    		}
    	}
    
    	// Return a format from list of formats in quorum.
    	quorumFormat, err := getFormatErasureInQuorum(formats)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Check if the reference format and input formats are same.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
Back to Top