- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for readLong (0.36 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
val prefix = header.readByteString(PREFIX_CLEAN.size.toLong()) if (prefix != PREFIX_CLEAN) throw IOException("unreadable cache file") val upstreamSize = header.readLong() val metadataSize = header.readLong() // Read the metadata. val metadataBuffer = Buffer() fileOperator.read(FILE_HEADER_SIZE + upstreamSize, metadataBuffer, metadataSize)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
name = "INTEGER", tagClass = DerHeader.TAG_CLASS_UNIVERSAL, tag = 2L, codec = object : BasicDerAdapter.Codec<Long> { override fun decode(reader: DerReader): Long = reader.readLong() override fun encode( writer: DerWriter, value: Long, ) = writer.writeLong(value) }, ) val INTEGER_AS_BIG_INTEGER = BasicDerAdapter(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
) } // Get frame length, optionally reading from follow-up bytes if indicated by special values. frameLength = (b1 and B1_MASK_LENGTH).toLong() if (frameLength == PAYLOAD_SHORT.toLong()) { frameLength = (source.readShort() and 0xffff).toLong() // Value is unsigned. } else if (frameLength == PAYLOAD_LONG.toLong()) { frameLength = source.readLong() if (frameLength < 0L) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
if (bytesLeft == 0L) throw ProtocolException("unexpected length: $bytesLeft at $this") val byteArray = source.readByteArray(bytesLeft) return BigInteger(byteArray) } fun readLong(): Long { if (bytesLeft !in 1..8) throw ProtocolException("unexpected length: $bytesLeft at $this") var result = source.readByte().toLong() // No "and 0xff" because this is a signed value!
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
check(state == STATE_OPEN_RESPONSE_BODY) { "state: $state" } state = STATE_READING_RESPONSE_BODY return FixedLengthSource(length) } private fun newChunkedSource(url: HttpUrl): Source { check(state == STATE_OPEN_RESPONSE_BODY) { "state: $state" } state = STATE_READING_RESPONSE_BODY return ChunkedSource(url) } private fun newUnknownLengthSource(): Source {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
// Give up because the cache cannot be written. try { editor?.abort() } catch (_: IOException) { } } /** * Initialize the cache. This will include reading the journal files from the storage and building * up the necessary in-memory cache information. * * The initialization time may vary depending on the journal file size and the current actual
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
TYPE_SETTINGS -> readSettings(handler, length, flags, streamId) TYPE_PUSH_PROMISE -> readPushPromise(handler, length, flags, streamId) TYPE_PING -> readPing(handler, length, flags, streamId) TYPE_GOAWAY -> readGoAway(handler, length, flags, streamId) TYPE_WINDOW_UPDATE -> readWindowUpdate(handler, length, flags, streamId)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
timeout().clearDeadline() } else { timeout().deadlineNanoTime(nowNs + originalDurationNs) } } } /** * Attempts to exhaust this, returning true if successful. This is useful when reading a complete * source is helpful, such as when doing so completes a cache body or frees a socket connection for * reuse. */ internal fun Source.discard( timeout: Int, timeUnit: TimeUnit, ): Boolean =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* ... // Handle the failure. * } * }); * ``` * * These examples will not work if you're consuming the response body on another thread. In such * cases the consuming thread must call [close] when it has finished reading the response * body. * * ### The response body can be consumed only once. * * This class may be used to stream very large responses. For example, it is possible to use this
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
"timeout", "Read timed out", ) assertThat(webSocket.close(1000, null)).isFalse() } /** * There's no read timeout when reading the first byte of a new frame. But as soon as we start * reading a frame we enable the read timeout. In this test we have the server returning the first * byte of a frame but no more frames. */ @Test fun readTimeoutAppliesWithinFrames() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1)