R3944Realms/ModernFix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Attempt to track server tick times more accurately

Browse Source
This commit is contained in:
embeddedt 2024-05-29 18:53:40 -04:00
parent 1728de0f16
commit 6bfe079175
No known key found for this signature in database
GPG Key ID: A69433EC199B5613
3 changed files with 43 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
common/src/main/java/org/embeddedt/modernfix/common/mixin/core/MinecraftServerMixin.java Normal file
View File

@ -0,0 +1,24 @@
package org.embeddedt.modernfix.common.mixin.core;
import net.minecraft.Util;
import net.minecraft.server.MinecraftServer;
import org.embeddedt.modernfix.duck.ITimeTrackingServer;
import org.spongepowered.asm.mixin.Mixin;
import org.spongepowered.asm.mixin.injection.At;
import org.spongepowered.asm.mixin.injection.Inject;
import org.spongepowered.asm.mixin.injection.callback.CallbackInfo;
@Mixin(MinecraftServer.class)
public class MinecraftServerMixin implements ITimeTrackingServer {
private long mfix$lastTickStartTime = -1L;
@Override
public long mfix$getLastTickStartTime() {
return mfix$lastTickStartTime;
}
@Inject(method = "runServer", at = @At(value = "INVOKE", target = "Lnet/minecraft/server/MinecraftServer;tickServer(Ljava/util/function/BooleanSupplier;)V"))
private void trackTickTime(CallbackInfo ci) {
mfix$lastTickStartTime = Util.getMillis();
}
}

5
common/src/main/java/org/embeddedt/modernfix/duck/ITimeTrackingServer.java Normal file
View File

@ -0,0 +1,5 @@
package org.embeddedt.modernfix.duck;
public interface ITimeTrackingServer {
long mfix$getLastTickStartTime();
}

22
common/src/main/java/org/embeddedt/modernfix/world/IntegratedWatchdog.java
View File

@ -5,8 +5,10 @@ import net.minecraft.Util;
import net.minecraft.server.MinecraftServer; import net.minecraft.server.MinecraftServer;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.embeddedt.modernfix.duck.ITimeTrackingServer;
import java.lang.ref.WeakReference; import java.lang.ref.WeakReference;
import java.util.OptionalLong;
public class IntegratedWatchdog extends Thread { public class IntegratedWatchdog extends Thread {
private static final Logger LOGGER = LogManager.getLogger(); private static final Logger LOGGER = LogManager.getLogger();
@ -22,23 +24,27 @@ public class IntegratedWatchdog extends Thread {
this.setName("ModernFix integrated server watchdog"); this.setName("ModernFix integrated server watchdog");
} }
private OptionalLong getLastTickStart() {
MinecraftServer server = this.server.get();
if(server == null || !server.isRunning())
return OptionalLong.empty();
return OptionalLong.of(((ITimeTrackingServer)server).mfix$getLastTickStartTime());
}
public void run() { public void run() {
while(true) { while(true) {
MinecraftServer server = this.server.get(); OptionalLong lastTickStart = getLastTickStart();
if(server == null || !server.isRunning()) if(!lastTickStart.isPresent()) {
return; return;
long nextTick = server.getNextTickTime(); }
long curTime = Util.getMillis(); long curTime = Util.getMillis();
long delta = curTime - nextTick; long delta = curTime - lastTickStart.getAsLong();
if(delta > MAX_TICK_DELTA) { if(delta > MAX_TICK_DELTA) {
LOGGER.error("A single server tick has taken {}, more than {} milliseconds", delta, MAX_TICK_DELTA); LOGGER.error("A single server tick has taken {}, more than {} milliseconds", delta, MAX_TICK_DELTA);
LOGGER.error(ThreadDumper.obtainThreadDump()); LOGGER.error(ThreadDumper.obtainThreadDump());
nextTick = 0;
curTime = 0;
} }
server = null; /* allow GC */
try { try {
Thread.sleep(nextTick + MAX_TICK_DELTA - curTime); Thread.sleep(MAX_TICK_DELTA - delta);
} catch(InterruptedException ignored) { } catch(InterruptedException ignored) {
} }
} }