Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for maxWait (0.05 sec)

  1. internal/config/scanner/scanner.go

    	}
    	cfg.Delay, err = strconv.ParseFloat(delay, 64)
    	if err != nil {
    		return err
    	}
    	maxWait := env.Get(EnvMaxWaitLegacy, "")
    	if maxWait == "" {
    		maxWait = env.Get(EnvMaxWait, kvs.GetWithDefault(MaxWait, DefaultKVS))
    	}
    	cfg.MaxWait, err = time.ParseDuration(maxWait)
    	if err != nil {
    		return err
    	}
    	cycle := env.Get(EnvCycle, kvs.GetWithDefault(Cycle, DefaultKVS))
    	if cycle == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. cmd/background-heal-ops.go

    	return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers())
    }
    
    func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) {
    	// No need to wait run at full speed.
    	if maxIO <= 0 {
    		return
    	}
    
    	const waitTick = 100 * time.Millisecond
    
    	tmpMaxWait := maxWait
    
    	for currentIO() >= maxIO {
    		if tmpMaxWait > 0 {
    			if tmpMaxWait < waitTick {
    				time.Sleep(tmpMaxWait)
    				return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    		// Grab current values
    		d.mu.RLock()
    		minWait, maxWait := d.minSleep, d.maxSleep
    		factor := d.factor
    		cycle := d.cycle
    		d.mu.RUnlock()
    		// Don't sleep for really small amount of time
    		wantSleep := time.Duration(float64(base) * factor)
    		if wantSleep <= minWait {
    			return
    		}
    		if maxWait > 0 && wantSleep > maxWait {
    			wantSleep = maxWait
    		}
    		timer := time.NewTimer(wantSleep)
    		select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  4. cmd/config-current.go

    			scannerCycle.Store(scannerCfg.Cycle)
    			scannerExcessObjectVersions.Store(scannerCfg.ExcessVersions)
    			scannerExcessFolders.Store(scannerCfg.ExcessFolders)
    			configLogIf(ctx, scannerSleeper.Update(scannerCfg.Delay, scannerCfg.MaxWait))
    		}
    	case config.LoggerWebhookSubSys:
    		loggerCfg, err := logger.LookupConfigForSubSys(ctx, s, config.LoggerWebhookSubSys)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  5. docs/config/README.md

    ```
    ~ mc admin config set alias/ scanner
    KEY:
    scanner  manage namespace scanning for usage calculation, lifecycle, healing and more
    
    ARGS:
    delay     (float)     scanner delay multiplier, defaults to '10.0'
    max_wait  (duration)  maximum wait time between operations, defaults to '15s'
    cycle     (duration)  time duration between scanner cycles
    ```
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (1)
  6. cmd/testdata/undeleteable-object.tgz

    ":{"_":[{"key":"name","value":""}]},"scanner":{"_":[{"key":"speed","value":"default"},{"key":"idle_speed","value":""},{"key":"alert_excess_versions","value":"100"},{"key":"alert_excess_folders","value":"50000"},{"key":"delay","value":""},{"key":"max_wait","value":""},{"key":"cycle","value":""}]},"site":{"_":[{"key":"name","value":""},{"key":"region","value":""}]},"storage_class":{"_":[{"key":"standard","value":"EC:5"},{"key":"rrs","value":"EC:1"},{"key":"optimize","value":"availability"},{"key":...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 26 00:31:12 UTC 2024
    - 8.7M bytes
    - Viewed (0)
Back to top