- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 74 for dquorum (0.12 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
internal/config/api/help.go
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) -
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) -
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) -
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)