Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 9 additions & 4 deletions okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ import okhttp3.internal.http.RecordingProxySelector
import okhttp3.internal.http2.ErrorCode
import okhttp3.testing.PlatformRule
import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.RepeatedTest
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.extension.RegisterExtension

Expand Down Expand Up @@ -82,7 +83,7 @@ class RouteFailureTest {
.build()
}

@Test
@RepeatedTest(100)
fun http2OneBadHostOneGoodNoRetryOnConnectionFailure() {
enableProtocol(Protocol.HTTP_2)

Expand All @@ -107,6 +108,7 @@ class RouteFailureTest {
.assertFailureMatches("stream was reset: REFUSED_STREAM")

assertThat(client.routeDatabase.failedRoutes).isEmpty()
server1.takeRequest()
assertThat(server1.requestCount).isEqualTo(1)
assertThat(server2.requestCount).isEqualTo(0)

Expand Down Expand Up @@ -162,7 +164,7 @@ class RouteFailureTest {
)
}

@Test
@RepeatedTest(100)
fun http2OneBadHostOneGoodNoRetryOnConnectionFailureFastFallback() {
enableProtocol(Protocol.HTTP_2)

Expand All @@ -187,6 +189,7 @@ class RouteFailureTest {
.assertFailureMatches("stream was reset: REFUSED_STREAM")

assertThat(client.routeDatabase.failedRoutes).isEmpty()
server1.takeRequest()
assertThat(server1.requestCount).isEqualTo(1)
assertThat(server2.requestCount).isEqualTo(0)

Expand Down Expand Up @@ -242,7 +245,7 @@ class RouteFailureTest {
)
}

@Test
@RepeatedTest(100)
fun http2OneBadHostRetryOnConnectionFailure() {
enableProtocol(Protocol.HTTP_2)

Expand All @@ -266,6 +269,7 @@ class RouteFailureTest {
.assertFailureMatches("stream was reset: REFUSED_STREAM")

assertThat(client.routeDatabase.failedRoutes).isEmpty()
server1.takeRequest()
assertThat(server1.requestCount).isEqualTo(1)

assertThat(clientTestRule.recordedConnectionEventTypes()).containsExactly(
Expand All @@ -276,7 +280,7 @@ class RouteFailureTest {
)
}

@Test
@RepeatedTest(100)
fun http2OneBadHostRetryOnConnectionFailureFastFallback() {
enableProtocol(Protocol.HTTP_2)

Expand All @@ -300,6 +304,7 @@ class RouteFailureTest {
.assertFailureMatches("stream was reset: REFUSED_STREAM")

assertThat(client.routeDatabase.failedRoutes).isEmpty()
server1.takeRequest()
assertThat(server1.requestCount).isEqualTo(1)

assertThat(clientTestRule.recordedConnectionEventTypes()).containsExactly(
Expand Down
Loading