Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for scanMode (0.07 sec)

  1. cmd/data-scanner.go

    			globalScannerMetrics.setCycle(&cycleInfo)
    
    			bgHealInfo := readBackgroundHealInfo(ctx, objAPI)
    			scanMode := getCycleScanMode(cycleInfo.current, bgHealInfo.BitrotStartCycle, bgHealInfo.BitrotStartTime)
    			if bgHealInfo.CurrentScanMode != scanMode {
    				newHealInfo := bgHealInfo
    				newHealInfo.CurrentScanMode = scanMode
    				if scanMode == madmin.HealDeepScan {
    					newHealInfo.BitrotStartTime = time.Now().UTC()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    			var result healEntryResult
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				res, err := er.HealObject(ctx, bucket, encodedEntryName, "",
    					madmin.HealOpts{
    						ScanMode: scanMode,
    						Remove:   healDeleteDangling,
    					})
    				if err != nil {
    					if isErrObjectNotFound(err) || isErrVersionNotFound(err) {
    						// queueing happens across namespace, ignore
    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/admin-heal-ops.go

    		bucket:    source.bucket,
    		object:    source.object,
    		versionID: source.versionID,
    		opts:      h.settings,
    	}
    	if source.opts != nil {
    		task.opts = *source.opts
    	} else {
    		task.opts.ScanMode = madmin.HealNormalScan
    	}
    
    	h.countScanned(healType)
    
    	if source.noWait {
    		select {
    		case globalBackgroundHealRoutine.tasks <- task:
    			if serverDebugLog {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. cmd/erasure-healing-common.go

    //     a not-found error or a hash-mismatch error.
    func disksWithAllParts(ctx context.Context, onlineDisks []StorageAPI, partsMetadata []FileInfo,
    	errs []error, latestMeta FileInfo, filterByETag bool, bucket, object string,
    	scanMode madmin.HealScanMode,
    ) (availableDisks []StorageAPI, dataErrsByDisk map[int][]int, dataErrsByPart map[int][]int) {
    	availableDisks = make([]StorageAPI, len(onlineDisks))
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    }
    
    func (p *xlStorageDiskIDCheck) Healing() *healingTracker {
    	return p.storage.Healing()
    }
    
    func (p *xlStorageDiskIDCheck) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, _ func() bool) (dataUsageCache, error) {
    	if contextCanceled(ctx) {
    		xioutil.SafeClose(updates)
    		return dataUsageCache{}, ctx.Err()
    	}
    
    	if err := p.checkDiskStale(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    		buf, _, err := s.readMetadataWithDMTime(ctx, itemPath)
    		return buf, err
    	})
    }
    
    func (s *xlStorage) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, weSleep func() bool) (dataUsageCache, error) {
    	atomic.AddInt32(&s.scanning, 1)
    	defer atomic.AddInt32(&s.scanning, -1)
    
    	var err error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top