Minecraft/mc-core
Archived
0
Fork 0
Code Activity

оптимизировали keepAlive

Browse Source
This commit is contained in:
DmitriyMX
2019-01-27 19:15:25 +03:00
parent 0a833fb715
commit d4556757b4
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
proto_1.12.2_netty/src/main/java/mc/core/network/proto_1_12_2/netty/KeepAliveThread.java
View File

@@ -6,11 +6,8 @@ import mc.core.player.PlayerManager;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.Random;
@Component @Component
public class KeepAliveThread extends Thread { public class KeepAliveThread extends Thread {
private static final Random RAND = new Random();
private final Object lock = new Object(); private final Object lock = new Object();
@Autowired @Autowired
private PlayerManager playerManager; private PlayerManager playerManager;
@@ -25,6 +22,8 @@ public class KeepAliveThread extends Thread {
@Override @Override
public void run() { public void run() {
final KeepAlivePacket keepAlivePacket = new KeepAlivePacket();
while (!Thread.currentThread().isInterrupted()) { while (!Thread.currentThread().isInterrupted()) {
while(playerManager.getCountPlayers() == 0) { while(playerManager.getCountPlayers() == 0) {
synchronized (lock) { synchronized (lock) {
@@ -36,7 +35,8 @@ public class KeepAliveThread extends Thread {
} }
} }
playerManager.getBroadcastChannel().writeAndFlush(new KeepAlivePacket(RAND.nextLong())); keepAlivePacket.setPayload(System.currentTimeMillis());
playerManager.getBroadcastChannel().writeAndFlush(keepAlivePacket);
try { try {
Thread.sleep(interval); Thread.sleep(interval);

2
proto_1.12.2_netty/src/main/java/mc/core/network/proto_1_12_2/netty/wrappers/WrapperNetChannel.java
View File

@@ -58,7 +58,7 @@ public class WrapperNetChannel implements NetChannel {
@Override @Override
public void writeAndFlush(SCPacket pkt) { public void writeAndFlush(SCPacket pkt) {
channel.writeAndFlush(pkt); channel.writeAndFlush(pkt, channel.voidPromise());
} }
@Override @Override