Increase stress test timeout

Author: Mr3zee

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

@@ -24,54 +24,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, 300.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, 300.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, 400.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, 300.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, 300.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, 400.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, 300.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, 300.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, 400.seconds, 200, 10)
 
 
     // ~23 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, 300.seconds, 150, 10)
 
     // ~24 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, 300.seconds, 150, 10)
 
     // ~20 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, 300.seconds, 150, 10)
 }
 
 
@@ -179,7 +179,7 @@ abstract class BaseStressTest : BaseServiceTest() {
 
     private fun runTest(
         perCallBufferSize: Int = 100,
-        timeout: Duration = 120.seconds,
+        timeout: Duration = 300.seconds,
         body: suspend Env.(Counter) -> Unit,
     ) = runTestWithCoroutinesProbes(timeout = timeout) {
         RpcInternalDumpLoggerContainer.set(null)