Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 257 for segondas (0.07 sec)

  1. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        exec.execute(task);
        runLatch.await();
        taskLatch.countDown();
    
        ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS));
        assertEquals(IllegalStateException.class, e.getCause().getClass());
    
        assertTrue(listenerLatch.await(5, SECONDS));
        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
      }
    
      public void testListenerCalledOnCancelFromNotRunning() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. cmd/metrics-v3-system-process.go

    	processStarttimeSecondsMD         = NewGaugeMD(processStartTimeSeconds, "Start time for MinIO process in seconds since Unix epoc")
    	processUptimeSecondsMD            = NewGaugeMD(processUptimeSeconds, "Uptime for MinIO process in seconds")
    	processFileDescriptorLimitTotalMD = NewGaugeMD(processFileDescriptorLimitTotal, "Limit on total number of open file descriptors for the MinIO Server process")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/SocketChannelTest.kt

        }
    
        val client =
          clientTestRule.newClientBuilder()
            .dns { listOf(InetAddress.getByName("localhost")) }
            .callTimeout(4, SECONDS)
            .writeTimeout(2, SECONDS)
            .readTimeout(2, SECONDS)
            .apply {
              if (socketMode is TlsInstance) {
                if (socketMode.socketMode == Channel) {
                  socketFactory(ChannelSocketFactory())
                }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/CacheControlJvmTest.kt

      @Throws(Exception::class)
      fun completeBuilder() {
        val cacheControl =
          CacheControl.Builder()
            .noCache()
            .noStore()
            .maxAge(1, TimeUnit.SECONDS)
            .maxStale(2, TimeUnit.SECONDS)
            .minFresh(3, TimeUnit.SECONDS)
            .onlyIfCached()
            .noTransform()
            .immutable()
            .build()
        assertThat(cacheControl.toString()).isEqualTo(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

         * T3 at 3 seconds
         *
         * Due to the slight delay of T1, T2 would have to sleep till 2.05 seconds, and T3 would also
         * have to sleep till 3.05 seconds.
         */
        return create(permitsPerSecond, SleepingStopwatch.createFromSystemTimer());
      }
    
      @VisibleForTesting
      static RateLimiter create(double permitsPerSecond, SleepingStopwatch stopwatch) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/testing/GcFinalization.java

          return;
        }
        long timeoutSeconds = timeoutSeconds();
        long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds);
        do {
          System.runFinalization();
          if (future.isDone()) {
            return;
          }
          System.gc();
          try {
            future.get(1L, SECONDS);
            return;
          } catch (CancellationException | ExecutionException ok) {
            return;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java

    import static com.google.common.util.concurrent.Uninterruptibles.getUninterruptibly;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    import static junit.framework.Assert.assertFalse;
    import static junit.framework.Assert.fail;
    
    import com.google.common.annotations.GwtCompatible;
    import java.util.concurrent.ExecutionException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/cache/CacheBuilderSpecTest.java

      public void testParse_writeExpirationSeconds() {
        CacheBuilderSpec spec = parse("expireAfterWrite=10s");
        assertEquals(SECONDS, spec.writeExpirationTimeUnit);
        assertEquals(10L, spec.writeExpirationDuration);
        assertCacheBuilderEquivalence(
            CacheBuilder.newBuilder().expireAfterWrite(10L, SECONDS), CacheBuilder.from(spec));
      }
    
      public void testParse_writeExpirationRepeated() {
        assertThrows(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

        assertTrue(latch.await(5, SECONDS));
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    
        assertEquals(expectedValue, future.get());
      }
    
      public void testCancelledFuture() throws InterruptedException, ExecutionException {
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    
        assertTrue(latch.await(5, SECONDS));
        assertTrue(future.isDone());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

          return;
        }
        long timeoutSeconds = timeoutSeconds();
        long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds);
        do {
          System.runFinalization();
          if (future.isDone()) {
            return;
          }
          System.gc();
          try {
            future.get(1L, SECONDS);
            return;
          } catch (CancellationException | ExecutionException ok) {
            return;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
Back to top