Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for random (0.64 sec)

  1. cmd/server-main.go

    		return
    	}
    
    	globalTrace.Publish(info)
    }
    
    func initServerConfig(ctx context.Context, newObject ObjectLayer) error {
    	t1 := time.Now()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	for {
    		select {
    		case <-ctx.Done():
    			// Retry was canceled successfully.
    			return fmt.Errorf("Initializing sub-systems stopped gracefully %w", ctx.Err())
    		default:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  2. cmd/erasure-sets.go

    // the set topology, this monitoring happens at a given monitoring interval.
    func (s *erasureSets) monitorAndConnectEndpoints(ctx context.Context, monitorInterval time.Duration) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	time.Sleep(time.Duration(r.Float64() * float64(time.Second)))
    
    	// Pre-emptively connect the disks if possible.
    	s.connectDisks()
    
    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)
  3. cmd/data-scanner.go

    	scannerExcessFolders                 = uatomic.NewInt64(50000)
    )
    
    // initDataScanner will start the scanner in the background.
    func initDataScanner(ctx context.Context, objAPI ObjectLayer) {
    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Run the data scanner in a loop
    		for {
    			runDataScanner(ctx, objAPI)
    			duration := time.Duration(r.Float64() * float64(scannerCycle.Load()))
    			if duration < time.Second {
    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)
Back to top