Mirrors/Velocity
3
0
Fork 1
Mirror von https://github.com/PaperMC/Velocity.git synchronisiert 2024-12-25 15:50:19 +01:00
Code Issues Pakete Projekte Releases Wiki Aktivität

Schedule the response handler to run in the channel event loop

Quellcode durchsuchen
Dieser Commit ist enthalten in:
Andrew Steinborn 2018-07-27 01:26:15 -04:00
Ursprung 22c7769eae
Commit bf2835da02
1 geänderte Dateien mit 2 neuen und 2 gelöschten Zeilen
Statistiken anzeigen Patch-Datei herunterladen Vergleichs-Datei herunterladen Alle Dateien ausklappen Alle Dateien einklappen

4
src/main/java/com/velocitypowered/proxy/connection/client/LoginSessionHandler.java
Datei anzeigen

@ -60,7 +60,7 @@ public class LoginSessionHandler implements MinecraftSessionHandler {
String playerIp = ((InetSocketAddress) inbound.getChannel().remoteAddress()).getHostString(); String playerIp = ((InetSocketAddress) inbound.getChannel().remoteAddress()).getHostString();
VelocityServer.getServer().getHttpClient() VelocityServer.getServer().getHttpClient()
.get(new URL(String.format(MOJANG_SERVER_AUTH_URL, login.getUsername(), serverId, playerIp))) .get(new URL(String.format(MOJANG_SERVER_AUTH_URL, login.getUsername(), serverId, playerIp)))
.thenAccept(profileResponse -> { .thenAcceptAsync(profileResponse -> {
try { try {
inbound.enableEncryption(decryptedSharedSecret); inbound.enableEncryption(decryptedSharedSecret);
} catch (GeneralSecurityException e) { } catch (GeneralSecurityException e) {
@ -69,7 +69,7 @@ public class LoginSessionHandler implements MinecraftSessionHandler {
GameProfile profile = VelocityServer.GSON.fromJson(profileResponse, GameProfile.class); GameProfile profile = VelocityServer.GSON.fromJson(profileResponse, GameProfile.class);
handleSuccessfulLogin(profile); handleSuccessfulLogin(profile);
}) }, inbound.getChannel().eventLoop())
.exceptionally(exception -> { .exceptionally(exception -> {
System.out.println("Can't enable encryption"); System.out.println("Can't enable encryption");
exception.printStackTrace(); exception.printStackTrace();