Skip to content

Commit

Permalink
monotonic time (match core)
Browse files Browse the repository at this point in the history
  • Loading branch information
mcmonkey4eva committed Apr 21, 2022
1 parent 6a780ef commit 352d6b2
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
Expand Up @@ -2,6 +2,7 @@

import com.denizenscript.denizencore.DenizenCore;
import com.denizenscript.denizencore.scripts.commands.core.AdjustCommand;
import com.denizenscript.denizencore.utilities.CoreUtilities;
import com.denizenscript.depenizen.bukkit.Depenizen;
import com.denizenscript.depenizen.bukkit.bungee.packets.in.*;
import com.denizenscript.depenizen.bukkit.bungee.packets.out.ControlsProxyCommandPacketOut;
Expand Down Expand Up @@ -209,7 +210,7 @@ public void run(ReplaceableTagEvent event) {
if (!connected) {
return;
}
if (System.currentTimeMillis() > lastPacketReceived + 20 * 1000) {
if (CoreUtilities.monotonicMillis() > lastPacketReceived + 20 * 1000) {
// 20 seconds without a packet = connection lost!
handler.fail("Connection time out.");
return;
Expand Down
@@ -1,5 +1,6 @@
package com.denizenscript.depenizen.bukkit.bungee;

import com.denizenscript.denizencore.utilities.CoreUtilities;
import com.denizenscript.depenizen.bukkit.Depenizen;
import com.denizenscript.depenizen.bukkit.bungee.packets.out.ControlsProxyCommandPacketOut;
import com.denizenscript.depenizen.bukkit.bungee.packets.out.ControlsProxyPingPacketOut;
Expand Down Expand Up @@ -86,7 +87,7 @@ public void channelActive(ChannelHandlerContext ctx) {
ctx.writeAndFlush(handshake); // Will release handshake
Bukkit.getScheduler().scheduleSyncDelayedTask(Depenizen.instance, () -> {
Debug.log("Depenizen now connected to Bungee server.");
BungeeBridge.instance.lastPacketReceived = System.currentTimeMillis();
BungeeBridge.instance.lastPacketReceived = CoreUtilities.monotonicMillis();
BungeeBridge.instance.sendPacket(new MyInfoPacketOut(Bukkit.getPort()));
BungeeBridge.instance.sendPacket(new ControlsProxyPingPacketOut(BungeeBridge.instance.controlsProxyPing));
BungeeBridge.instance.sendPacket(new ControlsProxyCommandPacketOut(BungeeBridge.instance.controlsProxyCommand));
Expand Down Expand Up @@ -117,7 +118,7 @@ else if (currentStage == Stage.AWAIT_DATA) {
return;
}
try {
BungeeBridge.instance.lastPacketReceived = System.currentTimeMillis();
BungeeBridge.instance.lastPacketReceived = CoreUtilities.monotonicMillis();
PacketIn packet = BungeeBridge.instance.packets.get(packetId);
packet.process(packetBuffer);
currentStage = Stage.AWAIT_HEADER;
Expand Down

0 comments on commit 352d6b2

Please sign in to comment.