- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for 0L (0.41 sec)
-
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
builder = builder.callTimeout(0L, TimeUnit.SECONDS) builder = builder.callTimeout(Duration.ofSeconds(0L)) builder = builder.connectTimeout(0L, TimeUnit.SECONDS) builder = builder.connectTimeout(Duration.ofSeconds(0L)) builder = builder.readTimeout(0L, TimeUnit.SECONDS) builder = builder.readTimeout(Duration.ofSeconds(0L)) builder = builder.writeTimeout(0L, TimeUnit.SECONDS)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 46.5K bytes - Viewed (4) -
android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 14.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
val hasData = sendBuffer.size > 0L val hasTrailers = trailers != null when { hasTrailers -> { while (sendBuffer.size > 0L) { emitFrame(false) } connection.writeHeaders(id, outFinished, trailers!!.toHeaderList()) } hasData -> { while (sendBuffer.size > 0L) { emitFrame(true)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
private var intervalPingsSent = 0L private var intervalPongsReceived = 0L private var degradedPingsSent = 0L private var degradedPongsReceived = 0L private var awaitPingsSent = 0L private var awaitPongsReceived = 0L /** Consider this connection to be unhealthy if a degraded pong isn't received by this time. */ private var degradedPongDeadlineNs = 0L
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt
val servedMillis = servedDate?.time ?: sentRequestMillis val delta = servedMillis - lastModified!!.time return if (delta > 0L) delta / 10 else 0L } return 0L } /** * Returns the current age of the response, in milliseconds. The calculation is specified by RFC * 7234, 4.2.3 Calculating Age. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/flowcontrol/WindowCounter.kt
package okhttp3.internal.http2.flowcontrol class WindowCounter( val streamId: Int, ) { /** The total number of bytes consumed. */ var total: Long = 0L private set /** The total number of bytes acknowledged by outgoing `WINDOW_UPDATE` frames. */ var acknowledged: Long = 0L private set val unacknowledged: Long @Synchronized get() = total - acknowledged @Synchronized fun update( total: Long = 0,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
// We've chosen a connection to evict. Confirm it's still okay to be evicted, then close it. toEvict.withLock { if (toEvict.calls.isNotEmpty()) return 0L // No longer idle. if (toEvict.idleAtNs != toEvictIdleAtNs) return 0L // No longer oldest. toEvict.noNewExchanges = true connections.remove(toEvict) } addressStates[toEvict.route.address]?.scheduleOpener()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
val pool = factory.newConnectionPool() val poolApi = ConnectionPool(pool) val c1 = factory.newConnection(pool, routeA1, 0L) allocateAndLeakAllocation(poolApi, c1) awaitGarbageCollection() assertThat(pool.closeConnections(100L)).isEqualTo(0L) assertThat(c1.calls).isEmpty() // Can't allocate once a leak has been detected. assertThat(c1.noNewExchanges).isTrue() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
val buffer = Buffer() var receivedByteCount = 0L @Throws(IOException::class) override fun write( source: Buffer, byteCount: Long, ) { val toRead = minOf(remainingByteCount, byteCount) if (toRead > 0L) { source.read(buffer, toRead) } val toSkip = byteCount - toRead if (toSkip > 0L) { source.skip(toSkip) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/math/LongMathTest.java
for (RoundingMode mode : ALL_ROUNDING_MODES) { assertEquals(0L, LongMath.divide(0L, q, mode)); } } } @GwtIncompatible // TODO public void testDivByZeroAlwaysFails() { for (long p : ALL_LONG_CANDIDATES) { for (RoundingMode mode : ALL_ROUNDING_MODES) { try { LongMath.divide(p, 0L, mode); fail("Expected ArithmeticException");
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 04 20:15:57 GMT 2024 - 32.5K bytes - Viewed (0)