- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for toObjectErr (0.06 sec)
- 
				
				cmd/erasure-object.goif err != nil { return objInfo, toObjectErr(err, bucket, object) } objInfo = fi.ToObjectInfo(bucket, object, opts.Versioned || opts.VersionSuspended) if fi.Deleted { if opts.VersionID == "" || opts.DeleteMarker { return objInfo, toObjectErr(errFileNotFound, bucket, object) } // Make sure to return object info to provide extra information. return objInfo, toObjectErr(errMethodNotAllowed, bucket, object) }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0)
- 
				
				cmd/erasure-multipart.goreturn pi, toObjectErr(errInvalidArgument) } uploadIDPath := er.getUploadIDDir(bucket, object, uploadID) // Validates if upload ID exists. fi, _, err := er.checkUploadIDExists(ctx, bucket, object, uploadID, true) if err != nil { if errors.Is(err, errVolumeNotFound) { return pi, toObjectErr(err, bucket) } return pi, toObjectErr(err, bucket, object, uploadID) } Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0)
- 
				
				cmd/erasure-object_test.goif err != nil { if err != toObjectErr(errErasureReadQuorum, bucket, object) { t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err) } } if gr != nil { _, err = io.Copy(io.Discard, gr) if err != toObjectErr(errErasureReadQuorum, bucket, object) {Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 38.3K bytes - Viewed (0)
- 
				
				cmd/peer-s3-client.goreturn madmin.HealResultItem{}, poolErr } } 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 }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0)
- 
				
				cmd/erasure-server-pool.goreturn toObjectErr(err, bucket) } select { case <-ctx.Done(): return ctx.Err() case r, found := <-results: if found { if r.Err != nil { s3LogIf(ctx, fmt.Errorf("unable to verify if the bucket %s is empty: %w", bucket, r.Err)) return toObjectErr(r.Err, bucket) } return toObjectErr(errVolumeNotEmpty, bucket) } }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0)
- 
				
				cmd/data-usage.goif err != nil { buf, err = readConfig(ctx, objAPI, dataUsageObjNamePath+".bkp") if err != nil { if errors.Is(err, errConfigNotFound) { return DataUsageInfo{}, nil } return DataUsageInfo{}, toObjectErr(err, minioMetaBucket, dataUsageObjNamePath) } } var dataUsageInfo DataUsageInfo json := jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(buf, &dataUsageInfo); err != nil {Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 5.6K bytes - Viewed (0)
- 
				
				cmd/erasure-healing.go// Healing directories handle it separately. if HasSuffix(object, SlashSeparator) { hr, err := er.healObjectDir(healCtx, bucket, object, opts.DryRun, opts.Remove) return hr, toObjectErr(err, bucket, object) } storageDisks := er.getDisks() storageEndpoints := er.getEndpoints() // When versionID is empty, we read directly from the `null` versionID for healing. Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.6K bytes - Viewed (0)
- 
				
				cmd/metacache-set.go// Read metadata associated with the object from all disks. fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, minioMetaBucket, o.objectPath(0), ObjectOptions{}, true) if err != nil { switch toObjectErr(err, minioMetaBucket, o.objectPath(0)).(type) { case ObjectNotFound, InsufficientReadQuorum: retryWait() continue } // Allow one fast retry for other errors. if retries > 0 { Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.7K bytes - Viewed (0)
- 
				
				cmd/object-api-errors.go"errors" "fmt" "io" ) // Converts underlying storage error. Convenience function written to // handle all cases where we have known types of errors returned by // underlying storage layer. func toObjectErr(oerr error, params ...string) error { if oerr == nil { return nil } // Unwarp the error first err := unwrapAll(oerr) if err == context.Canceled { return context.Canceled } Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 09 02:05:14 UTC 2024 - 22.1K bytes - Viewed (0)
- 
				
				cmd/test-utils_test.gofor i := 0; i < n-1; i++ { j = i + rand.Intn(n-i) s[i], s[j] = s[j], s[i] } return s } func TestToErrIsNil(t *testing.T) { if toObjectErr(nil) != nil { t.Errorf("Test expected to return nil, failed instead got a non-nil value %s", toObjectErr(nil)) } if toStorageErr(nil) != nil { t.Errorf("Test expected to return nil, failed instead got a non-nil value %s", toStorageErr(nil)) }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0)