Minecraft/asys
Archived
0
Fork 0
Code Activity

Bridge: пинг напрямую зависит от тика

Browse Source
This commit is contained in:
DmitriyMX
2017-07-24 22:51:35 +03:00
parent 8eb42d64ad
commit 02e734ff28
3 changed files with 20 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
bridge/build.gradle
View File

@@ -1,5 +1,5 @@
group = 'asys'
version = '0.8.2-SNAPSHOT'
version = '0.8.3-SNAPSHOT'
repositories {
maven { url 'https://hub.spigotmc.org/nexus/content/groups/public/' }

21
bridge/src/main/java/asys/bridge/bukkit/BridgeBukkitImpl.java
View File

@@ -8,14 +8,13 @@ import asys.bridge.client.AbstractBridge;
import asys.bridge.client.IBridge;
import asys.bridge.client.IConfig;
import asys.bridge.client.ILogger;
import io.netty.channel.Channel;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.core.Logger;
import asys.mcsmanager.packets.CS_Ping;
public class BridgeBukkitImpl extends AbstractBridge implements IBridge {
private BridgePlugin plugin;
private LoggerBukkitImpl logger;
private ConfigBukkitImpl configBukkit;
private int scheduleId = -1;
public BridgeBukkitImpl(BridgePlugin plugin) {
this.plugin = plugin;
@@ -45,4 +44,20 @@ public class BridgeBukkitImpl extends AbstractBridge implements IBridge {
command
);
}
@Override
public void startPing() {
scheduleId = plugin.getServer().getScheduler().scheduleSyncRepeatingTask(plugin,() -> {
plugin.getLogger().info("[D] send ping...");
this.client.sendPacket(new CS_Ping(
System.currentTimeMillis(),
20.0D, //FIXME fake tps
getCountOnlinePlayers()));
}, 0, 20L*5);
}
@Override
public void stopPing() {
plugin.getServer().getScheduler().cancelTask(scheduleId);
}
}

2
bridge/src/main/java/asys/bridge/client/AbstractBridge.java
View File

@@ -9,7 +9,7 @@ import asys.mcsmanager.packets.CS_CorrectShutdown;
import asys.mcsmanager.packets.CS_Ping;
public abstract class AbstractBridge implements IBridge {
private Client client;
protected Client client;
private TaskTicker connectTicker, pingTicker;
private int tryConnect = 0;
private boolean needReconnect = true;