- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for slow (0.21 sec)
-
okhttp/src/test/java/okhttp3/CallTest.kt
assertThat(server.takeRequest().sequenceNumber).isEqualTo(1) } @Tag("Slow") @Test fun successfulExpectContinuePermitsConnectionReuseWithHttp2() { enableProtocol(Protocol.HTTP_2) successfulExpectContinuePermitsConnectionReuse() } @Tag("Slow") @Test fun unsuccessfulExpectContinuePreventsConnectionReuse() { server.enqueue(MockResponse())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
* Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this happened enough then eventually the connection would stall. * Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we could use new flow control capacity before acknowledging it, causing strict HTTP/2 servers to fail the call.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
* this address. * * If [planToReplace] is non-null, this will swap it for a pooled connection if that pooled * connection uses HTTP/2. That results in fewer sockets overall and thus fewer TCP slow starts. */ internal fun planReusePooledConnection( planToReplace: ConnectPlan? = null, routes: List<Route>? = null, ): ReusePlan? { val result =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
// transmitted until the flow-control window is updated from the first request. val call2 = client.newCall(Request(server.url("/"))) val response2 = call2.execute() assertThat(response2.code).isEqualTo(200) // Close the response body. This should discard the buffered data and update the connection // flow-control window. response1.close()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
import okio.Pipe import okio.buffer import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test @Tag("Slow") class RealWebSocketTest { // NOTE: Fields are named 'client' and 'server' for cognitive simplicity. This differentiation has // zero effect on the behavior of the WebSocket API which is why tests are only written once
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Disabled import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension @Flaky @Tag("Slow") class WebSocketHttpTest { // Flaky https://github.com/square/okhttp/issues/4515 // Flaky https://github.com/square/okhttp/issues/4953 @RegisterExtension var clientTestRule = configureClientTestRule()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
/** Settings we communicate to the peer. */ val okHttpSettings = Settings().apply { // Flow control was designed more for servers, or proxies than edge clients. If we are a client, // set the flow control window to 16MiB. This avoids thrashing window updates every 64KiB, yet // small enough to avoid blowing up the heap. if (builder.client) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
* .url("http://publicobject.com/helloworld.txt") * .build(); * ``` * * ## Force a Cache Response * * Sometimes you'll want to show resources if they are available immediately, but not otherwise. * This can be used so your application can show *something* while waiting for the latest data to be * downloaded. To restrict a request to locally-cached resources, add the `only-if-cached` * directive: *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
/** True if this connect was canceled; typically because it lost a race. */ @Volatile private var canceled = false // These properties are initialized by connect() and never reassigned. /** The low-level TCP socket. */ private var rawSocket: Socket? = null /** * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket] * itself if this connection does not use SSL. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
listOf( FakeFileSystem().apply { emulateUnix() } to false, FileSystem.SYSTEM to TestUtil.windows, FakeFileSystem().apply { emulateWindows() } to true, ) } @Timeout(60) @Tag("Slow") class DiskLruCacheTest { private lateinit var filesystem: FaultyFileSystem private var windows: Boolean = false @TempDir lateinit var cacheDirFile: File lateinit var cacheDir: Path
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0)