From dcf83bc1b5e17d0a599b00aaba813d2ccff68dbb Mon Sep 17 00:00:00 2001
From: Travis Watkins <amaranth@ubuntu.com>
Date: Fri, 3 Aug 2012 00:46:21 -0500
Subject: [PATCH] Restore configurable connection throttle.

---
 .../server/DedicatedServerConnectionThread.java   | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java b/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java
index f27ce28f7a..28f804bf1b 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;