Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for QueuedBuckets (0.06 sec)

  1. cmd/background-newdisks-heal-ops.go

    	h.ResumeBytesFailed = h.BytesFailed
    	h.ResumeBytesSkipped = h.BytesSkipped
    	h.HealedBuckets = append(h.HealedBuckets, bucket)
    	for i, b := range h.QueuedBuckets {
    		if b == bucket {
    			// Delete...
    			h.QueuedBuckets = append(h.QueuedBuckets[:i], h.QueuedBuckets[i+1:]...)
    		}
    	}
    }
    
    // setQueuedBuckets will add buckets, but exclude any that is already in h.HealedBuckets.
    // Order is preserved.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom.go

    func (pd *PoolDecommissionInfo) bucketPop(bucket string) bool {
    	pd.DecommissionedBuckets = append(pd.DecommissionedBuckets, bucket)
    	for i, b := range pd.QueuedBuckets {
    		if b == bucket {
    			// Bucket is done.
    			pd.QueuedBuckets = append(pd.QueuedBuckets[:i], pd.QueuedBuckets[i+1:]...)
    			// Clear tracker info.
    			if pd.Bucket == bucket {
    				pd.Bucket = "" // empty this out for next bucket
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  3. cmd/global-heal.go

    			healingLogIf(ctx, tracker.update(ctx))
    		}
    	}
    	if retErr != nil {
    		return retErr
    	}
    
    	// Last sanity check
    	if len(tracker.QueuedBuckets) > 0 {
    		return fmt.Errorf("not all buckets were healed: %v", tracker.QueuedBuckets)
    	}
    
    	return nil
    }
    
    func healBucket(bucket string, scan madmin.HealScanMode) error {
    	// Get background heal sequence to send elements to heal
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    func (ahs *allHealState) updateHealStatus(tracker *healingTracker) {
    	ahs.Lock()
    	defer ahs.Unlock()
    
    	tracker.mu.RLock()
    	t := *tracker
    	t.QueuedBuckets = append(make([]string, 0, len(tracker.QueuedBuckets)), tracker.QueuedBuckets...)
    	t.HealedBuckets = append(make([]string, 0, len(tracker.HealedBuckets)), tracker.HealedBuckets...)
    	ahs.healStatus[tracker.ID] = t
    	tracker.mu.RUnlock()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
Back to top