Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for queueHealTask (0.17 sec)

  1. cmd/admin-heal-ops.go

    			// Eventually the traversal go-routine closes
    			// the channel and returns, so this go-routine
    			// itself will not leak.
    			<-h.traverseAndHealDoneCh
    		}()
    	}
    }
    
    func (h *healSequence) queueHealTask(source healSource, healType madmin.HealItemType) error {
    	// Send heal request
    	task := healTask{
    		bucket:    source.bucket,
    		object:    source.object,
    		versionID: source.versionID,
    		opts:      h.settings,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    func healBucket(bucket string, scan madmin.HealScanMode) error {
    	// Get background heal sequence to send elements to heal
    	bgSeq, ok := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if ok {
    		return bgSeq.queueHealTask(healSource{bucket: bucket}, madmin.HealItemBucket)
    	}
    	return nil
    }
    
    // healObject sends the given object/version to the background healing workers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    			if bucket != resolver.bucket {
    				// Bucket might be missing as well with abandoned children.
    				// make sure it is created first otherwise healing won't proceed
    				// for objects.
    				bgSeq.queueHealTask(healSource{
    					bucket: bucket,
    				}, madmin.HealItemBucket)
    			}
    
    			resolver.bucket = bucket
    
    			foundObjs := false
    			ctx, cancel := context.WithCancel(ctx)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top