- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for scanMode (0.16 sec)
-
cmd/mrf.go
// i.e 4 reconnect attempts. time.Sleep(time.Second) } // wait on timer per heal wait := healSleeper.Timer(context.Background()) scan := madmin.HealNormalScan if u.scanMode != 0 { scan = u.scanMode } if u.object == "" { healBucket(u.bucket, scan) } else { if len(u.versions) > 0 { vers := len(u.versions) / 16 if vers > 0 { for i := 0; i < vers; i++ {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 7.9K bytes - Viewed (0) -
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) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
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.countHeals(healType, false) if source.noWait { select { case globalBackgroundHealRoutine.tasks <- task: if serverDebugLog {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/erasure-server-pool.go
// HealObjectFn closure function heals the object. type HealObjectFn func(bucket, object, versionID string, scanMode madmin.HealScanMode) error func (z *erasureServerPools) HealObjects(ctx context.Context, bucket, prefix string, opts madmin.HealOpts, healObjectFn HealObjectFn) error { healEntry := func(bucket string, entry metaCacheEntry, scanMode madmin.HealScanMode) error { if entry.isDir() { return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/storage-rest-client.go
func (client *storageRESTClient) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, _ func() bool) (dataUsageCache, error) { defer xioutil.SafeClose(updates) st, err := storageNSScannerRPC.Call(ctx, client.gridConn, &nsScannerOptions{ DiskID: *client.diskID.Load(), ScanMode: int(scanMode), Cache: &cache, }) if err != nil { return cache, toStorageErr(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
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) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 47.6K bytes - Viewed (0) -
cmd/global-heal.go
if objAPI == nil { return errServerNotInitialized } for _, bucket := range healBuckets { _, err := objAPI.HealBucket(ctx, bucket, madmin.HealOpts{ScanMode: scanMode}) if err != nil { // Log bucket healing error if any, we shall retry again. healingLogIf(ctx, err) } } info, err := tracker.disk.DiskInfo(ctx, DiskInfoOptions{}) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (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()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0)