Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getHealSequenceByToken (0.32 sec)

  1. cmd/admin-heal-ops.go

    		case <-ctx.Done():
    			// server could be restarting - need
    			// to exit immediately
    			return
    		}
    	}
    }
    
    // getHealSequenceByToken - Retrieve a heal sequence by token. The second
    // argument returns if a heal sequence actually exists.
    func (ahs *allHealState) getHealSequenceByToken(token string) (h *healSequence, exists bool) {
    	ahs.RLock()
    	defer ahs.RUnlock()
    	for _, healSeq := range ahs.healSeqMap {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    			// If we are not heal scanning, return now.
    			break
    		}
    
    		if len(f.disks) == 0 || f.disksQuorum == 0 {
    			break
    		}
    
    		bgSeq, found := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    		if !found {
    			break
    		}
    
    		// Whatever remains in 'abandonedChildren' are folders at this level
    		// that existed in the previous run but wasn't found now.
    		//
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    	mg := &MetricsGroupV2{
    		cacheInterval:    10 * time.Second,
    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(_ context.Context) (metrics []MetricV2) {
    		bgSeq, exists := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    		if !exists {
    			return
    		}
    
    		if bgSeq.lastHealActivity.IsZero() {
    			return
    		}
    
    		metrics = make([]MetricV2, 0, 5)
    		metrics = append(metrics, MetricV2{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
Back to top