Support extra configuration in Netty Epoll adapter

hexagontk · Nov 5, 2023 · 6a84138 · 6a84138
1 parent c63ecda
commit 6a84138
Show file tree

Hide file tree

Showing 3 changed files with 20 additions and 3 deletions.
diff --git a/http/http_server_netty/src/main/kotlin/com/hexagonkt/http/server/netty/NettyServerAdapter.kt b/http/http_server_netty/src/main/kotlin/com/hexagonkt/http/server/netty/NettyServerAdapter.kt
@@ -58,6 +58,10 @@ open class NettyServerAdapter(
         soKeepAlive = true,
         shutdownQuietSeconds = 0,
         shutdownTimeoutSeconds = 0,
+        keepAliveHandler = true,
+        httpAggregatorHandler = true,
+        chunkedHandler = true,
+        enableWebsockets = true,
     )
 
     override fun runtimePort(): Int =

diff --git a/http/http_server_netty_epoll/api/http_server_netty_epoll.api b/http/http_server_netty_epoll/api/http_server_netty_epoll.api
@@ -1,7 +1,7 @@
 public final class com/hexagonkt/http/server/netty/epoll/NettyEpollServerAdapter : com/hexagonkt/http/server/netty/NettyServerAdapter {
 	public fun <init> ()V
-	public fun <init> (IIIIZZ)V
-	public synthetic fun <init> (IIIIZZILkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public fun <init> (IIIIZZJJZZZZ)V
+	public synthetic fun <init> (IIIIZZJJZZZZILkotlin/jvm/internal/DefaultConstructorMarker;)V
 	public fun groupSupplier (I)Lio/netty/channel/MultithreadEventLoopGroup;
 	public fun serverBootstrapSupplier (Lio/netty/channel/MultithreadEventLoopGroup;Lio/netty/channel/MultithreadEventLoopGroup;)Lio/netty/bootstrap/ServerBootstrap;
 }

diff --git a/...ty_epoll/src/main/kotlin/com/hexagonkt/http/server/netty/epoll/NettyEpollServerAdapter.kt b/...ty_epoll/src/main/kotlin/com/hexagonkt/http/server/netty/epoll/NettyEpollServerAdapter.kt
@@ -21,16 +21,29 @@ class NettyEpollServerAdapter(
     private val soBacklog: Int = 4 * 1_024,
     private val soReuseAddr: Boolean = true,
     private val soKeepAlive: Boolean = true,
+    shutdownQuietSeconds: Long = 0,
+    shutdownTimeoutSeconds: Long = 0,
+    keepAliveHandler: Boolean = true,
+    httpAggregatorHandler: Boolean = true,
+    chunkedHandler: Boolean = true,
+    enableWebsockets: Boolean = true,
 ) : NettyServerAdapter(
     bossGroupThreads,
     workerGroupThreads,
     executorThreads,
     soBacklog,
     soReuseAddr,
     soKeepAlive,
+    shutdownQuietSeconds,
+    shutdownTimeoutSeconds,
+    keepAliveHandler,
+    httpAggregatorHandler,
+    chunkedHandler,
+    enableWebsockets,
 ) {
 
-    constructor() : this(1, 0, Jvm.cpuCount * 2, 4 * 1_024, true, true)
+    constructor() :
+        this(1, 0, Jvm.cpuCount * 2, 4 * 1_024, true, true, 0, 0, true, true, true, true)
 
     override fun groupSupplier(it: Int): MultithreadEventLoopGroup =
         EpollEventLoopGroup(it)