KTOR-8164 Bump tiny header limit in CIO engine (#4650)

eb01f24d · Bruce Hamilton · GitHub · b91443ef · eb01f24d · eb01f24d
--- a/ktor-http/ktor-http-cio/common/src/io/ktor/http/cio/HttpHeadersMap.kt
+++ b/ktor-http/ktor-http-cio/common/src/io/ktor/http/cio/HttpHeadersMap.kt
@@ -7,7 +7,7 @@ package io.ktor.http.cio
 import io.ktor.http.cio.internals.*
 import io.ktor.utils.io.pool.*

-private const val EXPECTED_HEADERS_QTY = 64
+private const val EXPECTED_HEADERS_QTY = 512

 /*
 * index array structure

--- a/ktor-server/ktor-server-cio/common/test/io/ktor/tests/server/cio/CIOEngineTest.kt
+++ b/ktor-server/ktor-server-cio/common/test/io/ktor/tests/server/cio/CIOEngineTest.kt
@@ -4,6 +4,7 @@

 package io.ktor.tests.server.cio

+import io.ktor.client.request.header
 import io.ktor.client.statement.*
 import io.ktor.http.*
 import io.ktor.http.content.*
@@ -171,6 +172,26 @@ class CIOHttpServerTest : HttpServerCommonTestSuite<CIOApplicationEngine, CIOApp
        }
    }

+    @Test
+    fun testLotsOfHeaders() = runTest {
+        val count = 500
+        val implicitHeadersCount = 4
+
+        createAndStartServer {
+            get("/headers") {
+                call.respond("${call.request.headers.entries().size} headers received")
+            }
+        }
+        withUrl("/headers", {
+            repeat(count) {
+                header("HeaderName$it", "HeaderContent$it")
+            }
+        }) {
+            assertEquals(HttpStatusCode.OK, status)
+            assertEquals("${count + implicitHeadersCount} headers received", bodyAsText())
+        }
+    }
+
    private suspend fun readAvailable(channel: ByteReadChannel): String {
        val buffer = ByteArray(1024)
        val length = channel.readAvailable(buffer)