Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for isErrObjectNotFound (0.12 sec)

  1. cmd/object-handlers.go

    	var proxy proxyResult
    	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() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    				if !oi.TransitionedObject.FreeVersion {
    					// nothing to be done
    					continue
    				}
    
    				ignoreNotFoundErr := func(err error) error {
    					switch {
    					case isErrVersionNotFound(err), isErrObjectNotFound(err):
    						return nil
    					}
    					return err
    				}
    				// Remove the remote object
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    		}
    
    		obj, err := er.getObjectInfo(ctx, bucket, object, opts)
    		if err == nil && opts.CheckPrecondFn(obj) {
    			return nil, PreConditionFailed{}
    		}
    		if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !isErrReadQuorum(err) {
    			return nil, err
    		}
    	}
    
    	userDefined := cloneMSS(opts.UserDefined)
    	if opts.PreserveETag != "" {
    		userDefined["etag"] = opts.PreserveETag
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  4. cmd/object_api_suite_test.go

    	}
    
    	_, err = obj.GetObjectInfo(context.Background(), "bucket", "dir1", ObjectOptions{})
    	if err == nil {
    		t.Fatalf("%s: Expected error but found nil", instanceType)
    	}
    	if isErrObjectNotFound(err) {
    		if err.Error() != "Object not found: bucket/dir1" {
    			t.Errorf("%s: Expected the Error message to be `%s`, but instead found `%s`", instanceType, "Object not found: bucket/dir1", err.Error())
    		}
    	} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    			// delete marker already replicated
    			if dobj.VersionID == "" && rinfo.VersionPurgeStatus.Empty() {
    				rinfo.ReplicationStatus = replication.Completed
    				return
    			}
    		case isErrObjectNotFound(serr), isErrVersionNotFound(serr):
    			// version being purged is already not found on target.
    			if !rinfo.VersionPurgeStatus.Empty() {
    				rinfo.VersionPurgeStatus = Complete
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  6. cmd/server-main.go

    		errors.Is(err, errErasureWriteQuorum) ||
    		errors.Is(err, errErasureReadQuorum) ||
    		errors.Is(err, io.ErrUnexpectedEOF) ||
    		errors.As(err, &rquorum) ||
    		errors.As(err, &wquorum) ||
    		isErrObjectNotFound(err) ||
    		isErrBucketNotFound(err) ||
    		errors.Is(err, os.ErrDeadlineExceeded) ||
    		notInitialized
    }
    
    func bootstrapTraceMsg(msg string) {
    	info := madmin.TraceInfo{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  7. cmd/erasure-object.go

    		}
    
    		obj, err := er.getObjectInfo(ctx, bucket, object, opts)
    		if err == nil && opts.CheckPrecondFn(obj) {
    			return objInfo, PreConditionFailed{}
    		}
    		if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !isErrReadQuorum(err) {
    			return objInfo, err
    		}
    	}
    
    	// Validate input data size and it can never be less than -1.
    	if data.Size() < -1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  8. cmd/erasure-healing_test.go

    		ScanMode: madmin.HealDeepScan,
    	})
    	// since majority of xl.meta's are not available, object quorum
    	// can't be read properly will be deleted automatically and
    	// err is nil
    	if !isErrObjectNotFound(err) {
    		t.Fatal(err)
    	}
    }
    
    // Tests healing of empty directories
    func TestHealEmptyDirectoryErasure(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    			ReplicateDecisionStr:          dObjects[i].ReplicationState.ReplicateDecisionStr,
    		}
    		dindex := objectsToDelete[objToDel]
    		if errs[i] == nil || isErrObjectNotFound(errs[i]) || isErrVersionNotFound(errs[i]) {
    			if replicateDeletes {
    				dObjects[i].ReplicationState = deleteList[i].ReplicationState()
    			}
    			deleteResults[dindex].delInfo = dObjects[i]
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  10. cmd/object-api-listobjects_test.go

    		})
    		if err != nil {
    			if object.versionID != "" {
    				if !isErrVersionNotFound(err) {
    					t.Fatalf("%s : %s", instanceType, err)
    				}
    			} else {
    				if !isErrObjectNotFound(err) {
    					t.Fatalf("%s : %s", instanceType, err)
    				}
    			}
    		}
    		if obj.DeleteMarker != object.expectDelMarker {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 11:07:40 UTC 2024
    - 73.1K bytes
    - Viewed (0)
Back to top