- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for updateConnectionFlowControl (0.22 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
throw errorExceptionToDeliver!! } return -1L // This source is exhausted. } } private fun updateConnectionFlowControl(read: Long) { lock.assertNotHeld() connection.updateConnectionFlowControl(read) } /** * Accept bytes on the connection's reader thread. This function avoids holding locks while it
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
// The removed stream may be blocked on a connection-wide window update. condition.signalAll() return stream } } internal fun updateConnectionFlowControl(read: Long) { this.withLock { readBytes.update(total = read) val readBytesToAcknowledge = readBytes.unacknowledged if (readBytesToAcknowledge >= okHttpSettings.initialWindowSize / 2) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0)