Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for bucketMap (0.17 sec)

  1. cmd/admin-bucket-handlers.go

    					rpt.SetStatus(bucket, fileName, err)
    					continue
    				}
    				v, _ := globalBucketMetadataSys.Get(bucket)
    				bucketMap[bucket] = &v
    			}
    
    			bucketMap[bucket].ObjectLockConfigXML = configData
    			bucketMap[bucket].ObjectLockConfigUpdatedAt = updatedAt
    			rpt.SetStatus(bucket, fileName, nil)
    		}
    	}
    
    	// import versioning metadata
    	for _, file := range zr.File {
    		slc := strings.Split(file.Name, slashSeparator)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  2. cmd/peer-s3-client.go

    				_, ok := resultMap[bi.Name]
    				if ok {
    					// Skip it, this bucket is found in another pool
    					continue
    				}
    				bucketsMap[bi.Name]++
    				if bucketsMap[bi.Name] >= quorum {
    					resultMap[bi.Name] = bi
    				}
    			}
    		}
    		// loop through buckets and see if some with lost quorum
    		// these could be stale buckets lying around, queue a heal
    		// of such a bucket. This is needed here as we identify such
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-decom.go

    		BytesDone:               pd.BytesDone,
    		BytesFailed:             pd.BytesFailed,
    	}
    }
    
    // bucketPop should be called when a bucket is done decommissioning.
    // Adds the bucket to the list of decommissioned buckets and updates resume numbers.
    func (pd *PoolDecommissionInfo) bucketPop(bucket string) bool {
    	pd.DecommissionedBuckets = append(pd.DecommissionedBuckets, bucket)
    	for i, b := range pd.QueuedBuckets {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.3K bytes
    - Viewed (1)
Back to top