- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for applyAndAckSettings (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
rstStream?.receiveRstStream(errorCode) } override fun settings( clearPrevious: Boolean, settings: Settings, ) { writerQueue.execute("$connectionName applyAndAckSettings") { applyAndAckSettings(clearPrevious, settings) } } /** * Apply inbound settings and send an acknowledgement to the peer that provided them. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
} sink.write(CONNECTION_PREFACE) sink.flush() } } /** Applies `peerSettings` and then sends a settings ACK. */ @Throws(IOException::class) fun applyAndAckSettings(peerSettings: Settings) { this.withLock { if (closed) throw IOException("closed") this.maxFrameSize = peerSettings.getMaxFrameSize(maxFrameSize) if (peerSettings.headerTableSize != -1) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
connection: Http2Connection, amount: Int, ) { val settings = Settings() settings[Settings.MAX_CONCURRENT_STREAMS] = amount connection.readerRunnable.applyAndAckSettings(true, settings) assertThat(connection.peerSettings[Settings.MAX_CONCURRENT_STREAMS]).isEqualTo(amount) taskFaker.runTasks() }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
val connection = connect(peer) // fake a settings frame with clear flag set. val settings2 = Settings() settings2[Settings.MAX_CONCURRENT_STREAMS] = 60000 connection.readerRunnable.applyAndAckSettings(true, settings2) connection.withLock { assertThat(connection.peerSettings.headerTableSize).isEqualTo(-1) assertThat(connection.peerSettings.initialWindowSize)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0)