eaglercraft/ayuncraft-1.5
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added timeout for NetClientHandler

Browse Source
This commit is contained in:
LAX1DUDE 2022-03-30 17:13:38 -07:00
parent 280137bd97
commit b56976955b
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/net/minecraft/src/NetClientHandler.java
View File

@ -44,6 +44,8 @@ public class NetClientHandler extends NetHandler {
public List playerInfoList = new ArrayList(); public List playerInfoList = new ArrayList();
public int currentServerMaxPlayers = 20; public int currentServerMaxPlayers = 20;
private GuiScreen field_98183_l = null; private GuiScreen field_98183_l = null;
private int updateCounter = 0;
private int lastKeepAlive = 0;
/** RNG. */ /** RNG. */
EaglercraftRandom rand = new EaglercraftRandom(); EaglercraftRandom rand = new EaglercraftRandom();
@ -77,6 +79,14 @@ public class NetClientHandler extends NetHandler {
* function. * function.
*/ */
public void processReadPackets() { public void processReadPackets() {
++this.updateCounter;
if(updateCounter - lastKeepAlive > 500 || !EaglerAdapter.connectionOpen()) {
this.mc.displayGuiScreen(new GuiDisconnected(new GuiMultiplayer(new GuiMainMenu()), "disconnect.disconnected", "disconnect." + (EaglerAdapter.connectionOpen() ? "endOfStream" :" timeout"), null));
this.netManager.closeConnections();
this.disconnected = true;
this.mc.loadWorld((WorldClient) null);
return;
}
if (!this.disconnected && this.netManager != null) { if (!this.disconnected && this.netManager != null) {
this.netManager.processReadPackets(); this.netManager.processReadPackets();
} }
@ -87,7 +97,6 @@ public class NetClientHandler extends NetHandler {
} }
public void handleServerAuthData(Packet253ServerAuthData par1Packet253ServerAuthData) { public void handleServerAuthData(Packet253ServerAuthData par1Packet253ServerAuthData) {
this.addToSendQueue(new Packet252SharedKey()); this.addToSendQueue(new Packet252SharedKey());
} }
@ -1067,6 +1076,7 @@ public class NetClientHandler extends NetHandler {
* Handle a keep alive packet. * Handle a keep alive packet.
*/ */
public void handleKeepAlive(Packet0KeepAlive par1Packet0KeepAlive) { public void handleKeepAlive(Packet0KeepAlive par1Packet0KeepAlive) {
lastKeepAlive = updateCounter;
this.addToSendQueue(new Packet0KeepAlive(par1Packet0KeepAlive.randomId)); this.addToSendQueue(new Packet0KeepAlive(par1Packet0KeepAlive.randomId));
} }