- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for bucketDone (0.19 sec)
-
cmd/background-newdisks-heal-ops.go
h.ItemsFailed = h.ResumeItemsFailed h.BytesDone = h.ResumeBytesDone h.BytesFailed = h.ResumeBytesFailed } // bucketDone should be called when a bucket is done healing. // Adds the bucket to the list of healed buckets and updates resume numbers. func (h *healingTracker) bucketDone(bucket string) { h.mu.Lock() defer h.mu.Unlock() h.ResumeItemsHealed = h.ItemsHealed h.ResumeItemsFailed = h.ItemsFailed
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
return true } return false } func (p poolMeta) isBucketDecommissioned(idx int, bucket string) bool { return p.Pools[idx].Decommission.isBucketDecommissioned(bucket) } func (p *poolMeta) BucketDone(idx int, bucket decomBucketInfo) bool { if p.Pools[idx].Decommission == nil { // Decommission not in progress. return false } return p.Pools[idx].Decommission.bucketPop(bucket.String()) }
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) -
cmd/global-heal.go
retErr = err healingLogIf(ctx, err) continue } select { // If context is canceled don't mark as done... case <-ctx.Done(): return ctx.Err() default: tracker.bucketDone(bucket) healingLogIf(ctx, tracker.update(ctx)) } } tracker.setObject("") tracker.setBucket("") return retErr } func healBucket(bucket string, scan madmin.HealScanMode) error {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1)