Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for updateConnectionFlowControl (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top