Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for weSleep (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top