Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for countHealed (0.08 sec)

  1. cmd/global-heal.go

    					}
    					result = healEntryFailure(0)
    					bgSeq.countFailed(madmin.HealItemObject)
    					healingLogIf(ctx, fmt.Errorf("unable to heal object %s/%s: %w", bucket, entry.name, err))
    				} else {
    					bgSeq.countHealed(madmin.HealItemObject)
    					result = healEntrySuccess(uint64(res.ObjectSize))
    				}
    
    				send(result)
    				return
    			}
    
    			var versionNotFound int
    			for _, version := range fivs.Versions {
    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/background-heal-ops.go

    				continue
    			}
    
    			// when respCh is not set caller is not waiting but we
    			// update the relevant metrics for them
    			if bgSeq != nil {
    				if err == nil {
    					bgSeq.countHealed(res.Type)
    				} else {
    					bgSeq.countFailed(res.Type)
    				}
    			}
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    func newHealRoutine() *healRoutine {
    	workers := runtime.GOMAXPROCS(0) / 2
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    func (h *healSequence) countScanned(healType madmin.HealItemType) {
    	h.mutex.Lock()
    	defer h.mutex.Unlock()
    
    	h.scannedItemsMap[healType]++
    	h.lastHealActivity = UTCNow()
    }
    
    func (h *healSequence) countHealed(healType madmin.HealItemType) {
    	h.mutex.Lock()
    	defer h.mutex.Unlock()
    
    	h.healedItemsMap[healType]++
    	h.lastHealActivity = UTCNow()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
Back to top