Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 46 of 46 for NoNanos (0.05 seconds)

  1. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        assertThat(map.expireAfterWriteNanos).isEqualTo(unit.toNanos(duration));
      }
    
      public void testSetExpireAfterAccess() {
        long duration = 42;
        TimeUnit unit = SECONDS;
        LocalCache<Object, Object> map =
            makeLocalCache(createCacheBuilder().expireAfterAccess(duration, unit));
        assertThat(map.expireAfterAccessNanos).isEqualTo(unit.toNanos(duration));
      }
    
      public void testSetRefresh() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 116.4K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

      // Guarded by this.
      private val currentPushRequests = mutableSetOf<Int>()
    
      init {
        if (builder.pingIntervalMillis != 0) {
          val pingIntervalNanos = TimeUnit.MILLISECONDS.toNanos(builder.pingIntervalMillis.toLong())
          writerQueue.schedule("$connectionName ping", pingIntervalNanos) {
            val failDueToMissingPong =
              withLock {
                if (intervalPongsReceived < intervalPingsSent) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  3. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

            if (effect.closeSocket) socket.close()
          }
    
          Stall -> {
            // Sleep until the socket is closed.
            socket.sleepWhileOpen(TimeUnit.MINUTES.toNanos(60))
            error("expected timeout")
          }
        }
    
        return true
      }
    
      @Throws(IOException::class)
      private fun readEmptyLine(source: BufferedSource) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 40.3K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // and the approximate actual delay, to be robust to variance in thread scheduling.
        char overWaitNanosFirstDigit =
            Long.toString(thread.timeSpentBlocked - MILLISECONDS.toNanos(longWait ? 5000 : 3000))
                .charAt(0);
        if (overWaitNanosFirstDigit < '4') {
          overWaitNanosFirstDigit = '9';
        }
        String nanosRegex = "[4-" + overWaitNanosFirstDigit + "][0-9]+";
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        // and the approximate actual delay, to be robust to variance in thread scheduling.
        char overWaitNanosFirstDigit =
            Long.toString(thread.timeSpentBlocked - MILLISECONDS.toNanos(longWait ? 5000 : 3000))
                .charAt(0);
        if (overWaitNanosFirstDigit < '4') {
          overWaitNanosFirstDigit = '9';
        }
        String nanosRegex = "[4-" + overWaitNanosFirstDigit + "][0-9]+";
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        connection.writePingAndAwaitPong()
        val elapsedNanos = System.nanoTime() - pingAtNanos
        assertThat(elapsedNanos).isGreaterThan(0L)
        assertThat(elapsedNanos).isLessThan(TimeUnit.SECONDS.toNanos(1))
    
        // Verify the peer received what was expected.
        val pingFrame = peer.takeFrame()
        assertThat(pingFrame.type).isEqualTo(Http2.TYPE_PING)
        assertThat(pingFrame.streamId).isEqualTo(0)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
Back to Top