- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for dataDir (0.06 sec)
-
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/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/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-healing_test.go
} err = firstDisk.Delete(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{ Recursive: false, Immediate: false, }) if err != nil { t.Errorf("Failure during deleting part.1 - %v", err) } err = firstDisk.WriteAll(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{}) if err != nil { t.Errorf("Failure during creating part.1 - %v", err)
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/xl-storage-format-v1_gen.go
case "VersionID": z.VersionID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "VersionID") return } case "DataDir": z.DataDir, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "DataDir") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err) return } } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Dec 15 22:50:12 UTC 2024 - 41.4K bytes - Viewed (0) -
cmd/erasure-healing-common.go
meta := partsMetadata[i] corrupted := false if filterByETag { corrupted = meta.Metadata["etag"] != latestMeta.Metadata["etag"] } else { corrupted = !meta.ModTime.Equal(latestMeta.ModTime) || meta.DataDir != latestMeta.DataDir } if corrupted { metaErrs[i] = errFileCorrupt partsMetadata[i] = FileInfo{} onlineDisks[i] = nil continue } if erasureDistributionReliable {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 12K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
} } partsMetadata[0] = partsMetadataBackup // Revert before going to the next test // Test 3: Not synchronized DataDir erasureDisks = s.getDisks() partsMetadataBackup = partsMetadata[1] partsMetadata[1].DataDir = "foo-random" errs = make([]error, len(erasureDisks)) _, _ = checkObjectWithAllParts(ctx, erasureDisks, partsMetadata,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 22.4K bytes - Viewed (0) -
cmd/erasure-metadata_test.go
} } } func TestFindFileInfoInQuorum(t *testing.T) { getNFInfo := func(n int, quorum int, t int64, dataDir string, succModTimes []time.Time, numVersions []int) []FileInfo { fi := newFileInfo("test", 8, 8) fi.AddObjectPart(1, "etag", 100, 100, UTCNow(), nil, nil) fi.ModTime = time.Unix(t, 0) fi.DataDir = dataDir fis := make([]FileInfo, n) for i := range fis { fis[i] = fi fis[i].Erasure.Index = i + 1
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.4K bytes - Viewed (0) -
cmd/erasure-multipart.go
readQuorum := fi.ReadQuorum(er.defaultRQuorum()) // Read Part info for all parts partPath := pathJoin(uploadIDPath, fi.DataDir) + SlashSeparator // List parts in quorum partNums, err := er.listParts(ctx, onlineDisks, partPath, readQuorum) if err != nil { // This means that fi.DataDir, is not yet populated so we // return an empty response. if errors.Is(err, errFileNotFound) { return result, nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0) -
cmd/erasure-healing.go
// differentiate it with dstDataDir for readability // srcDataDir is the one used with newBitrotReader() // to read existing content. srcDataDir := latestMeta.DataDir dstDataDir := latestMeta.DataDir if latestMeta.XLV1 { dstDataDir = migrateDataDir } var inlineBuffers []*bytes.Buffer if !latestMeta.Deleted && !latestMeta.IsRemote() { if latestMeta.InlineData() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.6K bytes - Viewed (0)