Paper/src/main/java/net/minecraft/server/MinecraftServer.java

1194 Zeilen
40 KiB
Java

2010-12-22 16:22:23 +01:00
package net.minecraft.server;
2012-07-29 09:33:13 +02:00
import java.awt.GraphicsEnvironment;
2010-12-22 16:22:23 +01:00
import java.io.File;
2012-07-29 09:33:13 +02:00
import java.security.KeyPair;
import java.text.SimpleDateFormat;
2010-12-22 16:22:23 +01:00
import java.util.ArrayList;
2012-07-29 09:33:13 +02:00
import java.util.Date;
2010-12-28 20:52:24 +01:00
import java.util.Iterator;
2010-12-22 16:22:23 +01:00
import java.util.List;
2012-07-29 09:33:13 +02:00
import java.util.concurrent.Callable;
2010-12-22 16:22:23 +01:00
import java.util.logging.Level;
import java.util.logging.Logger;
2010-12-28 20:52:24 +01:00
// CraftBukkit start
import java.util.concurrent.ExecutionException;
import java.io.IOException;
import com.google.common.io.Files;
import jline.console.ConsoleReader;
import joptsimple.OptionSet;
2011-05-26 14:48:22 +02:00
import org.bukkit.World.Environment;
import org.bukkit.craftbukkit.util.Waitable;
2012-01-30 21:51:53 +01:00
import org.bukkit.event.server.RemoteServerCommandEvent;
import org.bukkit.event.world.WorldSaveEvent;
// CraftBukkit end
2010-12-22 16:22:23 +01:00
2012-11-06 13:05:28 +01:00
public abstract class MinecraftServer implements ICommandListener, Runnable, IMojangStatistics {
2010-12-22 16:22:23 +01:00
public static Logger log = Logger.getLogger("Minecraft");
2012-07-29 09:33:13 +02:00
private static MinecraftServer l = null;
public Convertable convertable; // CraftBukkit - private final -> public
private final MojangStatisticsGenerator n = new MojangStatisticsGenerator("server", this);
public File universe; // CraftBukkit - private final -> public
private final List p = new ArrayList();
private final ICommandHandler q;
public final MethodProfiler methodProfiler = new MethodProfiler();
private String serverIp;
private int s = -1;
2011-05-28 22:50:08 +02:00
// public WorldServer[] worldServer; // CraftBukkit - removed!
2012-12-20 05:03:52 +01:00
private PlayerList t;
private boolean isRunning = true;
2012-07-29 09:33:13 +02:00
private boolean isStopped = false;
private int ticks = 0;
public String d;
public int e;
private boolean onlineMode;
private boolean spawnAnimals;
private boolean spawnNPCs;
private boolean pvpMode;
private boolean allowFlight;
private String motd;
private int D;
2012-03-01 11:49:23 +01:00
private long E;
private long F;
private long G;
private long H;
2012-07-29 09:33:13 +02:00
public final long[] f = new long[100];
public final long[] g = new long[100];
public final long[] h = new long[100];
public final long[] i = new long[100];
public final long[] j = new long[100];
public long[][] k;
private KeyPair I;
private String J;
private String K;
private boolean demoMode;
private boolean N;
private boolean O;
private String P = "";
private boolean Q = false;
private long R;
private String S;
private boolean T;
2010-12-28 20:52:24 +01:00
2011-02-23 13:56:36 +01:00
// CraftBukkit start
public List<WorldServer> worlds = new ArrayList<WorldServer>();
public org.bukkit.craftbukkit.CraftServer server;
2011-01-29 22:50:29 +01:00
public OptionSet options;
public org.bukkit.command.ConsoleCommandSender console;
public org.bukkit.command.RemoteConsoleCommandSender remoteConsole;
public ConsoleReader reader;
public static int currentTick;
public final Thread primaryThread;
public java.util.Queue<Runnable> processQueue = new java.util.concurrent.ConcurrentLinkedQueue<Runnable>();
public int autosavePeriod;
2011-05-14 16:29:42 +02:00
// CraftBukkit end
2010-12-22 16:22:23 +01:00
2012-07-29 09:33:13 +02:00
public MinecraftServer(OptionSet options) { // CraftBukkit - signature file -> OptionSet
l = this;
// this.universe = file1; // CraftBukkit
this.q = new CommandDispatcher();
// this.convertable = new WorldLoaderServer(server.getWorldContainer()); // CraftBukkit - moved to DedicatedServer.init
this.al();
2011-06-12 00:02:58 +02:00
// CraftBukkit start
this.options = options;
try {
this.reader = new ConsoleReader(System.in, System.out);
this.reader.setExpandEvents(false); // Avoid parsing exceptions for uncommonly used event designators
} catch (Exception e) {
try {
// Try again with jline disabled for Windows users without C++ 2008 Redistributable
System.setProperty("jline.terminal", "jline.UnsupportedTerminal");
System.setProperty("user.language", "en");
org.bukkit.craftbukkit.Main.useJline = false;
this.reader = new ConsoleReader(System.in, System.out);
this.reader.setExpandEvents(false);
2012-07-29 09:33:13 +02:00
} catch (java.io.IOException ex) {
Logger.getLogger(MinecraftServer.class.getName()).log(Level.SEVERE, null, ex);
}
}
Runtime.getRuntime().addShutdownHook(new org.bukkit.craftbukkit.util.ServerShutdownThread(this));
2012-07-29 09:33:13 +02:00
primaryThread = new ThreadServerApplication(this, "Server thread"); // Moved from main
}
public abstract PropertyManager getPropertyManager();
2012-07-29 09:33:13 +02:00
// CraftBukkit end
2011-11-20 09:01:14 +01:00
private void al() {
BlockDispenser.a.a(Item.ARROW, new DispenseBehaviorArrow(this));
BlockDispenser.a.a(Item.EGG, new DispenseBehaviorEgg(this));
BlockDispenser.a.a(Item.SNOW_BALL, new DispenseBehaviorSnowBall(this));
BlockDispenser.a.a(Item.EXP_BOTTLE, new DispenseBehaviorExpBottle(this));
BlockDispenser.a.a(Item.POTION, new DispenseBehaviorPotion(this));
BlockDispenser.a.a(Item.MONSTER_EGG, new DispenseBehaviorMonsterEgg(this));
2012-12-20 05:03:52 +01:00
BlockDispenser.a.a(Item.FIREWORKS, new DispenseBehaviorFireworks(this));
BlockDispenser.a.a(Item.FIREBALL, new DispenseBehaviorFireball(this));
DispenseBehaviorMinecart dispensebehaviorminecart = new DispenseBehaviorMinecart(this);
BlockDispenser.a.a(Item.MINECART, dispensebehaviorminecart);
BlockDispenser.a.a(Item.STORAGE_MINECART, dispensebehaviorminecart);
BlockDispenser.a.a(Item.POWERED_MINECART, dispensebehaviorminecart);
BlockDispenser.a.a(Item.BOAT, new DispenseBehaviorBoat(this));
DispenseBehaviorFilledBucket dispensebehaviorfilledbucket = new DispenseBehaviorFilledBucket(this);
BlockDispenser.a.a(Item.LAVA_BUCKET, dispensebehaviorfilledbucket);
BlockDispenser.a.a(Item.WATER_BUCKET, dispensebehaviorfilledbucket);
BlockDispenser.a.a(Item.BUCKET, new DispenseBehaviorEmptyBucket(this));
}
2012-07-29 09:33:13 +02:00
protected abstract boolean init() throws java.net.UnknownHostException; // CraftBukkit - throws UnknownHostException
2011-11-20 09:01:14 +01:00
protected void b(String s) {
2012-07-29 09:33:13 +02:00
if (this.getConvertable().isConvertable(s)) {
log.info("Converting map!");
this.c("menu.convertingLevel");
2012-07-29 09:33:13 +02:00
this.getConvertable().convert(s, new ConvertProgressUpdater(this));
}
2010-12-22 16:22:23 +01:00
}
protected synchronized void c(String s) {
2012-07-29 09:33:13 +02:00
this.S = s;
}
2011-02-23 03:37:56 +01:00
protected void a(String s, String s1, long i, WorldType worldtype, String s2) {
this.b(s);
this.c("menu.loadingLevel");
2011-11-20 09:01:14 +01:00
// CraftBukkit - removed world and ticktime arrays
2012-07-29 09:33:13 +02:00
IDataManager idatamanager = this.convertable.a(s, true);
WorldData worlddata = idatamanager.getWorldData();
// CraftBukkit start - removed worldsettings
2011-11-24 19:48:01 +01:00
int worldCount = 3;
2011-11-20 09:01:14 +01:00
2012-07-29 09:33:13 +02:00
for (int j = 0; j < worldCount; ++j) {
2011-05-26 14:48:22 +02:00
WorldServer world;
2011-11-20 09:01:14 +01:00
int dimension = 0;
2012-07-29 09:33:13 +02:00
if (j == 1) {
if (this.getAllowNether()) {
2011-11-24 19:48:01 +01:00
dimension = -1;
} else {
continue;
}
2011-11-20 09:01:14 +01:00
}
2012-07-29 09:33:13 +02:00
if (j == 2) {
if (this.server.getAllowEnd()) {
dimension = 1;
} else {
continue;
}
2011-11-20 09:01:14 +01:00
}
String worldType = Environment.getEnvironment(dimension).toString().toLowerCase();
String name = (dimension == 0) ? s : s + "_" + worldType;
org.bukkit.generator.ChunkGenerator gen = this.server.getGenerator(name);
WorldSettings worldsettings = new WorldSettings(i, this.getGamemode(), this.getGenerateStructures(), this.isHardcore(), worldtype);
worldsettings.a(s2);
2012-07-29 09:33:13 +02:00
if (j == 0) {
if (this.M()) { // Strip out DEMO?
2012-07-29 09:33:13 +02:00
// CraftBukkit
world = new DemoWorldServer(this, new ServerNBTManager(server.getWorldContainer(), s1, true), s1, dimension, this.methodProfiler);
} else {
// CraftBukkit
2012-09-14 07:03:47 +02:00
world = new WorldServer(this, new ServerNBTManager(server.getWorldContainer(), s1, true), s1, dimension, worldsettings, this.methodProfiler, Environment.getEnvironment(dimension), gen);
2012-07-29 09:33:13 +02:00
}
2011-05-26 14:48:22 +02:00
} else {
String dim = "DIM" + dimension;
File newWorld = new File(new File(name), dim);
File oldWorld = new File(new File(s), dim);
if ((!newWorld.isDirectory()) && (oldWorld.isDirectory())) {
log.info("---- Migration of old " + worldType + " folder required ----");
log.info("Unfortunately due to the way that Minecraft implemented multiworld support in 1.6, Bukkit requires that you move your " + worldType + " folder to a new location in order to operate correctly.");
log.info("We will move this folder for you, but it will mean that you need to move it back should you wish to stop using Bukkit in the future.");
log.info("Attempting to move " + oldWorld + " to " + newWorld + "...");
if (newWorld.exists()) {
log.severe("A file or folder already exists at " + newWorld + "!");
log.info("---- Migration of old " + worldType + " folder failed ----");
} else if (newWorld.getParentFile().mkdirs()) {
if (oldWorld.renameTo(newWorld)) {
log.info("Success! To restore " + worldType + " in the future, simply move " + newWorld + " to " + oldWorld);
// Migrate world data too.
try {
Files.copy(new File(new File(s), "level.dat"), new File(new File(name), "level.dat"));
} catch (IOException exception) {
log.severe("Unable to migrate world data.");
}
log.info("---- Migration of old " + worldType + " folder complete ----");
} else {
log.severe("Could not move folder " + oldWorld + " to " + newWorld + "!");
log.info("---- Migration of old " + worldType + " folder failed ----");
}
} else {
log.severe("Could not create path for " + newWorld + "!");
log.info("---- Migration of old " + worldType + " folder failed ----");
}
}
2012-07-29 09:33:13 +02:00
this.c(name);
2012-07-29 09:33:13 +02:00
// CraftBukkit
2012-09-14 07:03:47 +02:00
world = new SecondaryWorldServer(this, new ServerNBTManager(server.getWorldContainer(), name, true), name, dimension, worldsettings, this.worlds.get(0), this.methodProfiler, Environment.getEnvironment(dimension), gen);
}
if (gen != null) {
world.getWorld().getPopulators().addAll(gen.getDefaultPopulators(world.getWorld()));
2011-05-26 14:48:22 +02:00
}
this.server.getPluginManager().callEvent(new org.bukkit.event.world.WorldInitEvent(world.getWorld()));
2011-05-26 14:48:22 +02:00
world.addIWorldAccess(new WorldManager(this, world));
if (!this.I()) {
2012-07-29 09:33:13 +02:00
world.getWorldData().setGameType(this.getGamemode());
}
this.worlds.add(world);
2012-07-29 09:33:13 +02:00
this.t.setPlayerFileData(this.worlds.toArray(new WorldServer[this.worlds.size()]));
// CraftBukkit end
2011-05-26 14:48:22 +02:00
}
2012-07-29 09:33:13 +02:00
this.c(this.getDifficulty());
this.e();
2012-07-29 09:33:13 +02:00
}
protected void e() {
2011-01-29 22:50:29 +01:00
short short1 = 196;
2012-07-29 09:33:13 +02:00
long i = System.currentTimeMillis();
this.c("menu.generatingTerrain");
byte b0 = 0;
2011-01-29 22:50:29 +01:00
// CraftBukkit start
2012-07-29 09:33:13 +02:00
for (int j = 0; j < this.worlds.size(); ++j) {
WorldServer worldserver = this.worlds.get(j);
log.info("Preparing start region for level " + j + " (Seed: " + worldserver.getSeed() + ")");
2012-01-12 23:10:13 +01:00
if (!worldserver.getWorld().getKeepSpawnInMemory()) {
continue;
}
// CraftBukkit end
ChunkCoordinates chunkcoordinates = worldserver.getSpawn();
2011-01-29 22:50:29 +01:00
2012-07-29 09:33:13 +02:00
for (int k = -short1; k <= short1 && this.isRunning(); k += 16) {
for (int l = -short1; l <= short1 && this.isRunning(); l += 16) {
long i1 = System.currentTimeMillis();
2011-05-26 14:48:22 +02:00
2012-07-29 09:33:13 +02:00
if (i1 < i) {
i = i1;
2012-01-12 23:10:13 +01:00
}
2011-01-14 14:31:10 +01:00
2012-07-29 09:33:13 +02:00
if (i1 > i + 1000L) {
int j1 = (short1 * 2 + 1) * (short1 * 2 + 1);
int k1 = (k + short1) * (short1 * 2 + 1) + l + 1;
2011-01-29 22:50:29 +01:00
2012-07-29 09:33:13 +02:00
this.a_("Preparing spawn area", k1 * 100 / j1);
i = i1;
2012-01-12 23:10:13 +01:00
}
2011-01-29 22:50:29 +01:00
2012-07-29 09:33:13 +02:00
worldserver.chunkProviderServer.getChunkAt(chunkcoordinates.x + k >> 4, chunkcoordinates.z + l >> 4);
2010-12-22 16:22:23 +01:00
}
2012-01-12 23:10:13 +01:00
}
2010-12-22 16:22:23 +01:00
}
2010-12-28 20:52:24 +01:00
this.j();
2010-12-22 16:22:23 +01:00
}
2012-07-29 09:33:13 +02:00
public abstract boolean getGenerateStructures();
public abstract EnumGamemode getGamemode();
public abstract int getDifficulty();
public abstract boolean isHardcore();
protected void a_(String s, int i) {
this.d = s;
this.e = i;
log.info(s + ": " + i + "%");
2010-12-22 16:22:23 +01:00
}
protected void j() {
2012-07-29 09:33:13 +02:00
this.d = null;
this.e = 0;
this.server.enablePlugins(org.bukkit.plugin.PluginLoadOrder.POSTWORLD); // CraftBukkit
2010-12-22 16:22:23 +01:00
}
2012-07-29 09:33:13 +02:00
protected void saveChunks(boolean flag) throws ExceptionWorldConflict { // CraftBukkit - added throws
if (!this.O) {
// CraftBukkit start
for (int j = 0; j < this.worlds.size(); ++j) {
WorldServer worldserver = this.worlds.get(j);
2012-07-29 09:33:13 +02:00
if (worldserver != null) {
if (!flag) {
2012-08-25 02:51:51 +02:00
log.info("Saving chunks for level \'" + worldserver.getWorldData().getName() + "\'/" + worldserver.worldProvider.getName());
2012-07-29 09:33:13 +02:00
}
worldserver.save(true, (IProgressUpdate) null);
2012-07-29 09:33:13 +02:00
worldserver.saveLevel();
2011-05-26 14:48:22 +02:00
2012-07-29 09:33:13 +02:00
WorldSaveEvent event = new WorldSaveEvent(worldserver.getWorld());
this.server.getPluginManager().callEvent(event);
}
}
// CraftBukkit end
}
2010-12-22 16:22:23 +01:00
}
2012-07-29 09:33:13 +02:00
public void stop() throws ExceptionWorldConflict { // CraftBukkit - added throws
if (!this.O) {
log.info("Stopping server");
// CraftBukkit start
if (this.server != null) {
this.server.disablePlugins();
}
// CraftBukkit end
2011-02-02 00:32:18 +01:00
if (this.ae() != null) {
this.ae().a();
2012-07-29 09:33:13 +02:00
}
2011-01-27 22:15:41 +01:00
2012-07-29 09:33:13 +02:00
if (this.t != null) {
log.info("Saving players");
this.t.savePlayers();
this.t.r();
}
2011-05-26 14:48:22 +02:00
2012-07-29 09:33:13 +02:00
log.info("Saving worlds");
this.saveChunks(false);
2012-11-06 13:05:28 +01:00
/* CraftBukkit start - handled in saveChunks
for (int i = 0; i < this.worldServer.length; ++i) {
WorldServer worldserver = this.worldServer[i];
2012-07-29 09:33:13 +02:00
worldserver.saveLevel();
}
// CraftBukkit end */
if (this.n != null && this.n.d()) {
this.n.e();
2012-01-12 23:10:13 +01:00
}
2012-07-29 09:33:13 +02:00
}
}
public String getServerIp() {
return this.serverIp;
}
public void d(String s) {
2012-07-29 09:33:13 +02:00
this.serverIp = s;
}
public boolean isRunning() {
return this.isRunning;
2010-12-22 16:22:23 +01:00
}
public void safeShutdown() {
this.isRunning = false;
2010-12-22 16:22:23 +01:00
}
public void run() {
try {
if (this.init()) {
2011-01-29 22:50:29 +01:00
long i = System.currentTimeMillis();
2010-12-28 20:52:24 +01:00
2012-07-29 09:33:13 +02:00
for (long j = 0L; this.isRunning; this.Q = true) {
2011-01-29 22:50:29 +01:00
long k = System.currentTimeMillis();
long l = k - i;
2010-12-28 20:52:24 +01:00
2012-07-29 09:33:13 +02:00
if (l > 2000L && i - this.R >= 15000L) {
if (this.server.getWarnOnOverload()) // CraftBukkit - Added option to suppress warning messages
log.warning("Can\'t keep up! Did the system time change, or is the server overloaded?");
2011-01-29 22:50:29 +01:00
l = 2000L;
2012-07-29 09:33:13 +02:00
this.R = i;
2010-12-22 16:22:23 +01:00
}
2011-01-29 22:50:29 +01:00
if (l < 0L) {
log.warning("Time ran backwards! Did the system time change?");
2011-01-29 22:50:29 +01:00
l = 0L;
2010-12-22 16:22:23 +01:00
}
2011-01-29 22:50:29 +01:00
j += l;
i = k;
2011-05-28 22:50:08 +02:00
if (this.worlds.get(0).everyoneDeeplySleeping()) { // CraftBukkit
this.q();
2011-02-23 03:37:56 +01:00
j = 0L;
} else {
while (j > 50L) {
MinecraftServer.currentTick = (int) (System.currentTimeMillis() / 50); // CraftBukkit
2011-02-23 03:37:56 +01:00
j -= 50L;
this.q();
2011-02-23 03:37:56 +01:00
}
2010-12-22 16:22:23 +01:00
}
2011-01-29 22:50:29 +01:00
2012-07-29 09:33:13 +02:00
Thread.sleep(1L);
2010-12-22 16:22:23 +01:00
}
2012-07-29 09:33:13 +02:00
} else {
this.a((CrashReport) null);
2010-12-22 16:22:23 +01:00
}
2011-02-23 03:37:56 +01:00
} catch (Throwable throwable) {
throwable.printStackTrace();
2012-07-29 09:33:13 +02:00
log.log(Level.SEVERE, "Encountered an unexpected exception " + throwable.getClass().getSimpleName(), throwable);
CrashReport crashreport = null;
if (throwable instanceof ReportedException) {
crashreport = this.b(((ReportedException) throwable).a());
} else {
crashreport = this.b(new CrashReport("Exception in server tick loop", throwable));
}
2011-01-29 22:50:29 +01:00
File file1 = new File(new File(this.o(), "crash-reports"), "crash-" + (new SimpleDateFormat("yyyy-MM-dd_HH.mm.ss")).format(new Date()) + "-server.txt");
2011-01-29 22:50:29 +01:00
2012-07-29 09:33:13 +02:00
if (crashreport.a(file1)) {
log.severe("This crash report has been saved to: " + file1.getAbsolutePath());
} else {
log.severe("We were unable to save this crash report to disk.");
2010-12-22 16:22:23 +01:00
}
2012-07-29 09:33:13 +02:00
this.a(crashreport);
2010-12-22 16:22:23 +01:00
} finally {
2011-01-14 14:31:10 +01:00
try {
this.stop();
this.isStopped = true;
2012-07-29 09:33:13 +02:00
} catch (Throwable throwable1) {
throwable1.printStackTrace();
} finally {
// CraftBukkit start - restore terminal to original settings
try {
this.reader.getTerminal().restore();
} catch (Exception e) {
}
// CraftBukkit end
this.p();
2011-01-14 14:31:10 +01:00
}
2010-12-22 16:22:23 +01:00
}
}
protected File o() {
2012-07-29 09:33:13 +02:00
return new File(".");
}
protected void a(CrashReport crashreport) {}
protected void p() {}
2012-07-29 09:33:13 +02:00
protected void q() throws ExceptionWorldConflict { // CraftBukkit - added throws
2011-11-20 09:01:14 +01:00
long i = System.nanoTime();
2010-12-28 20:52:24 +01:00
2012-07-29 09:33:13 +02:00
AxisAlignedBB.a().a();
++this.ticks;
if (this.T) {
this.T = false;
2012-09-10 06:19:28 +02:00
this.methodProfiler.a = true;
this.methodProfiler.a();
2012-07-29 09:33:13 +02:00
}
2010-12-28 20:52:24 +01:00
2012-09-10 06:19:28 +02:00
this.methodProfiler.a("root");
this.r();
if ((this.autosavePeriod > 0) && ((this.ticks % this.autosavePeriod) == 0)) { // CraftBukkit
2012-09-10 06:19:28 +02:00
this.methodProfiler.a("save");
2012-07-29 09:33:13 +02:00
this.t.savePlayers();
this.saveChunks(true);
2012-09-10 06:19:28 +02:00
this.methodProfiler.b();
2010-12-22 16:22:23 +01:00
}
2010-12-28 20:52:24 +01:00
2012-09-10 06:19:28 +02:00
this.methodProfiler.a("tallying");
2012-07-29 09:33:13 +02:00
this.j[this.ticks % 100] = System.nanoTime() - i;
this.f[this.ticks % 100] = Packet.p - this.E;
this.E = Packet.p;
this.g[this.ticks % 100] = Packet.q - this.F;
this.F = Packet.q;
this.h[this.ticks % 100] = Packet.n - this.G;
this.G = Packet.n;
this.i[this.ticks % 100] = Packet.o - this.H;
this.H = Packet.o;
2012-09-10 06:19:28 +02:00
this.methodProfiler.b();
this.methodProfiler.a("snooper");
2012-07-29 09:33:13 +02:00
if (!this.n.d() && this.ticks > 100) {
this.n.a();
}
2011-01-29 22:50:29 +01:00
2012-07-29 09:33:13 +02:00
if (this.ticks % 6000 == 0) {
this.n.b();
2010-12-22 16:22:23 +01:00
}
2012-09-10 06:19:28 +02:00
this.methodProfiler.b();
this.methodProfiler.b();
2012-07-29 09:33:13 +02:00
}
public void r() {
2012-09-10 06:19:28 +02:00
this.methodProfiler.a("levels");
2011-08-07 05:45:56 +02:00
2012-07-29 09:33:13 +02:00
// CraftBukkit start - only send timeupdates to the people in that world
this.server.getScheduler().mainThreadHeartbeat(this.ticks);
// Run tasks that are waiting on processing
while (!processQueue.isEmpty()) {
processQueue.remove().run();
}
Load chunks asynchronously for players. When a player triggers a chunk load via walking around or teleporting there is no need to stop everything and get this chunk on the main thread. The client is used to having to wait some time for this chunk and the server doesn't immediately do anything with it except send it to the player. At the same time chunk loading is the last major source of file IO that still runs on the main thread. These two facts make it possible to offload chunks loaded for this reason to another thread. However, not all parts of chunk loading can happen off the main thread. For this we use the new AsynchronousExecutor system to split chunk loading in to three pieces. The first is loading data from disk, decompressing it, and parsing it in to an NBT structure. The second piece is creating entities and tile entities in the chunk and adding them to the world, this is still done on the main thread. The third piece is informing everyone who requested a chunk load that the load is finished. For this we register callbacks and then run them on the main thread once the previous two stages are finished. There are still cases where a chunk is needed immediately and these will still trigger chunk loading entirely on the main thread. The most obvious case is plugins using the API to request a chunk load. We also must load the chunk immediately when something in the world tries to access it. In these cases we ignore any possibly pending or in progress chunk loading that is happening asynchronously as we will have the chunk loaded by the time they are finished. The hope is that overall this system will result in less CPU time and pauses due to blocking file IO on the main thread thus giving more consistent performance. Testing so far has shown that this also speeds up chunk loading client side although some of this is likely to be because we are sending less chunks at once for the client to process. Thanks for @ammaraskar for help with the implementation of this feature.
2012-11-30 09:49:19 +01:00
org.bukkit.craftbukkit.chunkio.ChunkIOExecutor.tick();
// Send timeupdates to everyone, it will get the right time from the world the player is in.
if (this.ticks % 20 == 0) {
2012-12-20 05:03:52 +01:00
for (int i = 0; i < this.getPlayerList().players.size(); ++i) {
EntityPlayer entityplayer = (EntityPlayer) this.getPlayerList().players.get(i);
entityplayer.playerConnection.sendPacket(new Packet4UpdateTime(entityplayer.world.getTime(), entityplayer.getPlayerTime())); // Add support for per player time
}
}
2012-11-06 13:05:28 +01:00
int i;
for (i = 0; i < this.worlds.size(); ++i) {
2012-07-29 09:33:13 +02:00
long j = System.nanoTime();
// if (i == 0 || this.getAllowNether()) {
WorldServer worldserver = this.worlds.get(i);
this.methodProfiler.a(worldserver.getWorldData().getName());
this.methodProfiler.a("pools");
worldserver.getVec3DPool().a();
this.methodProfiler.b();
/* Drop global time updates
2011-05-28 22:50:08 +02:00
if (this.ticks % 20 == 0) {
this.methodProfiler.a("timeSync");
2012-11-06 13:05:28 +01:00
this.t.a(new Packet4UpdateTime(worldserver.getTime(), worldserver.getDayTime()), worldserver.worldProvider.dimension);
this.methodProfiler.b();
2011-05-26 14:48:22 +02:00
}
// CraftBukkit end */
2012-09-10 06:19:28 +02:00
this.methodProfiler.a("tick");
2012-11-06 13:05:28 +01:00
CrashReport crashreport;
try {
worldserver.doTick();
} catch (Throwable throwable) {
crashreport = CrashReport.a(throwable, "Exception ticking world");
worldserver.a(crashreport);
throw new ReportedException(crashreport);
}
try {
worldserver.tickEntities();
} catch (Throwable throwable1) {
crashreport = CrashReport.a(throwable1, "Exception ticking world entities");
worldserver.a(crashreport);
throw new ReportedException(crashreport);
}
this.methodProfiler.b();
this.methodProfiler.a("tracker");
worldserver.getTracker().updatePlayers();
this.methodProfiler.b();
this.methodProfiler.b();
2012-07-29 09:33:13 +02:00
// } // CraftBukkit
2011-05-26 14:48:22 +02:00
2012-07-29 09:33:13 +02:00
// this.k[i][this.ticks % 100] = System.nanoTime() - j; // CraftBukkit
2011-05-26 14:48:22 +02:00
}
2011-01-29 22:50:29 +01:00
2012-09-10 06:19:28 +02:00
this.methodProfiler.c("connection");
this.ae().b();
2012-09-10 06:19:28 +02:00
this.methodProfiler.c("players");
2012-07-29 09:33:13 +02:00
this.t.tick();
2012-09-10 06:19:28 +02:00
this.methodProfiler.c("tickables");
2011-11-20 09:01:14 +01:00
2012-11-06 13:05:28 +01:00
for (i = 0; i < this.p.size(); ++i) {
((IUpdatePlayerListBox) this.p.get(i)).a();
2012-07-29 09:33:13 +02:00
}
2010-12-22 16:22:23 +01:00
2012-09-10 06:19:28 +02:00
this.methodProfiler.b();
2010-12-22 16:22:23 +01:00
}
2012-07-29 09:33:13 +02:00
public boolean getAllowNether() {
return true;
2010-12-22 16:22:23 +01:00
}
2010-12-28 20:52:24 +01:00
public void a(IUpdatePlayerListBox iupdateplayerlistbox) {
2012-07-29 09:33:13 +02:00
this.p.add(iupdateplayerlistbox);
2010-12-22 16:22:23 +01:00
}
2012-07-29 09:33:13 +02:00
public static void main(final OptionSet options) { // CraftBukkit - replaces main(String[] astring)
2011-04-20 22:47:26 +02:00
StatisticList.a();
2010-12-22 16:22:23 +01:00
try {
2012-07-29 09:33:13 +02:00
/* CraftBukkit start - replace everything
boolean flag = false;
String s = null;
String s1 = ".";
String s2 = null;
boolean flag1 = false;
boolean flag2 = false;
int i = -1;
for (int j = 0; j < astring.length; ++j) {
String s3 = astring[j];
String s4 = j == astring.length - 1 ? null : astring[j + 1];
boolean flag3 = false;
if (!s3.equals("nogui") && !s3.equals("--nogui")) {
if (s3.equals("--port") && s4 != null) {
flag3 = true;
try {
i = Integer.parseInt(s4);
} catch (NumberFormatException numberformatexception) {
;
}
} else if (s3.equals("--singleplayer") && s4 != null) {
flag3 = true;
s = s4;
} else if (s3.equals("--universe") && s4 != null) {
flag3 = true;
s1 = s4;
} else if (s3.equals("--world") && s4 != null) {
flag3 = true;
s2 = s4;
} else if (s3.equals("--demo")) {
flag1 = true;
} else if (s3.equals("--bonusChest")) {
flag2 = true;
}
} else {
flag = false;
}
if (flag3) {
++j;
}
}
// */
2011-01-29 22:50:29 +01:00
2012-07-29 09:33:13 +02:00
DedicatedServer dedicatedserver = new DedicatedServer(options);
if (options.has("port")) {
int port = (Integer) options.valueOf("port");
if (port > 0) {
dedicatedserver.setPort(port);
}
}
if (options.has("universe")) {
dedicatedserver.universe = (File) options.valueOf("universe");
}
if (options.has("world")) {
dedicatedserver.l((String) options.valueOf("world"));
2012-07-29 09:33:13 +02:00
}
/*
if (s != null) {
dedicatedserver.k(s);
2012-07-29 09:33:13 +02:00
}
if (s2 != null) {
dedicatedserver.l(s2);
2012-07-29 09:33:13 +02:00
}
2010-12-22 16:22:23 +01:00
2012-07-29 09:33:13 +02:00
if (i >= 0) {
dedicatedserver.setPort(i);
}
if (flag1) {
dedicatedserver.b(true);
}
if (flag2) {
dedicatedserver.c(true);
}
if (flag) {
dedicatedserver.an();
2012-07-29 09:33:13 +02:00
}
*/
dedicatedserver.primaryThread.start();
// Runtime.getRuntime().addShutdownHook(new ThreadShutdown(dedicatedserver));
// CraftBukkit end
2010-12-28 20:52:24 +01:00
} catch (Exception exception) {
log.log(Level.SEVERE, "Failed to start the minecraft server", exception);
2010-12-22 16:22:23 +01:00
}
}
public void t() {
2012-07-29 09:33:13 +02:00
// (new ThreadServerApplication(this, "Server thread")).start(); // CraftBukkit - prevent abuse
2010-12-22 16:22:23 +01:00
}
public File e(String s) {
return new File(this.o(), s);
2012-07-29 09:33:13 +02:00
}
public void info(String s) {
log.info(s);
2010-12-22 16:22:23 +01:00
}
2011-11-20 09:01:14 +01:00
public void warning(String s) {
log.warning(s);
2011-03-31 22:40:00 +02:00
}
public WorldServer getWorldServer(int i) {
2011-05-28 22:50:08 +02:00
// CraftBukkit start
for (WorldServer world : this.worlds) {
if (world.dimension == i) {
return world;
}
}
2011-05-28 22:50:08 +02:00
return this.worlds.get(0);
2011-05-28 22:50:08 +02:00
// CraftBukkit end
2011-05-26 14:48:22 +02:00
}
public String u() {
2012-07-29 09:33:13 +02:00
return this.serverIp;
2011-11-20 09:01:14 +01:00
}
public int v() {
2012-07-29 09:33:13 +02:00
return this.s;
2011-11-20 09:01:14 +01:00
}
public String w() {
return this.motd;
2011-11-20 09:01:14 +01:00
}
public String getVersion() {
2012-12-20 05:03:52 +01:00
return "1.4.6";
2011-11-20 09:01:14 +01:00
}
public int y() {
2012-07-29 09:33:13 +02:00
return this.t.getPlayerCount();
2011-11-20 09:01:14 +01:00
}
public int z() {
2012-07-29 09:33:13 +02:00
return this.t.getMaxPlayers();
2011-11-20 09:01:14 +01:00
}
public String[] getPlayers() {
2012-07-29 09:33:13 +02:00
return this.t.d();
2011-11-20 09:01:14 +01:00
}
public String getPlugins() {
// CraftBukkit start - whole method
StringBuilder result = new StringBuilder();
org.bukkit.plugin.Plugin[] plugins = server.getPluginManager().getPlugins();
result.append(server.getName());
result.append(" on Bukkit ");
result.append(server.getBukkitVersion());
if (plugins.length > 0 && this.server.getQueryPlugins()) {
result.append(": ");
for (int i = 0; i < plugins.length; i++) {
if (i > 0) {
result.append("; ");
}
result.append(plugins[i].getDescription().getName());
result.append(" ");
result.append(plugins[i].getDescription().getVersion().replaceAll(";", ","));
}
}
return result.toString();
// CraftBukkit end
2011-11-20 09:01:14 +01:00
}
// CraftBukkit start
public String h(final String s) { // CraftBukkit - final parameter
Waitable<String> waitable = new Waitable<String>() {
@Override
protected String evaluate() {
RemoteControlCommandListener.instance.c();
// Event changes start
RemoteServerCommandEvent event = new RemoteServerCommandEvent(MinecraftServer.this.remoteConsole, s);
MinecraftServer.this.server.getPluginManager().callEvent(event);
// Event changes end
ServerCommand servercommand = new ServerCommand(event.getCommand(), RemoteControlCommandListener.instance);
// this.q.a(RemoteControlCommandListener.instance, s);
MinecraftServer.this.server.dispatchServerCommand(MinecraftServer.this.remoteConsole, servercommand); // CraftBukkit
return RemoteControlCommandListener.instance.d();
}};
processQueue.add(waitable);
try {
return waitable.get();
} catch (ExecutionException e) {
throw new RuntimeException("Exception processing rcon command " + s, e.getCause());
} catch (InterruptedException e) {
Thread.currentThread().interrupt(); // Maintain interrupted state
throw new RuntimeException("Interrupted processing rcon command " + s, e);
}
// CraftBukkit end
2011-11-20 09:01:14 +01:00
}
public boolean isDebugging() {
2012-07-29 09:33:13 +02:00
return this.getPropertyManager().getBoolean("debug", false); // CraftBukkit - don't hardcode
2011-11-20 09:01:14 +01:00
}
public void i(String s) {
2011-11-20 09:01:14 +01:00
log.log(Level.SEVERE, s);
}
public void j(String s) {
2011-11-20 09:01:14 +01:00
if (this.isDebugging()) {
log.log(Level.INFO, s);
}
}
2012-07-29 09:33:13 +02:00
public String getServerModName() {
return "craftbukkit"; // CraftBukkit - cb > vanilla!
}
public CrashReport b(CrashReport crashreport) {
2012-11-06 13:05:28 +01:00
crashreport.g().a("Profiler Position", (Callable) (new CrashReportProfilerPosition(this)));
if (this.worlds != null && this.worlds.size() > 0 && this.worlds.get(0) != null) {
crashreport.g().a("Vec3 Pool Size", (Callable) (new CrashReportVec3DPoolSize(this)));
2012-07-29 09:33:13 +02:00
}
2012-11-06 13:05:28 +01:00
if (this.t != null) {
crashreport.g().a("Player Count", (Callable) (new CrashReportPlayerCount(this)));
2012-07-29 09:33:13 +02:00
}
return crashreport;
}
public List a(ICommandListener icommandlistener, String s) {
// CraftBukkit start - Allow tab-completion of Bukkit commands
/*
2012-07-29 09:33:13 +02:00
ArrayList arraylist = new ArrayList();
if (s.startsWith("/")) {
s = s.substring(1);
boolean flag = !s.contains(" ");
List list = this.q.b(icommandlistener, s);
if (list != null) {
Iterator iterator = list.iterator();
while (iterator.hasNext()) {
String s1 = (String) iterator.next();
if (flag) {
arraylist.add("/" + s1);
} else {
arraylist.add(s1);
}
}
}
return arraylist;
} else {
String[] astring = s.split(" ", -1);
String s2 = astring[astring.length - 1];
String[] astring1 = this.t.d();
int i = astring1.length;
for (int j = 0; j < i; ++j) {
String s3 = astring1[j];
if (CommandAbstract.a(s2, s3)) {
arraylist.add(s3);
}
}
return arraylist;
}
*/
return this.server.tabComplete(icommandlistener, s);
// CraftBukkit end
2011-11-20 09:01:14 +01:00
}
2012-07-29 09:33:13 +02:00
public static MinecraftServer getServer() {
return l;
2011-11-20 09:01:14 +01:00
}
2012-07-29 09:33:13 +02:00
public String getName() {
return "Server";
}
public void sendMessage(String s) {
log.info(StripColor.a(s));
}
public boolean a(int i, String s) {
2012-07-29 09:33:13 +02:00
return true;
}
public String a(String s, Object... aobject) {
return LocaleLanguage.a().a(s, aobject);
}
public ICommandHandler getCommandHandler() {
return this.q;
}
public KeyPair F() {
2012-07-29 09:33:13 +02:00
return this.I;
}
public int G() {
2012-07-29 09:33:13 +02:00
return this.s;
}
public void setPort(int i) {
this.s = i;
}
public String H() {
2012-07-29 09:33:13 +02:00
return this.J;
}
public void k(String s) {
2012-07-29 09:33:13 +02:00
this.J = s;
}
public boolean I() {
2012-07-29 09:33:13 +02:00
return this.J != null;
}
public String J() {
2012-07-29 09:33:13 +02:00
return this.K;
}
public void l(String s) {
2012-07-29 09:33:13 +02:00
this.K = s;
}
public void a(KeyPair keypair) {
this.I = keypair;
}
public void c(int i) {
// CraftBukkit start
for (int j = 0; j < this.worlds.size(); ++j) {
WorldServer worldserver = this.worlds.get(j);
// CraftBukkit end
if (worldserver != null) {
if (worldserver.getWorldData().isHardcore()) {
worldserver.difficulty = 3;
worldserver.setSpawnFlags(true, true);
} else if (this.I()) {
2012-07-29 09:33:13 +02:00
worldserver.difficulty = i;
worldserver.setSpawnFlags(worldserver.difficulty > 0, true);
} else {
worldserver.difficulty = i;
worldserver.setSpawnFlags(this.getSpawnMonsters(), this.spawnAnimals);
}
}
}
}
protected boolean getSpawnMonsters() {
return true;
}
public boolean M() {
2012-07-29 09:33:13 +02:00
return this.demoMode;
}
public void b(boolean flag) {
this.demoMode = flag;
}
public void c(boolean flag) {
this.N = flag;
}
public Convertable getConvertable() {
return this.convertable;
}
public void P() {
2012-07-29 09:33:13 +02:00
this.O = true;
this.getConvertable().d();
// CraftBukkit start - This needs review, what does it do? (it's new)
for (int i = 0; i < this.worlds.size(); ++i) {
WorldServer worldserver = this.worlds.get(i);
// CraftBukkit end
if (worldserver != null) {
worldserver.saveLevel();
}
}
this.getConvertable().e(this.worlds.get(0).getDataManager().g()); // CraftBukkit
2012-07-29 09:33:13 +02:00
this.safeShutdown();
}
public String getTexturePack() {
return this.P;
}
public void setTexturePack(String s) {
this.P = s;
}
public void a(MojangStatisticsGenerator mojangstatisticsgenerator) {
mojangstatisticsgenerator.a("whitelist_enabled", Boolean.valueOf(false));
mojangstatisticsgenerator.a("whitelist_count", Integer.valueOf(0));
mojangstatisticsgenerator.a("players_current", Integer.valueOf(this.y()));
mojangstatisticsgenerator.a("players_max", Integer.valueOf(this.z()));
2012-07-29 09:33:13 +02:00
mojangstatisticsgenerator.a("players_seen", Integer.valueOf(this.t.getSeenPlayers().length));
mojangstatisticsgenerator.a("uses_auth", Boolean.valueOf(this.onlineMode));
mojangstatisticsgenerator.a("gui_state", this.ag() ? "enabled" : "disabled");
2012-07-29 09:33:13 +02:00
mojangstatisticsgenerator.a("avg_tick_ms", Integer.valueOf((int) (MathHelper.a(this.j) * 1.0E-6D)));
mojangstatisticsgenerator.a("avg_sent_packet_count", Integer.valueOf((int) MathHelper.a(this.f)));
mojangstatisticsgenerator.a("avg_sent_packet_size", Integer.valueOf((int) MathHelper.a(this.g)));
mojangstatisticsgenerator.a("avg_rec_packet_count", Integer.valueOf((int) MathHelper.a(this.h)));
mojangstatisticsgenerator.a("avg_rec_packet_size", Integer.valueOf((int) MathHelper.a(this.i)));
int i = 0;
// CraftBukkit start
for (int j = 0; j < this.worlds.size(); ++j) {
// if (this.worldServer[j] != null) {
WorldServer worldserver = this.worlds.get(j);
// CraftBukkit end
WorldData worlddata = worldserver.getWorldData();
mojangstatisticsgenerator.a("world[" + i + "][dimension]", Integer.valueOf(worldserver.worldProvider.dimension));
mojangstatisticsgenerator.a("world[" + i + "][mode]", worlddata.getGameType());
mojangstatisticsgenerator.a("world[" + i + "][difficulty]", Integer.valueOf(worldserver.difficulty));
mojangstatisticsgenerator.a("world[" + i + "][hardcore]", Boolean.valueOf(worlddata.isHardcore()));
mojangstatisticsgenerator.a("world[" + i + "][generator_name]", worlddata.getType().name());
mojangstatisticsgenerator.a("world[" + i + "][generator_version]", Integer.valueOf(worlddata.getType().getVersion()));
mojangstatisticsgenerator.a("world[" + i + "][height]", Integer.valueOf(this.D));
2012-11-06 13:05:28 +01:00
mojangstatisticsgenerator.a("world[" + i + "][chunks_loaded]", Integer.valueOf(worldserver.I().getLoadedChunks()));
2012-07-29 09:33:13 +02:00
++i;
// } // CraftBukkit
}
mojangstatisticsgenerator.a("worlds", Integer.valueOf(i));
}
public void b(MojangStatisticsGenerator mojangstatisticsgenerator) {
mojangstatisticsgenerator.a("singleplayer", Boolean.valueOf(this.I()));
2012-07-29 09:33:13 +02:00
mojangstatisticsgenerator.a("server_brand", this.getServerModName());
mojangstatisticsgenerator.a("gui_supported", GraphicsEnvironment.isHeadless() ? "headless" : "supported");
mojangstatisticsgenerator.a("dedicated", Boolean.valueOf(this.T()));
2012-07-29 09:33:13 +02:00
}
public boolean getSnooperEnabled() {
return true;
}
public int S() {
2012-07-29 09:33:13 +02:00
return 16;
}
public abstract boolean T();
2012-07-29 09:33:13 +02:00
public boolean getOnlineMode() {
2012-12-20 05:03:52 +01:00
return this.server.getOnlineMode(); // CraftBukkit
2012-07-29 09:33:13 +02:00
}
public void setOnlineMode(boolean flag) {
this.onlineMode = flag;
}
public boolean getSpawnAnimals() {
return this.spawnAnimals;
}
public void setSpawnAnimals(boolean flag) {
this.spawnAnimals = flag;
}
public boolean getSpawnNPCs() {
return this.spawnNPCs;
}
public void setSpawnNPCs(boolean flag) {
this.spawnNPCs = flag;
}
public boolean getPvP() {
return this.pvpMode;
}
public void setPvP(boolean flag) {
this.pvpMode = flag;
}
public boolean getAllowFlight() {
return this.allowFlight;
}
public void setAllowFlight(boolean flag) {
this.allowFlight = flag;
}
public abstract boolean getEnableCommandBlock();
2012-07-29 09:33:13 +02:00
public String getMotd() {
return this.motd;
}
public void setMotd(String s) {
this.motd = s;
}
public int getMaxBuildHeight() {
return this.D;
}
public void d(int i) {
this.D = i;
}
public boolean isStopped() {
return this.isStopped;
}
2012-12-20 05:03:52 +01:00
public PlayerList getPlayerList() {
2012-07-29 09:33:13 +02:00
return this.t;
}
2012-12-20 05:03:52 +01:00
public void a(PlayerList playerlist) {
this.t = playerlist;
2012-07-29 09:33:13 +02:00
}
public void a(EnumGamemode enumgamemode) {
// CraftBukkit start
for (int i = 0; i < this.worlds.size(); ++i) {
getServer().worlds.get(i).getWorldData().setGameType(enumgamemode);
// CraftBukkit end
}
}
public abstract ServerConnection ae();
2012-07-29 09:33:13 +02:00
public boolean ag() {
2012-07-29 09:33:13 +02:00
return false;
}
public abstract String a(EnumGamemode enumgamemode, boolean flag);
public int ah() {
2012-07-29 09:33:13 +02:00
return this.ticks;
}
public void ai() {
2012-07-29 09:33:13 +02:00
this.T = true;
2012-03-30 23:33:51 +02:00
}
2011-11-20 09:01:14 +01:00
public ChunkCoordinates b() {
return new ChunkCoordinates(0, 0, 0);
}
public int getSpawnProtection() {
return 16;
}
2012-12-20 05:03:52 +01:00
public static PlayerList a(MinecraftServer minecraftserver) {
2012-07-29 09:33:13 +02:00
return minecraftserver.t;
2010-12-28 20:52:24 +01:00
}
}