diff --git a/ktor-hosts/ktor-jetty/test/JettyDeadlock.kt b/ktor-hosts/ktor-jetty/test/JettyDeadlock.kt index 46a3bbaf2e..549963f58c 100644 --- a/ktor-hosts/ktor-jetty/test/JettyDeadlock.kt +++ b/ktor-hosts/ktor-jetty/test/JettyDeadlock.kt @@ -44,12 +44,12 @@ class JettyDeadlockTest { val e = Executors.newCachedThreadPool() val q = LinkedBlockingQueue() - println("starting") + //println("starting") val conns = (0..2000).map { number -> e.submit(Callable { try { URL("http://localhost:$port/").openConnection().inputStream.bufferedReader().readLine().apply { - println("$number says $this") + //println("$number says $this") } ?: "" } catch (t: Throwable) { "error: ${t.message}" @@ -59,7 +59,7 @@ class JettyDeadlockTest { }) } - println("Main thread is waiting for responses") + //println("Main thread is waiting for responses") TimeUnit.SECONDS.sleep(5) var attempts = 7 @@ -67,7 +67,7 @@ class JettyDeadlockTest { fun dump() { val (valid, invalid) = conns.filter { it.isDone }.partition { it.get() == "Help !" } - println("Completed: ${valid.size} valid, ${invalid.size} invalid of ${valid.size + invalid.size} total [attempts $attempts]") + //println("Completed: ${valid.size} valid, ${invalid.size} invalid of ${valid.size + invalid.size} total [attempts $attempts]") } while (true) { diff --git a/ktor-hosts/ktor-test-host/src/org/jetbrains/ktor/testing/HostTestSuite.kt b/ktor-hosts/ktor-test-host/src/org/jetbrains/ktor/testing/HostTestSuite.kt index 8c6665fe56..1ddcecdbb8 100644 --- a/ktor-hosts/ktor-test-host/src/org/jetbrains/ktor/testing/HostTestSuite.kt +++ b/ktor-hosts/ktor-test-host/src/org/jetbrains/ktor/testing/HostTestSuite.kt @@ -893,7 +893,7 @@ abstract class HostTestSuite : HostTestBase() { @Test(timeout = 30000L) fun testBlockingConcurrency() { - println() + //println() val completed = AtomicInteger(0) createAndStartServer({ @@ -904,7 +904,7 @@ abstract class HostTestSuite : HostTestBase() { get("/{index}") { val index = call.parameters["index"]!!.toInt() call.respondWrite { - print("[$index] ") + //print("[$index] ") try { append("OK:$index\n") } finally { @@ -927,7 +927,7 @@ abstract class HostTestSuite : HostTestBase() { inputStream.reader().use { reader -> val firstByte = reader.read() if (firstByte == -1) { - println("Premature end of response stream at iteration $i") + //println("Premature end of response stream at iteration $i") fail("Premature end of response stream at iteration $i") } else { assertEquals('O', firstByte.toChar())