- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newNaughtyDisk (0.08 sec)
-
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) -
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) -
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)