Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for bucketDone (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top