Archiviert
13
0

Add DedicatedServerConnectionThread from mc-dev for diff visibility.

Dieser Commit ist enthalten in:
Travis Watkins 2012-08-03 00:06:25 -05:00
Ursprung d5fea5fd0d
Commit e156354a60

Datei anzeigen

@ -0,0 +1,119 @@
package net.minecraft.server;
import java.io.IOException;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
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;
public DedicatedServerConnectionThread(ServerConnection serverconnection, InetAddress inetaddress, int i) {
super("Listen thread");
this.f = serverconnection;
this.g = inetaddress;
this.h = i;
this.e = new ServerSocket(i, 0, inetaddress);
this.e.setPerformancePreferences(0, 2, 1);
}
public void a() {
List list = this.b;
synchronized (this.b) {
for (int i = 0; i < this.b.size(); ++i) {
NetLoginHandler netloginhandler = (NetLoginHandler) this.b.get(i);
try {
netloginhandler.c();
} catch (Exception exception) {
netloginhandler.disconnect("Internal server error");
a.log(Level.WARNING, "Failed to handle packet: " + exception, exception);
}
if (netloginhandler.c) {
this.b.remove(i--);
}
netloginhandler.networkManager.a();
}
}
}
public void run() {
while (this.f.b) {
try {
Socket socket = this.e.accept();
InetAddress inetaddress = socket.getInetAddress();
long i = System.currentTimeMillis();
HashMap hashmap = this.c;
synchronized (this.c) {
if (this.c.containsKey(inetaddress) && !b(inetaddress) && i - ((Long) this.c.get(inetaddress)).longValue() < 4000L) {
this.c.put(inetaddress, Long.valueOf(i));
socket.close();
continue;
}
this.c.put(inetaddress, Long.valueOf(i));
}
NetLoginHandler netloginhandler = new NetLoginHandler(this.f.d(), socket, "Connection #" + this.d++);
this.a(netloginhandler);
} catch (IOException ioexception) {
ioexception.printStackTrace();
}
}
System.out.println("Closing listening thread");
}
private void a(NetLoginHandler netloginhandler) {
if (netloginhandler == null) {
throw new IllegalArgumentException("Got null pendingconnection!");
} else {
List list = this.b;
synchronized (this.b) {
this.b.add(netloginhandler);
}
}
}
private static boolean b(InetAddress inetaddress) {
return "127.0.0.1".equals(inetaddress.getHostAddress());
}
public void a(InetAddress inetaddress) {
if (inetaddress != null) {
HashMap hashmap = this.c;
synchronized (this.c) {
this.c.remove(inetaddress);
}
}
}
public void b() {
try {
this.e.close();
} catch (Throwable throwable) {
;
}
}
}