Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for bucketDone (0.13 sec)

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

    	h.BytesDone = h.ResumeBytesDone
    	h.BytesFailed = h.ResumeBytesFailed
    	h.BytesSkipped = h.ResumeBytesSkipped
    }
    
    // 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    			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))
    		}
    	}
    	if retErr != nil {
    		return retErr
    	}
    
    	// Last sanity check
    	if len(tracker.QueuedBuckets) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
Back to top