Fix flaky tests

Author: Mr3zee

krpc/krpc-ktor/krpc-ktor-core/src/jvmTest/kotlin/kotlinx/rpc/krpc/ktor/KtorTransportTest.kt

@@ -9,6 +9,7 @@ package kotlinx.rpc.krpc.ktor
 import io.ktor.client.*
 import io.ktor.client.engine.cio.*
 import io.ktor.client.plugins.HttpRequestRetry
+import io.ktor.client.plugins.HttpTimeout
 import io.ktor.client.request.*
 import io.ktor.client.statement.*
 import io.ktor.server.application.*
@@ -188,6 +189,9 @@ class KtorTransportTest {
                 retryOnServerErrors(maxRetries = 5)
                 exponentialDelay()
             }
+            install(HttpTimeout) {
+                requestTimeoutMillis = 10000
+            }
 
             installKrpc {
                 serialization {
@@ -296,6 +300,9 @@ class KtorTransportTest {
                 retryOnServerErrors(maxRetries = 5)
                 exponentialDelay()
             }
+            install(HttpTimeout) {
+                requestTimeoutMillis = 10000
+            }
 
             installKrpc {
                 serialization {

krpc/krpc-test/src/commonTest/kotlin/kotlinx/rpc/krpc/test/BackPressureTest.kt

@@ -90,7 +90,7 @@ class BackPressureTest : BackPressureTestBase() {
 abstract class BackPressureTestBase {
     protected fun runServerTest(
         perCallBufferSize: Int,
-        timeout: Duration = 30.seconds,
+        timeout: Duration = 120.seconds,
     ) = runTest(perCallBufferSize, timeout) { service, impl ->
         var counter = 0
         val flowList = async {
@@ -123,7 +123,7 @@ abstract class BackPressureTestBase {
 
     protected fun runClientTest(
         perCallBufferSize: Int,
-        timeout: Duration = 30.seconds,
+        timeout: Duration = 120.seconds,
     ) = runTest(perCallBufferSize, timeout) { service, impl ->
         var counter = 0
         val flowList = async {

tests/krpc-protocol-compatibility-tests/src/test/kotlin/kotlinx/rpc/krpc/test/compat/KrpcProtocolCompatibilityTestsBase.kt

@@ -104,7 +104,7 @@ abstract class KrpcProtocolCompatibilityTestsBase {
 
     private fun testOldClientWithNewServer(
         perCallBufferSize: Int = 1,
-        timeout: Duration = 10.seconds,
+        timeout: Duration = 60.seconds,
         exclude: List<Versions>,
         body: suspend TestEnv.(CompatService, CompatServiceImpl) -> Unit,
     ) = runTest(Role.Client, exclude, timeout) {
@@ -117,7 +117,7 @@ abstract class KrpcProtocolCompatibilityTestsBase {
 
     private fun testOldServersWithNewClient(
         perCallBufferSize: Int = 1,
-        timeout: Duration = 10.seconds,
+        timeout: Duration = 60.seconds,
         exclude: List<Versions>,
         body: suspend TestEnv.(CompatService, CompatServiceImpl) -> Unit,
     ) = runTest(Role.Server, exclude, timeout) {
@@ -130,7 +130,7 @@ abstract class KrpcProtocolCompatibilityTestsBase {
 
     protected fun matrixTest(
         perCallBufferSize: Int = 1,
-        timeout: Duration = 10.seconds,
+        timeout: Duration = 60.seconds,
         exclude: List<VersionRolePair> = emptyList(),
         body: suspend TestEnv.(CompatService, CompatServiceImpl) -> Unit,
     ): Stream<DynamicTest> {