Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 507 for timers (1.44 sec)

  1. cmd/tier.go

    		Name:    "tier_ttlb_seconds",
    		Help:    "Time taken by requests served by warm tier",
    		Buckets: []float64{0.01, 0.1, 1, 2, 5, 10, 60, 5 * 60, 15 * 60, 30 * 60},
    	}, []string{"tier"}),
    }
    
    func (t *tierMetrics) Observe(tier string, dur time.Duration) {
    	t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds())
    }
    
    func (t *tierMetrics) logSuccess(tier string) {
    	t.Lock()
    	defer t.Unlock()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  2. src/main/webapp/js/admin/jquery-3.7.1.min.map

    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 131.6K bytes
    - Viewed (0)
  3. cmd/tier-handlers.go

    )
    
    var (
    	// error returned when remote tier already exists
    	errTierAlreadyExists = AdminError{
    		Code:       "XMinioAdminTierAlreadyExists",
    		Message:    "Specified remote tier already exists",
    		StatusCode: http.StatusConflict,
    	}
    	// error returned when remote tier is not found
    	errTierNotFound = AdminError{
    		Code:       "XMinioAdminTierNotFound",
    		Message:    "Specified remote tier was not found",
    		StatusCode: http.StatusNotFound,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        @RetainedLocalRef Future<?> localTimer = timer;
        // Try to cancel the timer as an optimization.
        // timer may be null if this call to run was by the timer task since there is no happens-before
        // edge between the assignment to timer and an execution of the timer task.
        if (localTimer != null) {
          localTimer.cancel(false);
        }
    
        delegateRef = null;
        timer = null;
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java

    import java.util.concurrent.atomic.AtomicBoolean;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.ThreadUtil;
    import org.codelibs.core.timer.TimeoutTarget;
    
    /**
     * AccessTimeoutTarget is a class that implements the TimeoutTarget interface.
     * It is used to interrupt a running thread when a timeout occurs.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  6. 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 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  7. cmd/data-usage-cache.go

    	for tier, st := range other.Tiers {
    		ats.Tiers[tier] = ats.Tiers[tier].add(st)
    	}
    }
    
    func (ats *allTierStats) clone() *allTierStats {
    	if ats == nil {
    		return nil
    	}
    	dst := *ats
    	dst.Tiers = make(map[string]tierStats, len(ats.Tiers))
    	maps.Copy(dst.Tiers, ats.Tiers)
    	return &dst
    }
    
    func (ats *allTierStats) populateStats(stats map[string]madmin.TierStats) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       *     ordered by startup time.
       */
      public ImmutableMap<Service, Long> startupTimes() {
        return state.startupTimes();
      }
    
      /**
       * Returns the service load times. This value will only return startup times for services that
       * have finished starting.
       *
       * @return Map of services and their corresponding startup time, the map entries will be ordered
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  9. 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,
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jul 08 18:30:38 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

      }
    
      public void testServiceStartupTimes_selfStartingServices() {
        // This tests to ensure that:
        // 1. service times are accurate when the service is started by the manager
        // 2. service times are recorded when the service is not started by the manager (but they may
        // not be accurate).
        Service b =
            new NoOpDelayedService(353) {
              @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K bytes
    - Viewed (0)
Back to top