- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 26 for derrs (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 objectCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (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) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jul 12 20:51:54 GMT 2024 - 11.1K bytes - Click Count (1) -
cmd/storage-rest-client.go
for i := range errs { errs[i] = toStorageErr(err) } return errs } dErrResp := &DeleteVersionsErrsResp{} decoder := msgpNewReader(reader) defer readMsgpReaderPoolPut(decoder) if err = dErrResp.DecodeMsg(decoder); err != nil { for i := range errs { errs[i] = toStorageErr(err) } return errs } for i, dErr := range dErrResp.Errs { if dErr != "" {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (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 { return format.Erasure.This
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 37K bytes - Click Count (1) -
cmd/config-current.go
if err != nil { errs = append(errs, fmt.Errorf("Unable to apply heal config: %w", err)) } else { globalHealConfig.Update(healCfg) } case config.BatchSubSys: batchCfg, err := batch.LookupConfig(s[config.BatchSubSys][config.Default]) if err != nil { errs = append(errs, fmt.Errorf("Unable to apply batch config: %w", err)) } else {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 28.5K bytes - Click Count (0) -
cmd/erasure-healing-common.go
inconsistent++ } } } erasureDistributionReliable := inconsistent <= len(partsMetadata)/2 metaErrs := make([]error, len(errs)) for i := range onlineDisks { if errs[i] != nil { metaErrs[i] = errs[i] continue } if onlineDisks[i] == OfflineDisk { metaErrs[i] = errDiskNotFound continue } meta := partsMetadata[i] corrupted := false
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12K bytes - Click Count (0) -
cmd/metacache-server-pool.go
allAtEOF = false } errs[i] = err }(len(errs), set) errs = append(errs, nil) } } mu.Unlock() // Gather results to a single channel. // Quorum is one since we are merging across sets. err := mergeEntryChannels(ctx, inputs, results, 1) cancelList() wg.Wait() // we should return 'errs' from per disk if isAllNotFound(errs) { if isAllVolumeNotFound(errs) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12.9K bytes - Click Count (0) -
cmd/format-erasure_test.go
} for _, erasureDir := range erasureDirs { defer os.RemoveAll(erasureDir) } endpoints := mustGetNewEndpoints(0, 8, erasureDirs...) storageDisks, errs := initStorageDisksWithErrors(endpoints, storageOpts{cleanUp: false, healthCheck: false}) for _, err := range errs { if err != nil && err != errDiskNotFound { t.Fatal(err) } } format := newFormatErasureV3(1, 8)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.7K bytes - Click Count (0) -
cmd/naughty-disk_test.go
func (d *naughtyDisk) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error { if err := d.calcError(); err != nil { errs := make([]error, len(versions)) for i := range errs { errs[i] = err } return errs } return d.disk.DeleteVersions(ctx, volume, versions, opts) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 25 05:41:04 GMT 2025 - 10.1K bytes - Click Count (0) -
cmd/peer-s3-client.go
if healBucketErr := reduceWriteQuorumErrs(ctx, errs, bucketOpIgnoredErrs, len(errs)/2+1); healBucketErr != nil { return madmin.HealResultItem{}, toObjectErr(healBucketErr, bucket) } res := madmin.HealResultItem{ Type: madmin.HealItemBucket, Bucket: bucket, SetCount: -1, // explicitly set an invalid value -1, for bucket heal scenario } for i, err := range errs { if err == nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.6K bytes - Click Count (0)