Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for cycle (0.12 sec)

  1. cmd/config-current.go

    			errs = append(errs, fmt.Errorf("Unable to apply scanner config: %w", err))
    		} else {
    			// update dynamic scanner values.
    			scannerIdleMode.Store(scannerCfg.IdleMode)
    			scannerCycle.Store(scannerCfg.Cycle)
    			scannerExcessObjectVersions.Store(scannerCfg.ExcessVersions)
    			scannerExcessFolders.Store(scannerCfg.ExcessFolders)
    			configLogIf(ctx, scannerSleeper.Update(scannerCfg.Delay, scannerCfg.MaxWait))
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    	minSleep time.Duration
    
    	// cycle will be closed
    	cycle chan struct{}
    
    	// isScanner should be set when this is used by the scanner
    	// to record metrics.
    	isScanner bool
    }
    
    // newDynamicSleeper
    func newDynamicSleeper(factor float64, maxWait time.Duration, isScanner bool) *dynamicSleeper {
    	return &dynamicSleeper{
    		factor:    factor,
    		cycle:     make(chan struct{}),
    		maxSleep:  maxWait,
    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)
  3. cmd/erasure-sets.go

    	if !globalIsTesting {
    		go s.monitorAndConnectEndpoints(ctx, defaultMonitorConnectEndpointInterval)
    	}
    
    	return s, nil
    }
    
    // cleanup ".trash/" folder every 5m minutes with sufficient sleep cycles, between each
    // deletes a dynamic sleeper is used with a factor of 10 ratio with max delay between
    // deletes to be 2 seconds.
    func (s *erasureSets) cleanupDeletedObjects(ctx context.Context) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
Back to top