- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for dataDirs (0.05 sec)
-
cmd/erasure-metadata-utils.go
func reduceCommonDataDir(dataDirs []string, writeQuorum int) (dataDir string) { dataDirsCount := make(map[string]int) for _, ddir := range dataDirs { dataDirsCount[ddir]++ } maxCnt := 0 for ddir, count := range dataDirsCount { if maxCnt < count { maxCnt = count dataDir = ddir } } if maxCnt >= writeQuorum { return dataDir } return "" }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.7K bytes - Viewed (0) -
cmd/erasure-object.go
versions = dversions } break } } dataDir = reduceCommonDataDir(dataDirs, writeQuorum) } // We can safely allow RenameData errors up to len(er.getDisks()) - writeQuorum // otherwise return failure. return evalDisks(disks, errs), versions, dataDir, err }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
dataDirs, err := erasureDisks[0].ListDir(context.Background(), minioMetaMultipartBucket, minioMetaMultipartBucket, uploadIDPath, -1) if err != nil { t.Fatalf("%s : %s", instanceType, err.Error()) } var dataDir string for _, folder := range dataDirs { if strings.HasSuffix(folder, SlashSeparator) { dataDir = folder break } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.4K bytes - Viewed (0) -
cmd/erasure-healing.go
notFoundMetaErrs, nonActionableMetaErrs := danglingMetaErrsCount(errs) notFoundPartsErrs, nonActionablePartsErrs := 0, 0 for _, dataErrs := range dataErrsByPart { if nf, na := danglingPartErrsCount(dataErrs); nf > notFoundPartsErrs { notFoundPartsErrs, nonActionablePartsErrs = nf, na } } for _, m := range metaArr { if m.IsValid() { validMeta = m
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.6K bytes - Viewed (0) -
cmd/data-scanner.go
return nil }) if err != nil { return err } if foundObjects && globalIsErasure { // If we found an object in erasure mode, we skip subdirs (only datadirs)... break } // If we have many subfolders, compact ourself. shouldCompact := f.newCache.Info.Name != folder.name && len(existingFolders)+len(newFolders) >= dataScannerCompactAtFolders ||
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.5K bytes - Viewed (0) -
cmd/erasure-healing_test.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 48.5K bytes - Viewed (0) -
cmd/erasure-healing-common.go
if verifyErr != nil { dataErrsByPart[p][i] = convPartErrToInt(verifyErr) } else { dataErrsByPart[p][i] = verifyResp.Results[p] } } } // Build dataErrs by disk from dataErrs by part for part, disks := range dataErrsByPart { for disk := range disks { dataErrsByDisk[disk][part] = dataErrsByPart[part][disk] } } return
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 12K bytes - Viewed (0) -
cmd/storage-datatypes.go
} // GetDataDir returns an expected dataDir given FileInfo // - deleteMarker returns "delete-marker" // - returns "legacy" if FileInfo is XLV1 and DataDir is // empty, returns DataDir otherwise // - returns "dataDir" func (fi FileInfo) GetDataDir() string { if fi.Deleted { return "delete-marker" } if fi.XLV1 && fi.DataDir == "" { return "legacy" } return fi.DataDir }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 17.4K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
}{ { // transitioned object version xlmeta: xlMetaV2Object{ VersionID: vID, DataDir: dataDir, MetaSys: transitioned, }, uses: false, }, { // to be restored (requires object version to be transitioned) xlmeta: xlMetaV2Object{ VersionID: vID, DataDir: dataDir, MetaSys: transitioned, MetaUser: toBeRestored, }, uses: false, },
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37.8K bytes - Viewed (0) -
cmd/xl-storage-format-v2.go
if fi.Deleted { err = x.addVersion(ventry) } if x.SharedDataDirCount(ver.ObjectV2.VersionID, ver.ObjectV2.DataDir) > 0 { // Found that another version references the same dataDir // we shouldn't remove it, and only remove the version instead return "", nil } return uuid.UUID(ver.ObjectV2.DataDir).String(), err } if fi.Deleted { err = x.addVersion(ventry) return "", err }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 65.6K bytes - Viewed (1)