From dcf83bc1b5e17d0a599b00aaba813d2ccff68dbb Mon Sep 17 00:00:00 2001 From: Travis Watkins Date: Fri, 3 Aug 2012 00:46:21 -0500 Subject: Restore configurable connection throttle. --- .../minecraft/server/DedicatedServerConnectionThread.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) (limited to 'src') diff --git a/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java b/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java index f27ce28f..28f804bf 100644 --- a/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java +++ b/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java @@ -22,7 +22,9 @@ public class DedicatedServerConnectionThread extends Thread { private final InetAddress g; private final int h; - public DedicatedServerConnectionThread(ServerConnection serverconnection, InetAddress inetaddress, int i) { + long connectionThrottle; // CraftBukkit + + public DedicatedServerConnectionThread(ServerConnection serverconnection, InetAddress inetaddress, int i) throws IOException { // CraftBukkit - added throws super("Listen thread"); this.f = serverconnection; this.g = inetaddress; @@ -62,8 +64,17 @@ public class DedicatedServerConnectionThread extends Thread { long i = System.currentTimeMillis(); HashMap hashmap = this.c; + // CraftBukkit start + if (((MinecraftServer) this.f.d()).server == null) { + socket.close(); + continue; + } + + connectionThrottle = ((MinecraftServer) this.f.d()).server.getConnectionThrottle(); + // CraftBukkit end + synchronized (this.c) { - if (this.c.containsKey(inetaddress) && !b(inetaddress) && i - ((Long) this.c.get(inetaddress)).longValue() < 4000L) { + if (this.c.containsKey(inetaddress) && !b(inetaddress) && i - ((Long) this.c.get(inetaddress)).longValue() < connectionThrottle) { this.c.put(inetaddress, Long.valueOf(i)); socket.close(); continue; -- cgit v1.2.3