- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Krause (0.29 sec)
-
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
import okhttp3.internal.connection.RealConnectionPool import okhttp3.internal.connection.RealRoutePlanner import okhttp3.internal.connection.RouteDatabase /** * Manages reuse of HTTP and HTTP/2 connections for reduced network latency. HTTP requests that * share the same [Address] may share a [Connection]. This class implements the policy * of which connections to keep open for future use. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
fun sendFrame(): Http2Writer { outFrames.add(OutFrame(frameCount++, bytesOut.size, false)) return writer } /** * Shortens the last frame from its original length to `length`. This will cause the peer to * close the socket as soon as this frame has been written; otherwise the peer stays open until * explicitly closed. */ fun truncateLastFrame(length: Int): Http2Writer {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
private val data = Buffer() private val random = Random(0) /** * Check all data as verified inside of the test. We do this in an AfterEachCallback so that * exceptions thrown from the test do not cause this check to fail. */ @RegisterExtension val noDataLeftBehind = AfterEachCallback { context: ExtensionContext -> if (context.executionException.isPresent) return@AfterEachCallback
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RetryTlsHandshake.kt
// ConnectionSpec: we assume it is unreachable. e is InterruptedIOException -> false // If the problem was a CertificateException from the X509TrustManager, do not retry. e is SSLHandshakeException && e.cause is CertificateException -> false // e.g. a certificate pinning error. e is SSLPeerUnverifiedException -> false // Retry for all other SSL failures. e is SSLException -> true else -> false
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 07 16:05:34 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/SessionReuseTest.kt
assertEquals(200, response.code) } client.connectionPool.evictAll() assertEquals(0, client.connectionPool.connectionCount()) // Force reuse. This appears flaky (30% of the time) even though sessions are reused. // javax.net.ssl.SSLHandshakeException: No new session is allowed and no existing // session can be resumed //
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ReusePlan.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.connection /** Reuse a connection from the pool. */ internal class ReusePlan( val connection: RealConnection, ) : RoutePlanner.Plan { override val isReady = true override fun connectTcp() = error("already connected")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
) fun noNewExchanges() fun cancel() } companion object { /** * The timeout to use while discarding a stream of input data. Since this is used for connection * reuse, this timeout should be significantly less than the time it takes to establish a new * connection. */ const val DISCARD_STREAM_TIMEOUT_MILLIS = 100 }
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/Connection.kt
* avoiding these options entirely, this class allows a connection to be attempted with modern * options and then retried without them should the attempt fail. * * ## Connection Reuse * * Each connection can carry a varying number of streams, depending on the underlying protocol being * used. HTTP/1.x connections can carry either zero or one streams. HTTP/2 connections can carry any
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.3K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
assertEquals(200, response.code) assertEquals("h3", response.negotiatedProtocol) assertTrue(response.content.contains("Disallow")) } catch (ee: ExecutionException) { throw ee.cause?.cause ?: ee.cause!! } } data class Response( val code: Int, val negotiatedProtocol: String, val content: String, ) private fun execute( engine: HttpEngine,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 24 13:19:43 GMT 2024 - 6.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it. */ object ShutdownInputAtEnd : SocketPolicy /** * Shutdown the socket output after sending the response. For testing bad behavior. * * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it. */ object ShutdownOutputAtEnd : SocketPolicy
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0)