Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for HealedBuckets (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top