Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for Diemer (0.18 sec)

  1. cmd/mrf.go

    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    			// wait on timer per heal
    			wait := healSleeper.Timer(context.Background())
    
    			scan := madmin.HealNormalScan
    			if u.scanMode != 0 {
    				scan = u.scanMode
    			}
    			if u.object == "" {
    				healBucket(u.bucket, scan)
    			} else {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  2. maven-compat/src/test/java/org/apache/maven/project/inheritance/t12scm/ProjectInheritanceTest.java

            System.out.println(
                    "Child SCM developer connection is: " + project1.getScm().getDeveloperConnection());
    
            assertEquals("http://host/viewer?path=/p0/modules/p1", project1.getScm().getUrl());
            assertEquals("scm:svn:http://host/p0/modules/p1", project1.getScm().getConnection());
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Thu Apr 25 05:46:50 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    		// time.
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		randSleepFor := func() time.Duration {
    			return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64())
    		}
    
    		timer := time.NewTimer(randSleepFor())
    		defer timer.Stop()
    
    		var (
    			quit     bool
    			traceMsg string
    		)
    
    		for {
    			select {
    			case rebalErr := <-doneCh:
    				quit = true
    				now := time.Now()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    			if err != nil {
    				return nil
    			}
    			w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    			return w.Run(func() error {
    				wait := deleteMultipartCleanupSleeper.Timer(ctx)
    				if time.Since(fi.ModTime) > expiry {
    					pathUUID := mustGetUUID()
    					targetPath := pathJoin(drivePath, minioMetaTmpDeletedBucket, pathUUID)
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  5. cmd/erasure.go

    				w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    				return w.Run(func() error {
    					wait := deleteCleanupSleeper.Timer(ctx)
    					removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir))
    					wait()
    					return nil
    				})
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  6. cmd/iam.go

    		randAmt := time.Duration(r.Float64() * float64(baseInterval))
    		return baseInterval/2 + randAmt
    	}
    
    	var maxDurationSecondsForLog float64 = 5
    	timer := time.NewTimer(waitInterval())
    	defer timer.Stop()
    
    	for {
    		select {
    		case <-timer.C:
    			// Load all IAM items (except STS creds) periodically.
    			refreshStart := time.Now()
    			if err := sys.Load(ctx, false); err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  7. cmd/metrics-resource.go

    	collectLocalResourceMetrics()
    
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    		case <-metricsTimer.C:
    			collectLocalResourceMetrics()
    
    			// Reset the timer for next cycle.
    			metricsTimer.Reset(resourceMetricsCollectionInterval)
    		}
    	}
    }
    
    // minioResourceCollector is the Collector for resource metrics
    type minioResourceCollector struct {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
Back to top