Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 288 for timeN (0.02 seconds)

  1. cmd/data-scanner.go

    		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 {
    		case <-ctx.Done():
    			if !timer.Stop() {
    				<-timer.C
    				if d.isScanner {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  2. internal/dsync/dsync_test.go

    	dm.Lock(id, source)
    	time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond)
    	dm.Unlock(t.Context())
    
    	dm.Lock(id, source)
    	time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond)
    	dm.Unlock(t.Context())
    
    	dm.Lock(id, source)
    	time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond)
    	dm.Unlock(t.Context())
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  3. cmd/erasure-healing-common.go

    			maxima = count
    			latest = etag
    		}
    	}
    
    	// Return the collected common max time, with maxima
    	return latest, maxima
    }
    
    // commonTime returns a maximally occurring time from a list of time.
    func commonTimeAndOccurrence(times []time.Time, group time.Duration) (maxTime time.Time, maxima int) {
    	timeOccurrenceMap := make(map[int64]int, len(times))
    	groupNano := group.Nanoseconds()
    	// Ignore the uuid sentinel and count the rest.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  4. cmd/metrics-resource.go

    		totalInodes:       "Total inodes on a drive",
    		cpuUser:           "CPU user time",
    		cpuSystem:         "CPU system time",
    		cpuIdle:           "CPU idle time",
    		cpuIOWait:         "CPU ioWait time",
    		cpuSteal:          "CPU steal time",
    		cpuNice:           "CPU nice time",
    		cpuLoad1:          "CPU load average 1min",
    		cpuLoad5:          "CPU load average 5min",
    		cpuLoad15:         "CPU load average 15min",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 17.2K bytes
    - Click Count (0)
  5. doc/godebug.md

    the Go 1.23 behavior.
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    There are no runtime metrics for this change,
    This setting will be removed in Go 1.27.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Dec 03 00:18:09 GMT 2025
    - 24.7K bytes
    - Click Count (0)
  6. cmd/prepare-storage.go

    		return nil, nil, errInvalidArgument
    	}
    
    	// prepare getElapsedTime() to calculate elapsed time since we started trying formatting disks.
    	// All times are rounded to avoid showing milli, micro and nano seconds
    	formatStartTime := time.Now().Round(time.Second)
    	getElapsedTime := func() string {
    		return time.Now().Round(time.Second).Sub(formatStartTime).String()
    	}
    
    	var (
    		tries   int
    		verbose bool
    	)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 20:51:54 GMT 2024
    - 11.1K bytes
    - Click Count (1)
  7. cmd/erasure-healing-common_test.go

    // time occurrence from a list of time.
    func TestCommonTime(t *testing.T) {
    	// List of test cases for common modTime.
    	testCases := []struct {
    		times  []time.Time
    		time   time.Time
    		quorum int
    	}{
    		{
    			// 1. Tests common times when slice has varying time elements.
    			[]time.Time{
    				time.Unix(0, 1).UTC(),
    				time.Unix(0, 2).UTC(),
    				time.Unix(0, 3).UTC(),
    				time.Unix(0, 3).UTC(),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  8. cmd/erasure-sets.go

    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(false)
    
    	monitor := time.NewTimer(monitorInterval)
    	defer monitor.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  9. cmd/erasure-server-pool-rebalance.go

    		// to avoid multiple pool leaders herding to update around the same
    		// 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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  10. cmd/background-newdisks-heal-ops.go

    	disk StorageAPI    `msg:"-"`
    	mu   *sync.RWMutex `msg:"-"`
    
    	ID         string
    	PoolIndex  int
    	SetIndex   int
    	DiskIndex  int
    	Path       string
    	Endpoint   string
    	Started    time.Time
    	LastUpdate time.Time
    
    	ObjectsTotalCount uint64
    	ObjectsTotalSize  uint64
    
    	ItemsHealed uint64
    	ItemsFailed uint64
    
    	BytesDone   uint64
    	BytesFailed uint64
    
    	// Last object scanned.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 16.5K bytes
    - Click Count (0)
Back to Top