Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 74 for dquorum (0.12 seconds)

  1. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  2. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  3. 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)
  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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Feb 13 09:26:38 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 16 08:43:49 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  8. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  10. cmd/object-api-putobject_test.go

    				continue
    			}
    		}
    	}
    }
    
    // Wrapper for calling PutObject tests for both Erasure multiple disks case
    // when quorum is not available.
    func TestObjectAPIPutObjectDiskNotFound(t *testing.T) {
    	ExecObjectLayerDiskAlteredTest(t, testObjectAPIPutObjectDiskNotFound)
    }
    
    // Tests validate correctness of PutObject.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 25.8K bytes
    - Click Count (0)
Back to Top