- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for countErrs (0.13 sec)
-
cmd/erasure-encode.go
// return a quorum error to HealFile(). nilCount := countErrs(p.errs, nil) if nilCount >= p.writeQuorum { return nil } writeErr := reduceWriteQuorumErrs(ctx, p.errs, objectOpIgnoredErrs, p.writeQuorum) return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers)) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/format-erasure.go
return json.Marshal(formatV3) } // countErrs - count a specific error. func countErrs(errs []error, err error) int { i := 0 for _, err1 := range errs { if err1 == err || errors.Is(err1, err) { i++ } } return i } // Does all errors indicate we need to initialize all disks?. func shouldInitErasureDisks(errs []error) bool { return countErrs(errs, errUnformattedDisk) == len(errs) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
cmd/storage-rest-server.go
// the server. if countErrs(errs, errUnsupportedDisk) == len(errs) { return errUnsupportedDisk } if countErrs(errs, errDiskAccessDenied) == len(errs) { return errDiskAccessDenied } if countErrs(errs, errFileAccessDenied) == len(errs) { return errDiskAccessDenied } if countErrs(errs, errDiskNotDir) == len(errs) { return errDiskNotDir }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 45.7K bytes - Viewed (0) -
cmd/global-heal.go
// proceed to heal nonetheless. entry, _ = entries.firstFound() } jt.Take() go healEntry(bucket, *entry) }, finished: func(errs []error) { if countErrs(errs, nil) != len(errs) { retErr = fmt.Errorf("one or more errors reported during listing: %v", errors.Join(errs...)) } }, }) jt.Wait() // synchronize all the concurrent heal jobs if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/erasure-object.go
) for success := range done { totalResp++ if success { validResp++ } if totalResp >= minDisks && opts.FastGetObjInfo { rw.Lock() ok := countErrs(errs, errFileNotFound) >= minDisks || countErrs(errs, errFileVersionNotFound) >= minDisks rw.Unlock() if ok { err = errFileNotFound if opts.VersionID != "" { err = errFileVersionNotFound } break }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
cmd/erasure-healing_test.go
_, err = objLayer.HealObject(ctx, bucket, object, "", hopts) if err != nil { t.Fatal(err) } fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true) if countErrs(errs, nil) != len(fileInfos) { t.Fatal("Expected all xl.meta healed, but partial heal detected") } fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", minioMetaBucket, cfgFile, "", false, true)
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-healing.go
} if len(entries) > 0 { return errVolumeNotEmpty } return nil }, index) } return g.Wait() } func isAllVolumeNotFound(errs []error) bool { return countErrs(errs, errVolumeNotFound) == len(errs) } // isAllNotFound will return if any element of the error slice is not // errFileNotFound, errFileVersionNotFound or errVolumeNotFound.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 02 17:50:41 UTC 2024 - 34.4K bytes - Viewed (0) -
cmd/erasure-sets.go
// Copy "after" drive state too from before. for k, v := range beforeDrives { res.Before.Drives[k] = v res.After.Drives[k] = v } if countErrs(sErrs, errUnformattedDisk) == 0 { return res, errNoHealRequired } if !reflect.DeepEqual(s.format, refFormat) { // Format is corrupted and unrecognized by the 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) -
guava/src/com/google/common/cache/AbstractCache.java
* Cache#invalidate invalidations}. */ void recordEviction(); /** * Returns a snapshot of this counter's values. Note that this may be an inconsistent view, as * it may be interleaved with update operations. */ CacheStats snapshot(); } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/AbstractCache.java
* Cache#invalidate invalidations}. */ void recordEviction(); /** * Returns a snapshot of this counter's values. Note that this may be an inconsistent view, as * it may be interleaved with update operations. */ CacheStats snapshot(); } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 9.1K bytes - Viewed (0)