- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 99 for Hillis (0.21 sec)
-
okhttp/src/main/kotlin/okhttp3/Cache.kt
} val sendRequestMillisString = responseHeadersBuilder[SENT_MILLIS] val receivedResponseMillisString = responseHeadersBuilder[RECEIVED_MILLIS] responseHeadersBuilder.removeAll(SENT_MILLIS) responseHeadersBuilder.removeAll(RECEIVED_MILLIS) sentRequestMillis = sendRequestMillisString?.toLong() ?: 0L
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
check(duration >= 0L) { "$name < 0" } val millis = unit.toMillis(duration) require(millis <= Integer.MAX_VALUE) { "$name too large" } require(millis != 0L || duration <= 0L) { "$name too small" } return millis.toInt() } internal fun checkDuration( name: String, duration: Duration, ): Int { check(!duration.isNegative()) { "$name < 0" } val millis = duration.inWholeMilliseconds
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
*/ static void delay(long millis) throws InterruptedException { long startTime = System.nanoTime(); long ns = millis * 1000 * 1000; for (; ; ) { if (millis > 0L) Thread.sleep(millis); else // too short to sleep Thread.yield(); long d = ns - (System.nanoTime() - startTime); if (d > 0L) millis = d / (1000 * 1000); else break; } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
* enqueued before the timeout. */ @Synchronized fun await(url: HttpUrl): RecordedResponse { val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS while (true) { val i = responses.iterator() while (i.hasNext()) { val recordedResponse = i.next() if (recordedResponse.request.url.equals(url)) { i.remove()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
import junit.framework.TestCase; /** * Unit test for {@link AbstractService}. * * @author Jesse Wilson */ public class AbstractServiceTest extends TestCase { private static final long LONG_TIMEOUT_MILLIS = 10000; private Thread executionThread; private Throwable thrownByExecutionThread; public void testNoOpServiceStartStop() throws Exception { NoOpService service = new NoOpService();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 29.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
* reuse, this timeout should be significantly less than the time it takes to establish a new * connection. */ const val DISCARD_STREAM_TIMEOUT_MILLIS = 100 }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
*/ static void delay(long millis) throws InterruptedException { long startTime = System.nanoTime(); long ns = millis * 1000 * 1000; for (; ; ) { if (millis > 0L) Thread.sleep(millis); else // too short to sleep Thread.yield(); long d = ns - (System.nanoTime() - startTime); if (d > 0L) millis = d / (1000 * 1000); else break; } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
import junit.framework.TestCase; /** * Unit test for {@link AbstractService}. * * @author Jesse Wilson */ public class AbstractServiceTest extends TestCase { private static final long LONG_TIMEOUT_MILLIS = 10000; private Thread executionThread; private Throwable thrownByExecutionThread; public void testNoOpServiceStartStop() throws Exception { NoOpService service = new NoOpService();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 29.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
assertThat(client.canceled).isFalse() taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS - 1)) assertThat(client.canceled).isFalse() taskFaker.advanceUntil(ns(RealWebSocket.CANCEL_AFTER_CLOSE_MILLIS)) assertThat(client.canceled).isTrue() client.processNextFrame() // This won't get a frame, but it will get a closed pipe.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/logging/OneLineLogFormat.kt
.toFormatter() private val offset = ZoneOffset.systemDefault() override fun format(record: LogRecord): String { val message = formatMessage(record) val time = Instant.ofEpochMilli(record.millis).atZone(offset) return if (record.thrown != null) { val sw = StringWriter(4096) val pw = PrintWriter(sw) record.thrown.printStackTrace(pw)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 2.1K bytes - Viewed (0)