From 3ebaecf37eed0070c90b07e4b70cddcb502f7676 Mon Sep 17 00:00:00 2001 From: MobiusDev <8391001+MobiusDevelopment@users.noreply.github.com> Date: Wed, 18 Mar 2015 14:37:56 +0000 Subject: [PATCH] Minor Loginserver improvements. --- .../com/l2jserver/loginserver/FloodProtectedListener.java | 4 ++-- trunk/java/com/l2jserver/loginserver/GameServerThread.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/trunk/java/com/l2jserver/loginserver/FloodProtectedListener.java b/trunk/java/com/l2jserver/loginserver/FloodProtectedListener.java index 9d699d3dbf..2ac770ae9f 100644 --- a/trunk/java/com/l2jserver/loginserver/FloodProtectedListener.java +++ b/trunk/java/com/l2jserver/loginserver/FloodProtectedListener.java @@ -22,8 +22,8 @@ import java.io.IOException; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; -import java.util.HashMap; import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; import java.util.logging.Level; import java.util.logging.Logger; @@ -35,7 +35,7 @@ import com.l2jserver.Config; public abstract class FloodProtectedListener extends Thread { private final Logger _log = Logger.getLogger(FloodProtectedListener.class.getName()); - private final Map _floodProtection = new HashMap<>(); + private final Map _floodProtection = new ConcurrentHashMap<>(); private ServerSocket _serverSocket; public FloodProtectedListener(String listenIp, int port) throws IOException diff --git a/trunk/java/com/l2jserver/loginserver/GameServerThread.java b/trunk/java/com/l2jserver/loginserver/GameServerThread.java index 230d54f19c..61af719f1e 100644 --- a/trunk/java/com/l2jserver/loginserver/GameServerThread.java +++ b/trunk/java/com/l2jserver/loginserver/GameServerThread.java @@ -26,8 +26,8 @@ import java.net.Socket; import java.security.KeyPair; import java.security.interfaces.RSAPrivateKey; import java.security.interfaces.RSAPublicKey; -import java.util.HashSet; import java.util.Set; +import java.util.concurrent.ConcurrentHashMap; import java.util.logging.Logger; import com.l2jserver.Config; @@ -63,7 +63,7 @@ public class GameServerThread extends Thread private GameServerInfo _gsi; /** Authed Clients on a GameServer */ - private final Set _accountsOnGameServer = new HashSet<>(); + private final Set _accountsOnGameServer = ConcurrentHashMap.newKeySet(); private String _connectionIPAddress;