diff options
Diffstat (limited to 'src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java')
-rw-r--r-- | src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java | 79 |
1 files changed, 38 insertions, 41 deletions
diff --git a/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java b/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java index 25e2ac1d..5be8dc2b 100644 --- a/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java +++ b/src/main/java/net/minecraft/server/DedicatedServerConnectionThread.java @@ -8,47 +8,44 @@ import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.List; -import java.util.logging.Level; -import java.util.logging.Logger; public class DedicatedServerConnectionThread extends Thread { - private static Logger a = Logger.getLogger("Minecraft"); - private final List b = Collections.synchronizedList(new ArrayList()); - private final HashMap c = new HashMap(); - private int d = 0; - private final ServerSocket e; - private ServerConnection f; - private final InetAddress g; - private final int h; + private final List a = Collections.synchronizedList(new ArrayList()); + private final HashMap b = new HashMap(); + private int c = 0; + private final ServerSocket d; + private ServerConnection e; + private final InetAddress f; + private final int g; long connectionThrottle; // CraftBukkit public DedicatedServerConnectionThread(ServerConnection serverconnection, InetAddress inetaddress, int i) throws IOException { // CraftBukkit - added throws super("Listen thread"); - this.f = serverconnection; - this.h = i; - this.e = new ServerSocket(i, 0, inetaddress); - this.g = inetaddress == null ? this.e.getInetAddress() : inetaddress; - this.e.setPerformancePreferences(0, 2, 1); + this.e = serverconnection; + this.g = i; + this.d = new ServerSocket(i, 0, inetaddress); + this.f = inetaddress == null ? this.d.getInetAddress() : inetaddress; + this.d.setPerformancePreferences(0, 2, 1); } public void a() { - List list = this.b; + List list = this.a; - synchronized (this.b) { - for (int i = 0; i < this.b.size(); ++i) { - PendingConnection pendingconnection = (PendingConnection) this.b.get(i); + synchronized (this.a) { + for (int i = 0; i < this.a.size(); ++i) { + PendingConnection pendingconnection = (PendingConnection) this.a.get(i); try { pendingconnection.c(); } catch (Exception exception) { pendingconnection.disconnect("Internal server error"); - a.log(Level.WARNING, "Failed to handle packet for " + pendingconnection.getName() + ": " + exception, exception); + this.e.d().getLogger().warning("Failed to handle packet for " + pendingconnection.getName() + ": " + exception, (Throwable) exception); } - if (pendingconnection.c) { - this.b.remove(i--); + if (pendingconnection.b) { + this.a.remove(i--); } pendingconnection.networkManager.a(); @@ -57,51 +54,51 @@ public class DedicatedServerConnectionThread extends Thread { } public void run() { - while (this.f.b) { + while (this.e.a) { try { - Socket socket = this.e.accept(); + Socket socket = this.d.accept(); InetAddress inetaddress = socket.getInetAddress(); long i = System.currentTimeMillis(); - HashMap hashmap = this.c; + HashMap hashmap = this.b; // CraftBukkit start - if (((MinecraftServer) this.f.d()).server == null) { + if (((MinecraftServer) this.e.d()).server == null) { socket.close(); continue; } - connectionThrottle = ((MinecraftServer) this.f.d()).server.getConnectionThrottle(); + connectionThrottle = ((MinecraftServer) this.e.d()).server.getConnectionThrottle(); // CraftBukkit end - synchronized (this.c) { - if (this.c.containsKey(inetaddress) && !b(inetaddress) && i - ((Long) this.c.get(inetaddress)).longValue() < connectionThrottle) { - this.c.put(inetaddress, Long.valueOf(i)); + synchronized (this.b) { + if (this.b.containsKey(inetaddress) && !b(inetaddress) && i - ((Long) this.b.get(inetaddress)).longValue() < connectionThrottle) { + this.b.put(inetaddress, Long.valueOf(i)); socket.close(); continue; } - this.c.put(inetaddress, Long.valueOf(i)); + this.b.put(inetaddress, Long.valueOf(i)); } - PendingConnection pendingconnection = new PendingConnection(this.f.d(), socket, "Connection #" + this.d++); + PendingConnection pendingconnection = new PendingConnection(this.e.d(), socket, "Connection #" + this.c++); this.a(pendingconnection); } catch (IOException ioexception) { - a.warning("DSCT: " + ioexception.getMessage()); // CraftBukkit + this.e.d().getLogger().warning("DSCT: " + ioexception.getMessage()); // CraftBukkit } } - System.out.println("Closing listening thread"); + this.e.d().getLogger().info("Closing listening thread"); } private void a(PendingConnection pendingconnection) { if (pendingconnection == null) { throw new IllegalArgumentException("Got null pendingconnection!"); } else { - List list = this.b; + List list = this.a; - synchronized (this.b) { - this.b.add(pendingconnection); + synchronized (this.a) { + this.a.add(pendingconnection); } } } @@ -112,17 +109,17 @@ public class DedicatedServerConnectionThread extends Thread { public void a(InetAddress inetaddress) { if (inetaddress != null) { - HashMap hashmap = this.c; + HashMap hashmap = this.b; - synchronized (this.c) { - this.c.remove(inetaddress); + synchronized (this.b) { + this.b.remove(inetaddress); } } } public void b() { try { - this.e.close(); + this.d.close(); } catch (Throwable throwable) { ; } |