From 6b843d995ffa4b1d5e50124bb67ea58289598596 Mon Sep 17 00:00:00 2001 From: md_5 Date: Thu, 30 Jun 2016 15:20:04 +1000 Subject: SPIGOT-1284: Run scheduler consistently within a tick --- nms-patches/MinecraftServer.patch | 50 ++++++++++++++++++++++----------------- 1 file changed, 28 insertions(+), 22 deletions(-) (limited to 'nms-patches/MinecraftServer.patch') diff --git a/nms-patches/MinecraftServer.patch b/nms-patches/MinecraftServer.patch index f3443083..91f6803d 100644 --- a/nms-patches/MinecraftServer.patch +++ b/nms-patches/MinecraftServer.patch @@ -413,13 +413,19 @@ this.methodProfiler.a("save"); this.v.savePlayers(); this.saveChunks(true); -@@ -524,20 +694,40 @@ +@@ -513,6 +683,7 @@ + } + + public void D() { ++ this.server.getScheduler().mainThreadHeartbeat(this.ticks); // CraftBukkit + this.methodProfiler.a("jobs"); + Queue queue = this.j; + +@@ -524,20 +695,38 @@ this.methodProfiler.c("levels"); + // CraftBukkit start -+ this.server.getScheduler().mainThreadHeartbeat(this.ticks); -+ + // Run tasks that are waiting on processing + while (!processQueue.isEmpty()) { + processQueue.remove().run(); @@ -457,7 +463,7 @@ this.methodProfiler.a("tick"); -@@ -564,9 +754,9 @@ +@@ -564,9 +753,9 @@ worldserver.getTracker().updatePlayers(); this.methodProfiler.b(); this.methodProfiler.b(); @@ -469,7 +475,7 @@ } this.methodProfiler.c("connection"); -@@ -590,10 +780,11 @@ +@@ -590,10 +779,11 @@ this.o.add(itickable); } @@ -482,7 +488,7 @@ boolean flag = true; String s = null; String s1 = "."; -@@ -638,13 +829,16 @@ +@@ -638,13 +828,16 @@ ++j; } } @@ -500,7 +506,7 @@ if (s != null) { dedicatedserver.i(s); } -@@ -675,6 +869,25 @@ +@@ -675,6 +868,25 @@ dedicatedserver.stop(); } }); @@ -526,7 +532,7 @@ } catch (Exception exception) { MinecraftServer.LOGGER.fatal("Failed to start the minecraft server", exception); } -@@ -682,8 +895,10 @@ +@@ -682,8 +894,10 @@ } public void F() { @@ -537,7 +543,7 @@ } public File d(String s) { -@@ -699,7 +914,14 @@ +@@ -699,7 +913,14 @@ } public WorldServer getWorldServer(int i) { @@ -553,7 +559,7 @@ } public String getVersion() { -@@ -723,7 +945,7 @@ +@@ -723,7 +944,7 @@ } public boolean isDebugging() { @@ -562,7 +568,7 @@ } public void g(String s) { -@@ -738,7 +960,7 @@ +@@ -738,7 +959,7 @@ } public String getServerModName() { @@ -571,7 +577,7 @@ } public CrashReport b(CrashReport crashreport) { -@@ -767,6 +989,7 @@ +@@ -767,6 +988,7 @@ } public List tabCompleteCommand(ICommandListener icommandlistener, String s, @Nullable BlockPosition blockposition, boolean flag) { @@ -579,7 +585,7 @@ ArrayList arraylist = Lists.newArrayList(); boolean flag1 = s.startsWith("/"); -@@ -809,10 +1032,13 @@ +@@ -809,10 +1031,13 @@ return arraylist; } @@ -594,7 +600,7 @@ } public String getName() { -@@ -868,11 +1094,13 @@ +@@ -868,11 +1093,13 @@ } public void a(EnumDifficulty enumdifficulty) { @@ -611,7 +617,7 @@ if (worldserver != null) { if (worldserver.getWorldData().isHardcore()) { -@@ -939,13 +1167,11 @@ +@@ -939,13 +1166,11 @@ int i = 0; if (this.worldServer != null) { @@ -629,7 +635,7 @@ WorldData worlddata = worldserver.getWorldData(); mojangstatisticsgenerator.a("world[" + i + "][dimension]", Integer.valueOf(worldserver.worldProvider.getDimensionManager().getDimensionID())); -@@ -978,7 +1204,7 @@ +@@ -978,7 +1203,7 @@ public abstract boolean aa(); public boolean getOnlineMode() { @@ -638,7 +644,7 @@ } public void setOnlineMode(boolean flag) { -@@ -1050,13 +1276,9 @@ +@@ -1050,13 +1275,9 @@ } public void setGamemode(EnumGamemode enumgamemode) { @@ -655,7 +661,7 @@ } } -@@ -1088,7 +1310,7 @@ +@@ -1088,7 +1309,7 @@ } public World getWorld() { @@ -664,7 +670,7 @@ } public Entity f() { -@@ -1160,8 +1382,10 @@ +@@ -1160,8 +1381,10 @@ WorldServer[] aworldserver = this.worldServer; int i = aworldserver.length; @@ -677,7 +683,7 @@ if (worldserver != null) { Entity entity = worldserver.getEntity(uuid); -@@ -1176,7 +1400,7 @@ +@@ -1176,7 +1399,7 @@ } public boolean getSendCommandFeedback() { @@ -686,7 +692,7 @@ } public void a(CommandObjectiveExecutor.EnumCommandResult commandobjectiveexecutor_enumcommandresult, int i) {} -@@ -1191,7 +1415,7 @@ +@@ -1191,7 +1414,7 @@ public ListenableFuture a(Callable callable) { Validate.notNull(callable); @@ -695,7 +701,7 @@ ListenableFutureTask listenablefuturetask = ListenableFutureTask.create(callable); Queue queue = this.j; -@@ -1236,4 +1460,11 @@ +@@ -1236,4 +1459,11 @@ public int a(@Nullable WorldServer worldserver) { return worldserver != null ? worldserver.getGameRules().c("spawnRadius") : 10; } -- cgit v1.2.3