Extended timeouts

Author: Mr3zee

krpc/krpc-core/src/commonTest/kotlin/kotlinx/rpc/krpc/KrpcConnectorTest.kt

@@ -326,7 +326,7 @@ abstract class KrpcConnectorBaseTest {
     )
 
     protected fun runTest(
-        testTimeout: Duration = 3.seconds,
+        testTimeout: Duration = 15.seconds,
         waitTimeout: Duration = 1.seconds,
         callTimeout: Duration = 1.seconds,
         perCallBufferSize: Int = 100,

krpc/krpc-core/src/commonTest/kotlin/kotlinx/rpc/krpc/KrpcReceiveHandlerTest.kt

@@ -114,7 +114,7 @@ internal class KrpcReceiveHandlerTest : KrpcReceiveHandlerBaseTest() {
             callTimeOut = 10.seconds,
             bufferSize = bufferSize,
             callHandler = { collected.add(it) },
-            timeout = 120.seconds,
+            timeout = 240.seconds,
         ) { acting ->
             val sendChannel = Channel<KrpcTransportMessage>(Channel.UNLIMITED)
             val sender = KrpcSendHandler(sendChannel)

krpc/krpc-test/src/commonMain/kotlin/kotlinx/rpc/krpc/test/KrpcTransportTestBase.kt

@@ -498,6 +498,6 @@ abstract class KrpcTransportTestBase {
     }
 }
 
-private val JS_EXTENDED_TIMEOUT = if (isJs) 300.seconds else 60.seconds
+private val JS_EXTENDED_TIMEOUT = if (isJs) 400.seconds else 120.seconds
 
 internal expect val isJs: Boolean

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

@@ -25,6 +25,7 @@ import kotlin.test.Test
 import kotlin.test.assertEquals
 import kotlin.test.assertFails
 import kotlin.test.assertTrue
+import kotlin.time.Duration
 import kotlin.time.Duration.Companion.seconds
 
 @Rpc
@@ -81,9 +82,10 @@ class TransportTest {
     }
 
     private fun runTest(
+        timeout: Duration = 120.seconds,
         times: Int = testIterations,
         block: suspend TestScope.(logs: List<String>) -> Unit,
-    ): TestResult = kotlinx.coroutines.test.runTest(timeout = 120.seconds) {
+    ): TestResult = kotlinx.coroutines.test.runTest(timeout = timeout) {
         debugCoroutines()
 
         repeat(times) {
@@ -205,7 +207,7 @@ class TransportTest {
     }
 
     @Test
-    fun testLateConnectWithManyCallsAndClients() = runTest {
+    fun testLateConnectWithManyCallsAndClients() = runTest(timeout = 240.seconds) {
         val transports = LocalTransport()
 
         val client = clientOf(transports)

krpc/krpc-test/src/commonTest/kotlin/kotlinx/rpc/krpc/test/cancellation/CancellationToolkit.kt

@@ -24,7 +24,7 @@ import kotlinx.rpc.withService
 import kotlin.time.Duration.Companion.seconds
 
 fun runCancellationTest(body: suspend CancellationToolkit.() -> Unit): TestResult {
-    return runTest(timeout = 3.seconds) {
+    return runTest(timeout = 15.seconds) {
         debugCoroutines()
         val toolkit = CancellationToolkit(this)
         try {

krpc/krpc-test/src/jvmTest/kotlin/kotlinx/rpc/krpc/test/stress/StressTest.kt

@@ -18,54 +18,54 @@ import kotlin.time.Duration.Companion.seconds
 class StressTest : BaseStressTest() {
     // ~30 sec, 300_000 messages
     @Test
-    fun `unary, buffer 100, launches 3_000 x 100`() = testUnary(100, 120.seconds, 3_000, 100)
+    fun `unary, buffer 100, launches 3_000 x 100`() = testUnary(100, 240.seconds, 3_000, 100)
 
     // ~10 sec, 100_000 messages
     @Test
-    fun `unary, buffer 1, launches 10_000 x 10`() = testUnary(1, 120.seconds, 10_000, 10)
+    fun `unary, buffer 1, launches 10_000 x 10`() = testUnary(1, 240.seconds, 10_000, 10)
 
     // ~51 min, 500_000 messages
     @Test
-    fun `unary, 1000 buffer, launches 50_000 x 10`() = testUnary(1000, 180.seconds, 50_000, 10)
+    fun `unary, 1000 buffer, launches 50_000 x 10`() = testUnary(1000, 360.seconds, 50_000, 10)
 
 
     // ~15 sec, 4_000_000 messages
     @Test
-    fun `server streaming, buffer 30 buf, launches 200 x 10`() = testServerStreaming(30, 120.seconds, 200, 10)
+    fun `server streaming, buffer 30 buf, launches 200 x 10`() = testServerStreaming(30, 240.seconds, 200, 10)
 
     // ~19 sec, 4_000_000 messages
     @Test
-    fun `server streaming, buffer 1, launches 200 x 10`() = testServerStreaming(1, 120.seconds, 200, 10)
+    fun `server streaming, buffer 1, launches 200 x 10`() = testServerStreaming(1, 240.seconds, 200, 10)
 
     // ~14 sec, 4_000_000 messages
     @Test
-    fun `server streaming, buffer 2000, launches 200 x 10`() = testServerStreaming(2000, 180.seconds, 200, 10)
+    fun `server streaming, buffer 2000, launches 200 x 10`() = testServerStreaming(2000, 360.seconds, 200, 10)
 
 
     // ~15 sec, 4_000_000 messages
     @Test
-    fun `client streaming, buffer 30, launches 200 x 10`() = testClientStreaming(30, 120.seconds, 200, 10)
+    fun `client streaming, buffer 30, launches 200 x 10`() = testClientStreaming(30, 240.seconds, 200, 10)
 
     // ~19 sec, 4_000_000 messages
     @Test
-    fun `client streaming, buffer 1, launches 200 x 10`() = testClientStreaming(1, 120.seconds, 200, 10)
+    fun `client streaming, buffer 1, launches 200 x 10`() = testClientStreaming(1, 240.seconds, 200, 10)
 
     // ~15 sec, 4_000_000 messages
     @Test
-    fun `client streaming, buffer 2000, launches 200 x 10`() = testClientStreaming(2000, 180.seconds, 200, 10)
+    fun `client streaming, buffer 2000, launches 200 x 10`() = testClientStreaming(2000, 360.seconds, 200, 10)
 
 
     // ~30 sec, 4_500_000 messages
     @Test
-    fun `bidi streaming, buffer 30, launches 150 x 10`() = testBidiStreaming(30, 120.seconds, 150, 10)
+    fun `bidi streaming, buffer 30, launches 150 x 10`() = testBidiStreaming(30, 240.seconds, 150, 10)
 
     // ~33 sec, 4_500_000 messages
     @Test
-    fun `bidi streaming, buffer 1, launches 150 x 10`() = testBidiStreaming(1, 120.seconds, 150, 10)
+    fun `bidi streaming, buffer 1, launches 150 x 10`() = testBidiStreaming(1, 240.seconds, 150, 10)
 
     // ~29 sec, 4_500_000 messages
     @Test
-    fun `bidi streaming, buffer 2000, launches 150 x 10`() = testBidiStreaming(2000, 120.seconds, 150, 10)
+    fun `bidi streaming, buffer 2000, launches 150 x 10`() = testBidiStreaming(2000, 240.seconds, 150, 10)
 }
 
 

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

@@ -138,7 +138,7 @@ class KrpcProtocolCompatibilityTests : KrpcProtocolCompatibilityTestsBase() {
     }
 
     @TestFactory
-    fun fastProducer() = matrixTest(timeout = 30.seconds) { service, impl ->
+    fun fastProducer() = matrixTest(timeout = 60.seconds) { service, impl ->
         val async = async {
             service.fastServerProduce(1000).map {
                 // long produce