Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for updateProgress (0.18 sec)

  1. cmd/global-heal.go

    				if res.entryDone {
    					tracker.setObject(res.name)
    					if time.Since(tracker.getLastUpdate()) > time.Minute {
    						healingLogIf(ctx, tracker.update(ctx))
    					}
    					continue
    				}
    
    				tracker.updateProgress(res.success, res.skipped, res.bytes)
    			}
    		}()
    
    		send := func(result healEntryResult) bool {
    			select {
    			case <-ctx.Done():
    				if !contextCanceled(ctx) {
    					healingLogIf(ctx, ctx.Err())
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:22:13 GMT 2024
    - 14.2K bytes
    - Viewed (1)
  2. cmd/background-newdisks-heal-ops.go

    	defer h.mu.RUnlock()
    
    	return h.Object
    }
    
    func (h *healingTracker) setObject(object string) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	h.Object = object
    }
    
    func (h *healingTracker) updateProgress(success, skipped bool, bytes uint64) {
    	h.mu.Lock()
    	defer h.mu.Unlock()
    
    	switch {
    	case success:
    		h.ItemsHealed++
    		h.BytesDone += bytes
    	case skipped:
    		h.ItemsSkipped++
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.7K bytes
    - Viewed (0)
Back to top