fix

Author: luigi

tests/codegen/service-codegen-tests/src/test/kotlin/com/test/CborServiceTest.kt

@@ -36,7 +36,7 @@ class CborServiceTest {
     @BeforeAll
     fun boot() {
         proc = startService("netty", port, closeGracePeriodMillis, closeTimeoutMillis, requestBodyLimit, projectDir)
-        val ready = waitForPort(port, portListnerTimeout)
+        val ready = waitForPort(port, portListnerTimeout, proc)
         assertTrue(ready, "Service did not start within $portListnerTimeout s")
     }
 

tests/codegen/service-codegen-tests/src/test/kotlin/com/test/ServiceConstraintsTest.kt

@@ -37,7 +37,7 @@ class ServiceConstraintsTest {
     @BeforeAll
     fun boot() {
         proc = startService("netty", port, closeGracePeriodMillis, closeTimeoutMillis, requestBodyLimit, projectDir)
-        val ready = waitForPort(port, portListenerTimeout)
+        val ready = waitForPort(port, portListenerTimeout, proc)
         assertTrue(ready, "Service did not start within $portListenerTimeout s")
     }
 

tests/codegen/service-codegen-tests/src/test/kotlin/com/test/ServiceEngineFactoryTest.kt

@@ -26,7 +26,7 @@ class ServiceEngineFactoryTest {
     fun `checks service with netty engine`() {
         val nettyPort: Int = ServerSocket(0).use { it.localPort }
         val nettyProc = startService("netty", nettyPort, closeGracePeriodMillis, closeTimeoutMillis, requestBodyLimit, projectDir)
-        val ready = waitForPort(nettyPort, portListnerTimeout)
+        val ready = waitForPort(nettyPort, portListnerTimeout, proc)
         assertTrue(ready, "Service did not start within $portListnerTimeout s")
         cleanupService(nettyProc, gracefulWindow)
     }

tests/codegen/service-codegen-tests/src/test/kotlin/com/test/utils.kt

@@ -83,7 +83,7 @@ private fun isWindows() = System.getProperty("os.name").lowercase().contains("wi
 internal fun waitForPort(port: Int, timeoutSec: Long = 180, proc: Process? = null): Boolean {
     val deadline = System.currentTimeMillis() + TimeUnit.SECONDS.toNanos(timeoutSec)
     while (System.currentTimeMillis() < deadline) {
-//        proc?.inputStream?.bufferedReader()?.forEachLine {println(it)}
+        proc?.inputStream?.bufferedReader()?.forEachLine {println(it)}
         try {
             Socket("localhost", port).use {
                 return true // Port is available