- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for countHealed (0.12 sec)
-
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) -
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) -
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)