Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 351 for duration (0.18 sec)

  1. internal/config/batch/batch.go

    type Config struct {
    	ReplicationWorkersWait time.Duration `json:"replicationWorkersWait"`
    	KeyRotationWorkersWait time.Duration `json:"keyRotationWorkersWait"`
    	ExpirationWorkersWait  time.Duration `json:"expirationWorkersWait"`
    }
    
    // ExpirationWait returns the duration for which a batch expiration worker
    // would wait before working on next object.
    func (opts Config) ExpirationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Dec 06 09:09:22 GMT 2023
    - 4.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/cache/CacheBuilderFactory.java

      }
    
      static class DurationSpec {
        private final long duration;
        private final TimeUnit unit;
    
        private DurationSpec(long duration, TimeUnit unit) {
          this.duration = duration;
          this.unit = unit;
        }
    
        public static DurationSpec of(long duration, TimeUnit unit) {
          return new DurationSpec(duration, unit);
        }
    
        @Override
        public int hashCode() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 8.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/base/Internal.java

      static long toNanosSaturated(Duration duration) {
        // Using a try/catch seems lazy, but the catch block will rarely get invoked (except for
        // durations longer than approximately +/- 292 years).
        try {
          return duration.toNanos();
        } catch (ArithmeticException tooBig) {
          return duration.isNegative() ? Long.MIN_VALUE : Long.MAX_VALUE;
        }
      }
    
      private Internal() {}
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Jan 11 14:30:06 GMT 2024
    - 2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/base/Internal.java

      static long toNanosSaturated(Duration duration) {
        // Using a try/catch seems lazy, but the catch block will rarely get invoked (except for
        // durations longer than approximately +/- 292 years).
        try {
          return duration.toNanos();
        } catch (ArithmeticException tooBig) {
          return duration.isNegative() ? Long.MIN_VALUE : Long.MAX_VALUE;
        }
      }
    
      private Internal() {}
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Jan 11 14:30:06 GMT 2024
    - 2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/cache/CacheBuilder.java

      @SuppressWarnings("GoodTime") // duration decomposition
      private static long toNanosSaturated(java.time.Duration duration) {
        // Using a try/catch seems lazy, but the catch block will rarely get invoked (except for
        // durations longer than approximately +/- 292 years).
        try {
          return duration.toNanos();
        } catch (ArithmeticException tooBig) {
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 51.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/CacheBuilderFactory.java

      }
    
      static class DurationSpec {
        private final long duration;
        private final TimeUnit unit;
    
        private DurationSpec(long duration, TimeUnit unit) {
          this.duration = duration;
          this.unit = unit;
        }
    
        public static DurationSpec of(long duration, TimeUnit unit) {
          return new DurationSpec(duration, unit);
        }
    
        @Override
        public int hashCode() {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 8.1K bytes
    - Viewed (0)
  7. internal/http/listener_test.go

    		{[]string{"unknown-host:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{true}},                            // 4
    		{[]string{"localhost:65432"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{false}},                              // 5
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java

        String result = executorService.invokeAny(tasks, Duration.ofSeconds(7));
    
        assertThat(result).isEqualTo("invokeAny");
        assertThat(recordedTasks).isSameInstanceAs(tasks);
        assertThat(recordedTimeUnit).isEqualTo(NANOSECONDS);
        assertThat(Duration.ofNanos(recordedTimeout)).isEqualTo(Duration.ofSeconds(7));
      }
    
      public void testInvokeAll() throws Exception {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Fri Jun 02 12:45:23 GMT 2023
    - 4.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

        }
      }
    
      @GwtIncompatible // java.time.Duration
      public void testTimeToLive_setTwice_duration() {
        CacheBuilder<Object, Object> builder =
            CacheBuilder.newBuilder().expireAfterWrite(java.time.Duration.ofSeconds(3600));
        assertThrows(
            IllegalStateException.class,
            () -> builder.expireAfterWrite(java.time.Duration.ofSeconds(3600)));
      }
    
      public void testTimeToIdle_negative() {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Oct 03 20:10:02 GMT 2023
    - 25.5K bytes
    - Viewed (0)
  10. cmd/dynamic-timeouts.go

    	timeout       int64
    	minimum       int64
    	entries       int64
    	log           [dynamicTimeoutLogSize]time.Duration
    	mutex         sync.Mutex
    	retryInterval time.Duration
    }
    
    type dynamicTimeoutOpts struct {
    	timeout       time.Duration
    	minimum       time.Duration
    	retryInterval time.Duration
    }
    
    func newDynamicTimeoutWithOpts(opts dynamicTimeoutOpts) *dynamicTimeout {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Aug 19 23:21:05 GMT 2022
    - 4.5K bytes
    - Viewed (0)
Back to top