Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for ScanMode (0.14 sec)

  1. cmd/erasure-healing_test.go

    	}
    
    	if err = objLayer.HealObjects(ctx, bucket, "", madmin.HealOpts{Remove: true},
    		func(bucket, object, vid string, scanMode madmin.HealScanMode) error {
    			_, err := objLayer.HealObject(ctx, bucket, object, vid, madmin.HealOpts{ScanMode: scanMode, Remove: true})
    			return err
    		}); err != nil {
    		t.Fatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/storage-rest-common_gen.go

    		case "id":
    			z.DiskID, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "DiskID")
    				return
    			}
    		case "m":
    			z.ScanMode, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "ScanMode")
    				return
    			}
    		case "c":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Cache")
    					return
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  3. scan.go

    		field.NewValuePool.Put(values[idx])
    	}
    }
    
    // ScanMode scan data mode
    type ScanMode uint8
    
    // scan modes
    const (
    	ScanInitialized         ScanMode = 1 << 0 // 1
    	ScanUpdate              ScanMode = 1 << 1 // 2
    	ScanOnConflictDoNothing ScanMode = 1 << 2 // 4
    )
    
    // Scan scan rows into db statement
    func Scan(rows Rows, db *DB, mode ScanMode) {
    	var (
    		columns, _          = rows.Columns()
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. cmd/erasure-healing.go

    			if err := healEntry(bucket, entry, scanMode); err != nil {
    				cancel()
    			}
    		},
    		partial: func(entries metaCacheEntries, _ []error) {
    			entry, ok := entries.resolve(&resolver)
    			if !ok {
    				// check if we can get one entry at least
    				// proceed to heal nonetheless.
    				entry, _ = entries.firstFound()
    			}
    
    			if err := healEntry(bucket, *entry, scanMode); err != nil {
    				cancel()
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  7. cmd/storage-rest-common.go

    	storageRESTOrigVolume       = "ovol"
    	storageRESTInclFreeVersions = "incl-fv"
    	storageRESTRange            = "rng"
    )
    
    type nsScannerOptions struct {
    	DiskID   string          `msg:"id"`
    	ScanMode int             `msg:"m"`
    	Cache    *dataUsageCache `msg:"c"`
    }
    
    type nsScannerResp struct {
    	Update *dataUsageEntry `msg:"u"`
    	Final  *dataUsageCache `msg:"f"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  8. buildscripts/heal-manual.go

    	}
    
    	opts := madmin.HealOpts{
    		Recursive: true,                  // recursively heal all objects at 'prefix'
    		Remove:    true,                  // remove content that has lost quorum and not recoverable
    		ScanMode:  madmin.HealNormalScan, // by default do not do 'deep' scanning
    	}
    
    	start, _, err := madmClnt.Heal(context.Background(), "healing-rewrite-bucket", "", opts, "", false, false)
    	if err != nil {
    		log.Fatalln(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 27 09:47:58 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  9. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, weSleep func() bool) (info dataUsageCache, err error) {
    	if err := d.calcError(); err != nil {
    		return info, err
    	}
    	return d.disk.NSScanner(ctx, cache, updates, scanMode, weSleep)
    }
    
    func (d *naughtyDisk) DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. 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)
Back to top