From 962f523af9eba5b5cc67fffa91320ee394291d0b Mon Sep 17 00:00:00 2001 From: s809 <43530948+s809@users.noreply.github.com> Date: Fri, 5 Jan 2024 22:37:27 +0500 Subject: [PATCH] Fix 1.16.5 and 1.17.1 builds --- .../com/seibel/distanthorizons/core/network/NetworkClient.java | 2 +- .../com/seibel/distanthorizons/core/network/NetworkServer.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkClient.java b/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkClient.java index 3db6f26dc..be323d3d3 100644 --- a/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkClient.java +++ b/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkClient.java @@ -69,7 +69,7 @@ public class NetworkClient extends NetworkEventSource implements IConnection, Au /** Indicates whether the connection is established and first message is sent. */ public boolean isReady() { return ready; } - private final EventLoopGroup workerGroup = new NioEventLoopGroup(new DefaultThreadFactory("DH-Network - Client Thread")); + private final EventLoopGroup workerGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("DH-Network - Client Thread")); private final Bootstrap clientBootstrap = new Bootstrap() .group(this.workerGroup) .channel(NioSocketChannel.class) diff --git a/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkServer.java b/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkServer.java index a9a77fd55..d62a26876 100644 --- a/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkServer.java +++ b/core/src/main/java/com/seibel/distanthorizons/core/network/NetworkServer.java @@ -47,7 +47,7 @@ public class NetworkServer extends NetworkEventSource implements AutoCloseable private final int port; private final EventLoopGroup bossGroup = new NioEventLoopGroup(1, new DefaultThreadFactory("DH-Network - Server Boss Thread")); - private final EventLoopGroup workerGroup = new NioEventLoopGroup(new DefaultThreadFactory("DH-Network - Server Worker Thread")); + private final EventLoopGroup workerGroup = new NioEventLoopGroup(0, new DefaultThreadFactory("DH-Network - Server Worker Thread")); private final AtomicBoolean isClosed = new AtomicBoolean(); private final ConcurrentMap connections = new MapMaker().weakKeys().weakValues().makeMap();