- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for erasureDisks (0.12 sec)
-
cmd/erasure-object_test.go
for i := 0; i <= f; i++ { diskErrors[i] = nil } erasureDisks := xl.getDisks() for i := range erasureDisks[:9] { switch diskType := erasureDisks[i].(type) { case *naughtyDisk: erasureDisks[i] = newNaughtyDisk(diskType.disk, diskErrors, errFaultyDisk) default: erasureDisks[i] = newNaughtyDisk(erasureDisks[i], diskErrors, errFaultyDisk) } } z.serverPools[0].erasureDisksMu.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 36.8K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
if errs[j] != nil { t.Fatalf("expected error to be nil: %s", errs[j]) } partsMetadata[j].ModTime = test.modTimes[j] } if erasureDisks, err = writeUniqueFileInfo(ctx, erasureDisks, "", bucket, object, partsMetadata, diskCount(erasureDisks)); err != nil { t.Fatal(ctx, err) } tamperedIndex := -1 switch test._tamperBackend { case deletePart:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 15:19:10 UTC 2024 - 23.1K bytes - Viewed (0) -
cmd/erasure-healing_test.go
// Test 1: Remove the object backend files from the first disk. z := objLayer.(*erasureServerPools) er := z.serverPools[0].sets[0] erasureDisks := er.getDisks() firstDisk := erasureDisks[0] secondDisk := erasureDisks[1] fileInfos, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true) fi, err := getLatestFileInfo(ctx, fileInfos, er.defaultParityCount, errs) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
cmd/erasure-sets_test.go
defer cancel() nDisks := 16 // Maximum disks. var erasureDisks []string for i := 0; i < nDisks; i++ { // Do not attempt to create this path, the test validates // so that newErasureSets initializes non existing paths // and successfully returns initialized object layer. disk := filepath.Join(globalTestTmpDir, "minio-"+nextSuffix()) erasureDisks = append(erasureDisks, disk) defer os.RemoveAll(disk) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 12 07:21:56 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/erasure-sets.go
// current design. type erasureSets struct { sets []*erasureObjects // Reference format. format *formatErasureV3 // erasureDisks mutex to lock erasureDisks. erasureDisksMu sync.RWMutex // Re-ordered list of disks per set. erasureDisks [][]StorageAPI // Distributed locker clients. erasureLockers setsDsyncLockers // Distributed lock owner (constant per running instance).
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
cmd/object-api-multipart_test.go
} z := obj.(*erasureServerPools) er := z.serverPools[0].sets[0] erasureDisks := er.getDisks() ridx := rand.Intn(len(erasureDisks)) z.serverPools[0].erasureDisksMu.Lock() er.getDisks = func() []StorageAPI { erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk) return erasureDisks } z.serverPools[0].erasureDisksMu.Unlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 88.8K bytes - Viewed (0) -
cmd/test-utils_test.go
func getRandomDisks(n int) ([]string, error) { var erasureDisks []string for i := 0; i < n; i++ { path, err := os.MkdirTemp(globalTestTmpDir, "minio-") if err != nil { // Remove directories created so far. removeRoots(erasureDisks) return nil, err } erasureDisks = append(erasureDisks, path) } return erasureDisks, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0) -
cmd/object-api-utils_test.go
// Now check if we actually wrote to backend (regardless of the response // returned by the server). z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0] erasureDisks := xl.getDisks() parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName, "", false, false) for i := range parts { if errs[i] == nil { if parts[i].Name == objectName {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
cmd/post-policy_test.go
// Now check if we actually wrote to backend (regardless of the response // returned by the server). z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0] erasureDisks := xl.getDisks() parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName+"/upload.txt", "", false, false) for i := range parts { if errs[i] == nil { if parts[i].Name == objectName+"/upload.txt" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0)