Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for isAllBucketsNotFound (0.08 sec)

  1. cmd/peer-s3-server.go

    			Endpoint: localDrives[i].Endpoint().String(),
    			State:    beforeState[i],
    		})
    	}
    
    	// check dangling and delete bucket only if its not a meta bucket
    	if !isMinioMetaBucketName(bucket) && !isAllBucketsNotFound(errs) && opts.Remove {
    		g := errgroup.WithNErrs(len(localDrives))
    		for index := range localDrives {
    			g.Go(func() error {
    				if localDrives[index] == nil {
    					return errDiskNotFound
    				}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  2. cmd/erasure-healing.go

    			case errFileVersionNotFound.Error():
    				continue
    			}
    		}
    		return false
    	}
    	return len(errs) > 0
    }
    
    // isAllBucketsNotFound will return true if all the errors are either errFileNotFound
    // or errFileCorrupt
    // A 0 length slice will always return false.
    func isAllBucketsNotFound(errs []error) bool {
    	if len(errs) == 0 {
    		return false
    	}
    	notFoundCount := 0
    	for _, err := range errs {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    	}
    
    	if !opts.Recreate {
    		// when there is no force recreate look for pool
    		// errors to recreate the bucket on all pools.
    		opts.Remove = isAllBucketsNotFound(poolErrs)
    		opts.Recreate = !opts.Remove
    	}
    
    	g = errgroup.WithNErrs(len(sys.peerClients))
    	healBucketResults := make([]madmin.HealResultItem, len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  4. cmd/bucket-handlers.go

    	dObjects, errs := deleteObjectsFn(ctx, bucket, deleteList, ObjectOptions{
    		PrefixEnabledFn:  vc.PrefixEnabled,
    		VersionSuspended: vc.Suspended(),
    	})
    
    	// Are all objects saying bucket not found?
    	if isAllBucketsNotFound(errs) {
    		writeErrorResponse(ctx, w, toAPIError(ctx, errs[0]), r.URL)
    		return
    	}
    
    	for i := range errs {
    		// DeleteMarkerVersionID is not used specifically to avoid
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
Back to top