Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newNaughtyDisk (0.07 sec)

  1. cmd/erasure-object_test.go

    		}
    		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()
    		xl.getDisks = func() []StorageAPI {
    			return erasureDisks
    		}
    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/naughty-disk_test.go

    	errors map[int]error
    	// The error to return when no error value is programmed
    	defaultErr error
    	// The current API call number
    	callNR int
    	// Data protection
    	mu sync.Mutex
    }
    
    func newNaughtyDisk(d StorageAPI, errs map[int]error, defaultErr error) *naughtyDisk {
    	return &naughtyDisk{disk: d, errors: errs, defaultErr: defaultErr}
    }
    
    func (d *naughtyDisk) String() string {
    	return d.disk.String()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. cmd/object-api-multipart_test.go

    	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()
    
    	uploadIDs = append(uploadIDs, res.UploadID)
    
    	// Create multipart parts.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
Back to top