- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for weSleep (0.09 sec)
-
cmd/data-usage_test.go
return } sizeS.totalSize = s.Size() sizeS.versions++ return sizeS, nil } return } weSleep := func() bool { return false } got, err := scanDataFolder(context.Background(), nil, base, dataUsageCache{Info: dataUsageCacheInfo{Name: bucket}}, getSize, 0, weSleep) if err != nil { t.Fatal(err) } // Test dirs want := []struct { path string isNil bool
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Mar 27 15:10:40 UTC 2024 - 14.1K 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) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 9.4K bytes - Viewed (0) -
cmd/data-scanner.go
updateCache: dataUsageCache{Info: cache.Info}, dataUsageScannerDebug: false, healObjectSelect: 0, scanMode: scanMode, weSleep: weSleep, updates: cache.Info.updates, updateCurrentPath: updatePath, disks: disks, disksQuorum: len(disks) / 2, } // Enable healing in XL mode.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} if err := p.checkDiskStale(); err != nil { xioutil.SafeClose(updates) return dataUsageCache{}, err } weSleep := func() bool { return scannerIdleMode.Load() == 0 } return p.storage.NSScanner(ctx, cache, updates, scanMode, weSleep) } func (p *xlStorageDiskIDCheck) GetDiskLoc() (poolIdx, setIdx, diskIdx int) { return p.storage.GetDiskLoc() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0) -
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 Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (0)