Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for bucket5 (0.09 sec)

  1. cmd/global-heal.go

    	var retErr error
    
    	// Heal all buckets with all objects
    	for _, bucket := range healBuckets {
    		if tracker.isHealed(bucket) {
    			continue
    		}
    
    		var forwardTo string
    		// If we resume to the same bucket, forward to last known item.
    		b := tracker.getBucket()
    		if b == bucket {
    			forwardTo = tracker.getObject()
    		}
    		if b != "" {
    			// Reset to where last bucket ended if resuming.
    			tracker.resume()
    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/background-newdisks-heal-ops.go

    	buckets, _ := z.ListBuckets(ctx, BucketOptions{})
    	// Buckets data are dispersed in multiple pools/sets, make
    	// sure to heal all bucket metadata configuration.
    	buckets = append(buckets, BucketInfo{
    		Name: pathJoin(minioMetaBucket, minioConfigPrefix),
    	}, BucketInfo{
    		Name: pathJoin(minioMetaBucket, bucketMetaPrefix),
    	})
    
    	// Heal latest buckets first.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. cmd/api-response.go

    	data := ListBucketsResponse{}
    	owner := Owner{
    		ID:          globalMinioDefaultOwnerID,
    		DisplayName: "minio",
    	}
    
    	for _, bucket := range buckets {
    		listbuckets = append(listbuckets, Bucket{
    			Name:         bucket.Name,
    			CreationDate: amztime.ISO8601Format(bucket.Created.UTC()),
    		})
    	}
    
    	data.Owner = owner
    	data.Buckets.Buckets = listbuckets
    
    	return data
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	}
    
    	// Heal latest buckets first.
    	sort.Slice(buckets, func(i, j int) bool {
    		return buckets[i].Created.After(buckets[j].Created)
    	})
    
    	for _, bucket := range buckets {
    		if err = h.healBucket(objAPI, bucket.Name, false); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    // healBucket - traverses and heals given bucket
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  5. cmd/warm-backend-azure.go

    	return azureCodesToObjectError(err, serviceCode, statusCode, bucket, object)
    }
    
    func azureCodesToObjectError(err error, serviceCode string, statusCode int, bucket string, object string) error {
    	switch serviceCode {
    	case "ContainerNotFound", "ContainerBeingDeleted":
    		err = BucketNotFound{Bucket: bucket}
    	case "ContainerAlreadyExists":
    		err = BucketExists{Bucket: bucket}
    	case "InvalidResourceName":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/CompactHashing.java

      static Object createTable(int buckets) {
        if (buckets < 2
            || buckets > Ints.MAX_POWER_OF_TWO
            || Integer.highestOneBit(buckets) != buckets) {
          throw new IllegalArgumentException("must be power of 2 between 2^1 and 2^30: " + buckets);
        }
        if (buckets <= BYTE_MAX_SIZE) {
          return new byte[buckets];
        } else if (buckets <= SHORT_MAX_SIZE) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 15:34:52 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. cmd/warm-backend-gcs.go

    		fallthrough
    	case "forbidden":
    		err = PrefixAccessDenied{
    			Bucket: bucket,
    			Object: object,
    		}
    	case "invalid":
    		err = BucketNameInvalid{
    			Bucket: bucket,
    		}
    	case "notFound":
    		if object != "" {
    			err = ObjectNotFound{
    				Bucket: bucket,
    				Object: object,
    			}
    			break
    		}
    		err = BucketNotFound{Bucket: bucket}
    	case "conflict":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    		if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bucket}) {
    			return objInfo, err
    		}
    		rcfg, err = globalBucketObjectLockSys.Get(bucket)
    		if err != nil {
    			return objInfo, err
    		}
    		replcfg, err = getReplicationConfig(ctx, bucket)
    		if err != nil {
    			return objInfo, err
    		}
    	}
    
    	// expiration attempted on a bucket with no lifecycle
    	// rules shall be rejected.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  9. cmd/warm-backend-s3.go

    type warmBackendS3 struct {
    	client       *minio.Client
    	core         *minio.Core
    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    func (s3 *warmBackendS3) ToObjectError(err error, params ...string) error {
    	object := ""
    	if len(params) >= 1 {
    		object = params[0]
    	}
    
    	return ErrorRespToObjectError(err, s3.Bucket, s3.getDest(object))
    }
    
    func (s3 *warmBackendS3) getDest(object string) string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/CompactHashing.java

      static Object createTable(int buckets) {
        if (buckets < 2
            || buckets > Ints.MAX_POWER_OF_TWO
            || Integer.highestOneBit(buckets) != buckets) {
          throw new IllegalArgumentException("must be power of 2 between 2^1 and 2^30: " + buckets);
        }
        if (buckets <= BYTE_MAX_SIZE) {
          return new byte[buckets];
        } else if (buckets <= SHORT_MAX_SIZE) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 15:34:52 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top