Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for erasureDisks (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top