Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for isErrObjectNotFound (0.14 sec)

  1. cmd/global-heal.go

    			if err != nil {
    				res, err := er.HealObject(ctx, bucket, encodedEntryName, "",
    					madmin.HealOpts{
    						ScanMode: scanMode,
    						Remove:   healDeleteDangling,
    					})
    				if err != nil {
    					if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    						// queueing happens across namespace, ignore
    						// objects that are not found.
    						return
    					}
    					result = healEntryFailure(0)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom.go

    }
    
    func (p *poolMeta) load(ctx context.Context, pool *erasureSets, pools []*erasureSets) error {
    	data, err := readConfig(ctx, pool, poolMetaName)
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) || isErrObjectNotFound(err) {
    			return nil
    		}
    		return err
    	}
    	if len(data) == 0 {
    		// Seems to be empty create a new poolMeta object.
    		return nil
    	}
    	if len(data) <= 4 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    					if err != nil {
    						err := bgSeq.queueHealTask(healSource{
    							bucket:    bucket,
    							object:    entry.name,
    							versionID: "",
    						}, madmin.HealItemObject)
    						if !isErrObjectNotFound(err) && !isErrVersionNotFound(err) {
    							scannerLogIf(ctx, err)
    						}
    						foundObjs = foundObjs || err == nil
    						return
    					}
    
    					custom["versions"] = fmt.Sprint(len(fiv.Versions))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    					// These rebalance failures can be ignored.
    					if err != nil {
    						// This can happen when rebalance stop races with ongoing rebalance workers.
    						// These rebalance failures can be ignored.
    						if isErrObjectNotFound(err) || isErrVersionNotFound(err) || isDataMovementOverWriteErr(err) {
    							ignore = true
    							stopFn(0, nil)
    							continue
    						}
    					}
    					stopFn(version.Size, err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. cmd/bucket-object-lock.go

    			// This happens usually for a delete marker
    			if oi.DeleteMarker || !oi.VersionPurgeStatus.Empty() {
    				// Delete marker should be present and valid.
    				return nil
    			}
    		}
    		if isErrObjectNotFound(gerr) || isErrVersionNotFound(gerr) {
    			return nil
    		}
    		return gerr
    	}
    
    	lhold := objectlock.GetObjectLegalHoldMeta(oi.UserDefined)
    	if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  6. cmd/object-api-errors.go

    func isErrWriteQuorum(err error) bool {
    	var rquorum InsufficientWriteQuorum
    	return errors.As(err, &rquorum)
    }
    
    // isErrObjectNotFound - Check if error type is ObjectNotFound.
    func isErrObjectNotFound(err error) bool {
    	if errors.Is(err, errFileNotFound) {
    		return true
    	}
    
    	var objNotFound ObjectNotFound
    	return errors.As(err, &objNotFound)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top