- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for isErrReadQuorum (0.07 sec)
-
cmd/erasure-multipart-conditional_test.go
// Precondition fails if object exists (ETag is not empty) return oi.ETag != "" }, } _, err := obj.NewMultipartUpload(ctx, bucket, object, opts) if !isErrReadQuorum(err) { t.Errorf("Expected read quorum error when if-none-match is used with quorum failure, got: %v", err) } }) t.Run("if-match with wrong ETag and read quorum failure", func(t *testing.T) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 6.9K bytes - Viewed (0) -
cmd/erasure-object-conditional_test.go
return oi.ETag != "" }, } _, err := obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader([]byte("new-value")), int64(len("new-value")), "", ""), opts) if !isErrReadQuorum(err) { t.Errorf("Expected read quorum error when if-none-match is used with quorum failure, got: %v", err) } }) t.Run("if-match with read quorum failure", func(t *testing.T) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 4.9K bytes - Viewed (0) -
cmd/object-api-errors.go
if errors.Is(err, errVolumeNotFound) { return true } var bkNotFound BucketNotFound return errors.As(err, &bkNotFound) } // isErrReadQuorum check if the error type is InsufficientReadQuorum func isErrReadQuorum(err error) bool { var rquorum InsufficientReadQuorum return errors.As(err, &rquorum) } // isErrWriteQuorum check if the error type is InsufficientWriteQuorum
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 09 02:05:14 UTC 2024 - 22.1K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if opts.SkipRebalancing && z.IsPoolRebalancing(pinfo.Index) { continue } if pinfo.Err == nil { // found a pool return pinfo, z.poolsWithObject(poolObjInfos, opts), nil } if isErrReadQuorum(pinfo.Err) && !opts.MetadataChg { // read quorum is returned when the object is visibly // present but its unreadable, we simply ask the writes to // schedule to this pool instead. If there is no quorum
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 89.2K bytes - Viewed (0) -
cmd/bucket-replication.go
// version being purged is already not found on target. if !rinfo.VersionPurgeStatus.Empty() { rinfo.VersionPurgeStatus = replication.VersionPurgeComplete return rinfo } case isErrReadQuorum(serr), isErrWriteQuorum(serr): // destination has some quorum issues, perform removeObject() anyways // to complete the operation. default:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 118.2K bytes - Viewed (0) -
cmd/object-handlers.go
gr, err := getObjectNInfo(ctx, bucket, object, rs, r.Header, opts) if err != nil { var ( reader *GetObjectReader perr error ) if (isErrObjectNotFound(err) || isErrVersionNotFound(err) || isErrReadQuorum(err)) && (gr == nil || !gr.ObjInfo.DeleteMarker) { proxytgts := getProxyTargets(ctx, bucket, object, opts) if !proxytgts.Empty() { globalReplicationStats.Load().incProxy(bucket, getObjectAPI, false)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 120.6K bytes - Viewed (0)