- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 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) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/http2/Http2Connection;->removeStream$okhttp(I)Lokhttp3/internal/http2/Http2Stream; HSPLokhttp3/internal/http2/Http2Connection;->shutdown(Lokhttp3/internal/http2/ErrorCode;)V HSPLokhttp3/internal/http2/Http2Connection;->updateConnectionFlowControl$okhttp(J)V HSPLokhttp3/internal/http2/Http2Connection;->writeData(IZLokio/Buffer;J)V HSPLokhttp3/internal/http2/Http2ExchangeCodec;-><clinit>()V
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (0)