- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 153 for derrs (0.09 sec)
-
cmd/erasure-healing.go
if err != nil { m, derr := er.deleteIfDangling(ctx, bucket, object, partsMetadata, errs, nil, ObjectOptions{ VersionID: versionID, }) errs = make([]error, len(errs)) if derr == nil { derr = errFileNotFound if versionID != "" { derr = errFileVersionNotFound } // We did find a new danging object
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
} partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true) fi, err := getLatestFileInfo(ctx, partsMetadata, z.serverPools[0].sets[0].defaultParityCount, errs) if err != nil { t.Fatalf("Failed to getLatestFileInfo %v", err) } for j := range partsMetadata { if errs[j] != nil { t.Fatalf("expected error to be nil: %s", errs[j])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
cmd/notification.go
workers *workers.Workers errs []NotificationPeerErr retryCount int } // WithNPeers returns a new NotificationGroup with length of errs slice upto nerrs, // upon Wait() errors are returned collected from all tasks. func WithNPeers(nerrs int) *NotificationGroup { if nerrs <= 0 { nerrs = 1 } wk, _ := workers.New(nerrs)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
cmd/prepare-storage.go
// Attempt to load all `format.json` from all disks. formatConfigs, sErrs := loadFormatErasureAll(storageDisks, false) if err := checkDiskFatalErrs(sErrs); err != nil { return nil, err } for i, err := range sErrs { if err != nil && !errors.Is(err, errXLBackend) && !errors.Is(err, errUnformattedDisk) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun May 19 08:06:49 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/erasure-metadata.go
} return errFileCorrupt }, index) } // Wait for all the routines. mErrs := g.Wait() err := reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, quorum) return evalDisks(disks, mErrs), err } func commonParity(parities []int, defaultParityCount int) int { N := len(parities) occMap := make(map[int]int)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.4K bytes - Viewed (0) -
cmd/storage-rest-client.go
for i := range errs { errs[i] = toStorageErr(err) } return errs } dErrResp := &DeleteVersionsErrsResp{} if err = gob.NewDecoder(reader).Decode(dErrResp); err != nil { for i := range errs { errs[i] = toStorageErr(err) } return errs } for i, dErr := range dErrResp.Errs { errs[i] = toStorageErr(dErr) } return errs } // RenameFile - renames a file.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
cmd/erasure-sets.go
drive := endpoints.GetString(i) state := madmin.DriveStateCorrupt switch { case format != nil: state = madmin.DriveStateOk case sErrs[i] == errUnformattedDisk: state = madmin.DriveStateMissing case sErrs[i] == errDiskNotFound: state = madmin.DriveStateOffline } beforeDrives[i] = madmin.HealDriveInfo{ UUID: func() string { if format != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0) -
cmd/format-erasure.go
// 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.2K bytes - Viewed (0) -
pkg/config/validation/envoyfilter/envoyfilter.go
errs = validation.AppendValidation(errs, fmt.Errorf("Envoy filter: missing applyTo")) // nolint: stylecheck continue } if cp.Patch == nil { errs = validation.AppendValidation(errs, fmt.Errorf("Envoy filter: missing patch")) // nolint: stylecheck continue } if cp.Patch.Operation == networking.EnvoyFilter_Patch_INVALID {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 00:31:03 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/config/validation/agent/extensionprovider.go
errs = AppendErrors(errs, err) } if config.PathPrefix != "" { if _, err := url.Parse(config.PathPrefix); err != nil { errs = AppendErrors(errs, fmt.Errorf("invalid pathPrefix %s: %v", config.PathPrefix, err)) } if !strings.HasPrefix(config.PathPrefix, "/") { errs = AppendErrors(errs, fmt.Errorf("pathPrefix should begin with `/` but found %q", config.PathPrefix)) } } return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 11K bytes - Viewed (0)