KTOR-9125 Fix double ResponseSent invocation when exception is thrown after respond (#5215)

Author: marychatte

ktor-server/ktor-server-core/common/src/io/ktor/server/engine/DefaultEnginePipeline.kt

@@ -17,8 +17,8 @@ import io.ktor.util.cio.*
 import io.ktor.util.logging.*
 import io.ktor.util.pipeline.*
 import io.ktor.utils.io.*
-import kotlinx.coroutines.*
 import kotlinx.coroutines.CancellationException
+import kotlinx.coroutines.TimeoutCancellationException
 import kotlinx.io.IOException
 
 /**

ktor-server/ktor-server-test-host/common/src/io/ktor/server/testing/TestApplicationEngine.kt

@@ -122,6 +122,7 @@ public class TestApplicationEngine(
 
     private suspend fun handleTestFailure(call: ApplicationCall, cause: Throwable) {
         logError(call, cause)
+        if (call.response.isSent) return
 
         val throwOnException = environment.config
             .propertyOrNull(CONFIG_KEY_THROW_ON_EXCEPTION)

ktor-server/ktor-server-test-suites/common/src/io/ktor/server/testing/suites/HttpServerCommonTestSuite.kt

@@ -821,6 +821,36 @@ abstract class HttpServerCommonTestSuite<TEngine : ApplicationEngine, TConfigura
         }
     }
 
+    @Test
+    fun testResponseSentCalledOnce() = runTest {
+        var responseSentCalled = 0
+        createAndStartServer {
+            serverConfig {
+                enableSsl = false
+                enableHttp2 = false
+            }
+            install(
+                createRouteScopedPlugin("Plugin") {
+                    on(ResponseSent) {
+                        responseSentCalled++
+                    }
+                }
+            )
+
+            get("/") {
+                call.respond("ok")
+                throw ExpectedTestException("exception")
+            }
+        }
+
+        withUrl("/") {
+            assertEquals(HttpStatusCode.OK, status)
+            assertEquals("ok", bodyAsText())
+        }
+        delay(500)
+        assertEquals(1, responseSentCalled)
+    }
+
     private data class TestData(
         val name: String
     ) : AbstractCoroutineContextElement(TestData) {