- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for HealedBuckets (0.09 sec)
-
cmd/background-newdisks-heal-ops_gen.go
return } } case "HealedBuckets": var zb0003 uint32 zb0003, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "HealedBuckets") return } if cap(z.HealedBuckets) >= int(zb0003) { z.HealedBuckets = (z.HealedBuckets)[:zb0003] } else { z.HealedBuckets = make([]string, zb0003) } for za0002 := range z.HealedBuckets {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 20 15:42:49 UTC 2024 - 24.6K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
h.ResumeBytesSkipped = h.BytesSkipped h.HealedBuckets = append(h.HealedBuckets, bucket) for i, b := range h.QueuedBuckets { if b == bucket { // Delete... h.QueuedBuckets = append(h.QueuedBuckets[:i], h.QueuedBuckets[i+1:]...) } } } // setQueuedBuckets will add buckets, but exclude any that is already in h.HealedBuckets. // Order is preserved.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
ahs.Lock() defer ahs.Unlock() tracker.mu.RLock() t := *tracker t.QueuedBuckets = append(make([]string, 0, len(tracker.QueuedBuckets)), tracker.QueuedBuckets...) t.HealedBuckets = append(make([]string, 0, len(tracker.HealedBuckets)), tracker.HealedBuckets...) ahs.healStatus[tracker.ID] = t tracker.mu.RUnlock() } // Sort by zone, set and disk index func sortDisks(disks []madmin.Disk) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0)