Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for erasureDisks (0.06 sec)

  1. cmd/erasure-healing-common_test.go

    	// Test 2: Not synchronized modtime
    	erasureDisks = s.getDisks()
    	partsMetadataBackup := partsMetadata[0]
    	partsMetadata[0].ModTime = partsMetadata[0].ModTime.Add(-1 * time.Hour)
    
    	errs = make([]error, len(erasureDisks))
    	_, _ = checkObjectWithAllParts(ctx, erasureDisks, partsMetadata,
    		errs, fi, false, bucket, object, madmin.HealDeepScan)
    
    	for diskIndex, disk := range erasureDisks {
    		if diskIndex == 0 && disk != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  4. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  5. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  6. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.6K bytes
    - Viewed (0)
Back to top