- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 59 for Elapsed (0.06 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
Stopwatch stopwatch = Stopwatch.createStarted(); String result = proxy.sleepThenReturnInput("x"); assertThat(result).isEqualTo("x"); assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(DELAY_MS, ENOUGH_MS)); assertThat(target.finished).isTrue(); } public void testNewProxy_goodMethodWithNotEnoughTime() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/StopwatchTest.java
ticker.advance(2); assertEquals(0, stopwatch.elapsed(NANOSECONDS)); stopwatch.start(); ticker.advance(3); assertEquals(3, stopwatch.elapsed(NANOSECONDS)); } public void testReset_whileRunning() { ticker.advance(1); stopwatch.start(); assertEquals(0, stopwatch.elapsed(NANOSECONDS)); ticker.advance(2); assertEquals(2, stopwatch.elapsed(NANOSECONDS)); stopwatch.reset();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Sep 17 18:14:12 UTC 2024 - 5.7K bytes - Viewed (0) -
guava/src/com/google/common/base/Stopwatch.java
* * <p>It is generally not a good idea to use an ambiguous, unitless {@code long} to represent * elapsed time. Therefore, we recommend using {@link #elapsed()} instead, which returns a * strongly-typed {@code Duration} instance. * * @since 14.0 (since 10.0 as {@code elapsedTime()}) */ public long elapsed(TimeUnit desiredUnit) { return desiredUnit.convert(elapsedNanos(), NANOSECONDS); } /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 9.3K bytes - Viewed (0) -
cmd/rebalance-admin.go
totalBytesToRebal := float64(ps.InitCapacity)*meta.PercentFreeGoal - float64(ps.InitFreeSpace) elapsed := time.Since(ps.Info.StartTime) eta := time.Duration(totalBytesToRebal * float64(elapsed) / float64(ps.Bytes)) if !ps.Info.EndTime.IsZero() { stopTime = ps.Info.EndTime } if !stopTime.IsZero() { // rebalance is stopped or completed elapsed = stopTime.Sub(ps.Info.StartTime) eta = 0 }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 22 00:56:43 UTC 2023 - 3.8K bytes - Viewed (0) -
logger/logger.go
} case elapsed > l.SlowThreshold && l.SlowThreshold != 0 && l.LogLevel >= Warn: sql, rows := fc() slowLog := fmt.Sprintf("SLOW SQL >= %v", l.SlowThreshold) if rows == -1 { l.Printf(l.traceWarnStr, utils.FileWithLineNum(), slowLog, float64(elapsed.Nanoseconds())/1e6, "-", sql) } else { l.Printf(l.traceWarnStr, utils.FileWithLineNum(), slowLog, float64(elapsed.Nanoseconds())/1e6, rows, sql)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Nov 07 02:19:41 UTC 2023 - 5.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/StopwatchTest.java
ticker.advance(2); assertEquals(0, stopwatch.elapsed(NANOSECONDS)); stopwatch.start(); ticker.advance(3); assertEquals(3, stopwatch.elapsed(NANOSECONDS)); } public void testReset_whileRunning() { ticker.advance(1); stopwatch.start(); assertEquals(0, stopwatch.elapsed(NANOSECONDS)); ticker.advance(2); assertEquals(2, stopwatch.elapsed(NANOSECONDS)); stopwatch.reset();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Sep 17 18:14:12 UTC 2024 - 5.7K bytes - Viewed (0) -
cmd/endpoint.go
) if orchestrated && hostResolveToLocalhost(endpoints[i]) { // time elapsed timeElapsed := time.Since(startTime) // log error only if more than a second has elapsed if timeElapsed > time.Second { reqInfo.AppendTags("elapsedTime", humanize.RelTime(startTime, startTime.Add(timeElapsed), "elapsed", "", )) ctx := logger.SetReqInfo(GlobalContext,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 34.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/StopwatchJavaTimeTest.java
public void testElapsed_duration() { stopwatch.start(); ticker.advance(999999); assertEquals(Duration.ofNanos(999999), stopwatch.elapsed()); ticker.advance(1); assertEquals(Duration.ofMillis(1), stopwatch.elapsed()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu May 04 09:41:29 UTC 2023 - 1.3K bytes - Viewed (0) -
cmd/prepare-storage.go
logger.Info("Waiting for a minimum of %d drives to come online (elapsed %s)\n", len(endpoints)/2, getElapsedTime()) case errors.Is(err, errErasureWriteQuorum): // no quorum available continue to wait for minimum number of servers. logger.Info("Waiting for a minimum of %d drives to come online (elapsed %s)\n", (len(endpoints)/2)+1, getElapsedTime()) case errors.Is(err, errErasureV3ThisEmpty):
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
) : ConnectionListener() { val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableSetOf<Any>() /** The timestamp of the last taken event, used to measure elapsed time between events. */ private var lastTimestampNs: Long? = null /** Confirm that the thread does not hold a lock on `lock` during the callback. */ fun forbidLock(lock: Any) { forbiddenLocks.add(lock) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0)