- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for HealedBuckets (0.18 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 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 17:05:40 GMT 2024 - 21.5K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
h.ResumeBytesFailed = h.BytesFailed 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.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K 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) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1)