MiniDay/Velocity
1
0
Fork 0
Code Issues Pull Requests Packages Releases Wiki Activity

Fix bug in VelocityRegisteredServer#ping()

Browse Source
This commit is contained in:
Andrew Steinborn
2023-10-28 19:53:29 -04:00
parent ae63da6836
commit 74033addbe
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
proxy/src/main/java/com/velocitypowered/proxy/server/VelocityRegisteredServer.java
View File

@@ -124,9 +124,10 @@ public class VelocityRegisteredServer implements RegisteredServer, ForwardingAud
}).connect(serverInfo.getAddress()).addListener((ChannelFutureListener) future -> {
if (future.isSuccess()) {
MinecraftConnection conn = future.channel().pipeline().get(MinecraftConnection.class);
conn.setActiveSessionHandler(StateRegistry.HANDSHAKE,
new PingSessionHandler(pingFuture, VelocityRegisteredServer.this, conn,
pingOptions.getProtocolVersion()));
PingSessionHandler handler = new PingSessionHandler(pingFuture,
VelocityRegisteredServer.this, conn, pingOptions.getProtocolVersion());
conn.setActiveSessionHandler(StateRegistry.HANDSHAKE, handler);
conn.addSessionHandler(StateRegistry.LOGIN, handler);
} else {
pingFuture.completeExceptionally(future.cause());
}