- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for barrier (0.19 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/FlowControlListener.kt
* [WindowCounter] generally carries the client view of total and acked bytes. */ fun receivingStreamWindowChanged( streamId: Int, windowCounter: WindowCounter, bufferSize: Long, ) /** * Notification that the receiving connection flow control window has changed. * [WindowCounter] generally carries the client view of total and acked bytes. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
* the inbound request was truncated, this exception will be non-null. */ val failure: IOException? = null, ) { val method: String? val path: String? /** * The TLS handshake of the connection that carried this request, or null if the request was * received without TLS. */ val handshake: Handshake? val requestUrl: HttpUrl? /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3.8K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
recurrence: Boolean, ): Boolean { task.initQueue(this) val now = taskRunner.backend.nanoTime() val executeNanoTime = now + delayNanos // If the task is already scheduled, take the earlier of the two times. val existingIndex = futureTasks.indexOf(task) if (existingIndex != -1) { if (task.nextExecuteNanoTime <= executeNanoTime) { taskRunner.logger.taskLog(task, this) { "already scheduled" }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/StreamResetException.kt
* limitations under the License. */ package okhttp3.internal.http2 import java.io.IOException /** Thrown when an HTTP/2 stream is canceled without damage to the socket that carries it. */ class StreamResetException( @JvmField val errorCode: ErrorCode,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 869 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
import okhttp3.Request import okhttp3.Response import okhttp3.internal.checkDuration import okhttp3.internal.connection.Exchange import okhttp3.internal.connection.RealCall /** * A concrete interceptor chain that carries the entire interceptor chain: all application * interceptors, the OkHttp core, all network interceptors, and finally the network caller. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/Android10SocketAdapter.kt
import okhttp3.internal.platform.Platform import okhttp3.internal.platform.Platform.Companion.isAndroid /** * Simple non-reflection SocketAdapter for Android Q+. * * These API assumptions make it unsuitable for use on earlier Android versions. */ @SuppressLint("NewApi") @SuppressSignatureCheck class Android10SocketAdapter : SocketAdapter { override fun matchesSocket(sslSocket: SSLSocket): Boolean = SSLSockets.isSupportedSocket(sslSocket)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
import okio.Sink import okio.Source /** Encodes HTTP requests and decodes HTTP responses. */ interface ExchangeCodec { /** The connection or CONNECT tunnel that owns this codec. */ val carrier: Carrier /** Returns an output stream where the request body can be streamed. */ @Throws(IOException::class) fun createRequestBody( request: Request, contentLength: Long, ): Sink
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
internal var hasFailure: Boolean = false private set internal val connection: RealConnection get() = codec.carrier as? RealConnection ?: error("no connection for CONNECT tunnels") internal val isCoalescedConnection: Boolean get() = finder.routePlanner.address.url.host != codec.carrier.route.address.url.host @Throws(IOException::class) fun writeRequestHeaders(request: Request) { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
import okhttp3.internal.immutableListOf import okio.Sink import okio.Source /** Encode requests and responses using HTTP/2 frames. */ class Http2ExchangeCodec( client: OkHttpClient, override val carrier: Carrier, private val chain: RealInterceptorChain, private val http2Connection: Http2Connection, ) : ExchangeCodec { @Volatile private var stream: Http2Stream? = null private val protocol: Protocol =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0)