Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for getHealSequenceByToken (0.27 sec)

  1. cmd/global-heal.go

    func getLocalBackgroundHealStatus(ctx context.Context, o ObjectLayer) (madmin.BgHealState, bool) {
    	if globalBackgroundHealState == nil {
    		return madmin.BgHealState{}, false
    	}
    
    	bgSeq, ok := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if !ok {
    		return madmin.BgHealState{}, false
    	}
    
    	status := madmin.BgHealState{
    		ScannedItemsCount: bgSeq.getScannedItemsCount(),
    	}
    
    	healDisksMap := map[string]struct{}{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. cmd/metrics.go

    // collects healing specific metrics for MinIO instance in Prometheus specific format
    // and sends to given channel
    func healingMetricsPrometheus(ch chan<- prometheus.Metric) {
    	bgSeq, exists := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if !exists {
    		return
    	}
    
    	var dur time.Duration
    	if !bgSeq.lastHealActivity.IsZero() {
    		dur = time.Since(bgSeq.lastHealActivity)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top