- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for Hong (0.2 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
* connection if `streamId` is zero. */ @Throws(IOException::class) fun windowUpdate( streamId: Int, windowSizeIncrement: Long, ) { this.withLock { if (closed) throw IOException("closed") require(windowSizeIncrement != 0L && windowSizeIncrement <= 0x7fffffffL) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
clientListener.assertOpen() // Send messages until the client's outgoing buffer overflows! val message: ByteString = ByteString.of(*ByteArray(1024 * 1024)) var messageCount: Long = 0 while (true) { val success = webSocket.send(message) if (!success) break messageCount++ val queueSize = webSocket.queueSize()
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) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
pool.evictAll() assertThat(pool.connectionCount()).isEqualTo(0) taskFaker.runTasks() } private fun forceConnectionsToExpire( pool: RealConnectionPool, expireTime: Long, ) { val idleTimeNanos = expireTime + pool.keepAliveDurationNs repeat(pool.connectionCount()) { pool.closeConnections(idleTimeNanos) } taskFaker.runTasks() } private fun connectHttp2(
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) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
*/ class Cache internal constructor( directory: Path, maxSize: Long, fileSystem: FileSystem, taskRunner: TaskRunner, ) : Closeable, Flushable { /** Create a cache of at most [maxSize] bytes in [directory]. */ constructor( fileSystem: FileSystem, directory: Path, maxSize: Long, ) : this( directory, maxSize, fileSystem, TaskRunner.INSTANCE,
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-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
var uriHost: String = "example.com" var uriPort: Int = 1 fun newConnection( pool: RealConnectionPool, route: Route, idleAtNanos: Long = Long.MAX_VALUE, taskRunner: TaskRunner = this.taskRunner, ): RealConnection { val result = RealConnection.newTestConnection( taskRunner = taskRunner, connectionPool = pool,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
"Retry-After", "1", ), body = "You took too long!", socketPolicy = DisconnectAtEnd, ), ) val request = Request(server.url("/")) val response = client.newCall(request).execute() assertThat(response.body.string()).isEqualTo("You took too long!") } @Test fun requestBodyRetransmittedOnClientRequestTimeout() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-CacheControlCommon.kt
if (immutable) append("immutable, ") if (isEmpty()) return "" deleteRange(length - 2, length) } headerValue = result } return result } internal fun Long.commonClampToInt(): Int { return when { this > Int.MAX_VALUE -> Int.MAX_VALUE else -> toInt() } } internal fun CacheControl.Companion.commonForceNetwork() = CacheControl.Builder() .noCache()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
while (source!!.read(buffer, 16384) != -1L) { } source.close() buffer.readByteString() } } private fun assertFile( prefix: ByteString, upstreamSize: Long, metadataSize: Int, upstream: String?, metadata: ByteString?, ) { val source = file.source().buffer() assertThat(source.readByteString(prefix.size.toLong())).isEqualTo(prefix)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/tls/OkHostnameVerifier.kt
// character in that label return false } // Optimization: check whether hostname is too short to match the pattern. hostName must be at // least as long as the pattern because asterisk must match the whole left-most label and // hostname starts with a non-empty label. Thus, asterisk has to match one or more characters. if (hostname.length < pattern.length) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
private val pingIntervalMillis: Long, /** * For clients this is initially null, and will be assigned to the agreed-upon extensions. For * servers it should be the agreed-upon extensions immediately. */ private var extensions: WebSocketExtensions?, /** If compression is negotiated, outbound messages of this size and larger will be compressed. */ private var minimumDeflateSize: Long, private val webSocketCloseTimeout: Long,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0)