public void processLoginStart(C00PacketLoginStart packetIn) { Validate.validState(this.currentLoginState == NetHandlerLoginServer.LoginState.HELLO, "Unexpected hello packet", new Object[0]); this.loginGameProfile = packetIn.getProfile(); if (this.server.isServerInOnlineMode() && !this.networkManager.isLocalChannel()) { this.currentLoginState = NetHandlerLoginServer.LoginState.KEY; this.networkManager.sendPacket(new S01PacketEncryptionRequest(this.serverId, this.server.getKeyPair().getPublic(), this.verifyToken)); } else { this.currentLoginState = NetHandlerLoginServer.LoginState.READY_TO_ACCEPT; } }
public void processLoginStart(C00PacketLoginStart p_147316_1_) { Validate.validState(this.field_147328_g == NetHandlerLoginServer.LoginState.HELLO, "Unexpected hello packet", new Object[0]); this.field_147337_i = p_147316_1_.func_149304_c(); if (this.field_147327_f.isServerInOnlineMode() && !this.field_147333_a.isLocalChannel()) { this.field_147328_g = NetHandlerLoginServer.LoginState.KEY; this.field_147333_a.scheduleOutboundPacket(new S01PacketEncryptionRequest(this.field_147334_j, this.field_147327_f.getKeyPair().getPublic(), this.field_147330_e), new GenericFutureListener[0]); } else { this.field_147328_g = NetHandlerLoginServer.LoginState.READY_TO_ACCEPT; } }
public void processLoginStart(C00PacketLoginStart p_147316_1_) { Validate.validState(this.field_147328_g == LoginState.HELLO, "Unexpected hello packet", new Object[0]); this.field_147337_i = p_147316_1_.func_149304_c(); if (this.field_147327_f.isServerInOnlineMode() && !this.field_147333_a.isLocalChannel()) { this.field_147328_g = LoginState.KEY; this.field_147333_a.scheduleOutboundPacket(new S01PacketEncryptionRequest(this.field_147334_j, this.field_147327_f.getKeyPair().getPublic(), this.field_147330_e), new GenericFutureListener[0]); } else { (new ThreadPlayerLookupUUID(this, "User Authenticator #" + field_147331_b.incrementAndGet())).start(); // Spigot } }
public void connect(final String p_connect_1_, final int p_connect_2_) { Realms.setConnectedToRealms(true); (new Thread("Realms-connect-task") { public void run() { InetAddress inetaddress = null; try { inetaddress = InetAddress.getByName(p_connect_1_); if (RealmsConnect.this.aborted) { return; } RealmsConnect.this.connection = NetworkManager.func_181124_a(inetaddress, p_connect_2_, Minecraft.getMinecraft().gameSettings.func_181148_f()); if (RealmsConnect.this.aborted) { return; } RealmsConnect.this.connection.setNetHandler(new NetHandlerLoginClient(RealmsConnect.this.connection, Minecraft.getMinecraft(), RealmsConnect.this.onlineScreen.getProxy())); if (RealmsConnect.this.aborted) { return; } RealmsConnect.this.connection.sendPacket(new C00Handshake(47, p_connect_1_, p_connect_2_, EnumConnectionState.LOGIN)); if (RealmsConnect.this.aborted) { return; } RealmsConnect.this.connection.sendPacket(new C00PacketLoginStart(Minecraft.getMinecraft().getSession().getProfile())); } catch (UnknownHostException unknownhostexception) { Realms.clearResourcePack(); if (RealmsConnect.this.aborted) { return; } RealmsConnect.LOGGER.error((String)"Couldn\'t connect to world", (Throwable)unknownhostexception); Minecraft.getMinecraft().getResourcePackRepository().func_148529_f(); Realms.setScreen(new DisconnectedRealmsScreen(RealmsConnect.this.onlineScreen, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {"Unknown host \'" + p_connect_1_ + "\'"}))); } catch (Exception exception) { Realms.clearResourcePack(); if (RealmsConnect.this.aborted) { return; } RealmsConnect.LOGGER.error((String)"Couldn\'t connect to world", (Throwable)exception); String s = exception.toString(); if (inetaddress != null) { String s1 = inetaddress.toString() + ":" + p_connect_2_; s = s.replaceAll(s1, ""); } Realms.setScreen(new DisconnectedRealmsScreen(RealmsConnect.this.onlineScreen, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {s}))); } } }).start(); }
private void connect(final String ip, final int port) { logger.info("Connecting to " + ip + ", " + port); (new Thread("Server Connector #" + CONNECTION_ID.incrementAndGet()) { public void run() { InetAddress inetaddress = null; try { if (GuiConnecting.this.cancel) { return; } inetaddress = InetAddress.getByName(ip); GuiConnecting.this.networkManager = NetworkManager.func_181124_a(inetaddress, port, GuiConnecting.this.mc.gameSettings.func_181148_f()); GuiConnecting.this.networkManager.setNetHandler(new NetHandlerLoginClient(GuiConnecting.this.networkManager, GuiConnecting.this.mc, GuiConnecting.this.previousGuiScreen)); GuiConnecting.this.networkManager.sendPacket(new C00Handshake(47, ip, port, EnumConnectionState.LOGIN)); GuiConnecting.this.networkManager.sendPacket(new C00PacketLoginStart(GuiConnecting.this.mc.getSession().getProfile())); } catch (UnknownHostException unknownhostexception) { if (GuiConnecting.this.cancel) { return; } GuiConnecting.logger.error((String)"Couldn\'t connect to server", (Throwable)unknownhostexception); GuiConnecting.this.mc.displayGuiScreen(new GuiDisconnected(GuiConnecting.this.previousGuiScreen, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {"Unknown host"}))); } catch (Exception exception) { if (GuiConnecting.this.cancel) { return; } GuiConnecting.logger.error((String)"Couldn\'t connect to server", (Throwable)exception); String s = exception.toString(); if (inetaddress != null) { String s1 = inetaddress.toString() + ":" + port; s = s.replaceAll(s1, ""); } GuiConnecting.this.mc.displayGuiScreen(new GuiDisconnected(GuiConnecting.this.previousGuiScreen, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {s}))); } } }).start(); }
private void func_146367_a(final String p_146367_1_, final int p_146367_2_) { logger.info("Connecting to " + p_146367_1_ + ", " + p_146367_2_); (new Thread("Server Connector #" + field_146372_a.incrementAndGet()) { private static final String __OBFID = "CL_00000686"; public void run() { try { if (GuiConnecting.this.field_146373_h) { return; } GuiConnecting.this.field_146371_g = NetworkManager.provideLanClient(InetAddress.getByName(p_146367_1_), p_146367_2_); GuiConnecting.this.field_146371_g.setNetHandler(new NetHandlerLoginClient(GuiConnecting.this.field_146371_g, GuiConnecting.this.mc, GuiConnecting.this.field_146374_i)); GuiConnecting.this.field_146371_g.scheduleOutboundPacket(new C00Handshake(Resilience.getInstance().getValues().version, p_146367_1_, p_146367_2_, EnumConnectionState.LOGIN), new GenericFutureListener[0]); GuiConnecting.this.field_146371_g.scheduleOutboundPacket(new C00PacketLoginStart(GuiConnecting.this.mc.getSession().func_148256_e()), new GenericFutureListener[0]); } catch (UnknownHostException var2) { if (GuiConnecting.this.field_146373_h) { return; } GuiConnecting.logger.error("Couldn\'t connect to server", var2); GuiConnecting.this.mc.displayGuiScreen(new GuiDisconnected(GuiConnecting.this.field_146374_i, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {"Unknown host \'" + p_146367_1_ + "\'"}))); } catch (Exception var3) { if (GuiConnecting.this.field_146373_h) { return; } GuiConnecting.logger.error("Couldn\'t connect to server", var3); GuiConnecting.this.mc.displayGuiScreen(new GuiDisconnected(GuiConnecting.this.field_146374_i, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {var3.toString()}))); } } }).start(); }
private void func_148432_a(final String p_148432_1_, final int p_148432_2_) { (new Thread("MCO Connector #" + field_148439_a.incrementAndGet()) { private static final String __OBFID = "CL_00000791"; public void run() { try { if (TaskOnlineConnect.this.func_148418_c()) { return; } TaskOnlineConnect.this.field_148436_d = NetworkManager.provideLanClient(InetAddress.getByName(p_148432_1_), p_148432_2_); if (TaskOnlineConnect.this.func_148418_c()) { return; } TaskOnlineConnect.this.field_148436_d.setNetHandler(new NetHandlerLoginClient(TaskOnlineConnect.this.field_148436_d, TaskOnlineConnect.this.func_148413_b(), TaskOnlineConnect.this.field_148435_f)); if (TaskOnlineConnect.this.func_148418_c()) { return; } TaskOnlineConnect.this.field_148436_d.scheduleOutboundPacket(new C00Handshake(4, p_148432_1_, p_148432_2_, EnumConnectionState.LOGIN), new GenericFutureListener[0]); if (TaskOnlineConnect.this.func_148418_c()) { return; } TaskOnlineConnect.this.field_148436_d.scheduleOutboundPacket(new C00PacketLoginStart(TaskOnlineConnect.this.func_148413_b().getSession().func_148256_e()), new GenericFutureListener[0]); TaskOnlineConnect.this.func_148417_b(I18n.format("mco.connect.authorizing", new Object[0])); } catch (UnknownHostException var2) { if (TaskOnlineConnect.this.func_148418_c()) { return; } TaskOnlineConnect.logger.error("Couldn\'t connect to world", var2); TaskOnlineConnect.this.func_148413_b().displayGuiScreen(new GuiScreenDisconnectedOnline(TaskOnlineConnect.this.field_148435_f, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {"Unknown host \'" + p_148432_1_ + "\'"}))); } catch (Exception var3) { if (TaskOnlineConnect.this.func_148418_c()) { return; } TaskOnlineConnect.logger.error("Couldn\'t connect to world", var3); TaskOnlineConnect.this.func_148413_b().displayGuiScreen(new GuiScreenDisconnectedOnline(TaskOnlineConnect.this.field_148435_f, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {var3.toString()}))); } } }).start(); }
/** * Arguments: World foldername, World ingame name, WorldSettings */ public void launchIntegratedServer(String par1Str, String par2Str, WorldSettings par3WorldSettings) { this.loadWorld((WorldClient)null); System.gc(); ISaveHandler var4 = this.saveLoader.getSaveLoader(par1Str, false); WorldInfo var5 = var4.loadWorldInfo(); if (var5 == null && par3WorldSettings != null) { var5 = new WorldInfo(par3WorldSettings, par1Str); var4.saveWorldInfo(var5); } if (par3WorldSettings == null) { par3WorldSettings = new WorldSettings(var5); } try { this.theIntegratedServer = new IntegratedServer(this, par1Str, par2Str, par3WorldSettings); this.theIntegratedServer.startServerThread(); this.integratedServerIsRunning = true; } catch (Throwable var10) { CrashReport var7 = CrashReport.makeCrashReport(var10, "Starting integrated server"); CrashReportCategory var8 = var7.makeCategory("Starting integrated server"); var8.addCrashSection("Level ID", par1Str); var8.addCrashSection("Level Name", par2Str); throw new ReportedException(var7); } this.loadingScreen.displayProgressMessage(I18n.format("menu.loadingLevel", new Object[0])); while (!this.theIntegratedServer.serverIsInRunLoop()) { String var6 = this.theIntegratedServer.getUserMessage(); if (var6 != null) { this.loadingScreen.resetProgresAndWorkingMessage(I18n.format(var6, new Object[0])); } else { this.loadingScreen.resetProgresAndWorkingMessage(""); } try { Thread.sleep(200L); } catch (InterruptedException var9) { ; } } this.displayGuiScreen((GuiScreen)null); SocketAddress var11 = this.theIntegratedServer.func_147137_ag().addLocalEndpoint(); NetworkManager var12 = NetworkManager.provideLocalClient(var11); var12.setNetHandler(new NetHandlerLoginClient(var12, this, (GuiScreen)null)); var12.scheduleOutboundPacket(new C00Handshake(4, var11.toString(), 0, EnumConnectionState.LOGIN), new GenericFutureListener[0]); var12.scheduleOutboundPacket(new C00PacketLoginStart(this.getSession().func_148256_e()), new GenericFutureListener[0]); this.myNetworkManager = var12; }
public void connect(final String p_connect_1_, final int p_connect_2_) { (new Thread("Realms-connect-task") { private static final String __OBFID = "CL_00001808"; public void run() { InetAddress inetaddress = null; try { cpw.mods.fml.client.FMLClientHandler.instance().connectToRealmsServer(p_connect_1_, p_connect_2_); inetaddress = InetAddress.getByName(p_connect_1_); if (RealmsConnect.this.aborted) { return; } RealmsConnect.this.connection = NetworkManager.provideLanClient(inetaddress, p_connect_2_); if (RealmsConnect.this.aborted) { return; } RealmsConnect.this.connection.setNetHandler(new NetHandlerLoginClient(RealmsConnect.this.connection, Minecraft.getMinecraft(), RealmsConnect.this.onlineScreen.getProxy())); if (RealmsConnect.this.aborted) { return; } RealmsConnect.this.connection.scheduleOutboundPacket(new C00Handshake(5, p_connect_1_, p_connect_2_, EnumConnectionState.LOGIN), new GenericFutureListener[0]); if (RealmsConnect.this.aborted) { return; } RealmsConnect.this.connection.scheduleOutboundPacket(new C00PacketLoginStart(Minecraft.getMinecraft().getSession().func_148256_e()), new GenericFutureListener[0]); } catch (UnknownHostException unknownhostexception) { if (RealmsConnect.this.aborted) { return; } RealmsConnect.LOGGER.error("Couldn\'t connect to world", unknownhostexception); Realms.setScreen(new DisconnectedOnlineScreen(RealmsConnect.this.onlineScreen, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {"Unknown host \'" + p_connect_1_ + "\'"}))); } catch (Exception exception) { if (RealmsConnect.this.aborted) { return; } RealmsConnect.LOGGER.error("Couldn\'t connect to world", exception); String s = exception.toString(); if (inetaddress != null) { String s1 = inetaddress.toString() + ":" + p_connect_2_; s = s.replaceAll(s1, ""); } Realms.setScreen(new DisconnectedOnlineScreen(RealmsConnect.this.onlineScreen, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {s}))); } } }).start(); }
private void func_146367_a(final String p_146367_1_, final int p_146367_2_) { logger.info("Connecting to " + p_146367_1_ + ", " + p_146367_2_); (new Thread("Server Connector #" + field_146372_a.incrementAndGet()) { private static final String __OBFID = "CL_00000686"; public void run() { InetAddress inetaddress = null; try { if (GuiConnecting.this.field_146373_h) { return; } inetaddress = InetAddress.getByName(p_146367_1_); GuiConnecting.this.field_146371_g = NetworkManager.provideLanClient(inetaddress, p_146367_2_); GuiConnecting.this.field_146371_g.setNetHandler(new NetHandlerLoginClient(GuiConnecting.this.field_146371_g, GuiConnecting.this.mc, GuiConnecting.this.field_146374_i)); GuiConnecting.this.field_146371_g.scheduleOutboundPacket(new C00Handshake(5, p_146367_1_, p_146367_2_, EnumConnectionState.LOGIN), new GenericFutureListener[0]); GuiConnecting.this.field_146371_g.scheduleOutboundPacket(new C00PacketLoginStart(GuiConnecting.this.mc.getSession().func_148256_e()), new GenericFutureListener[0]); } catch (UnknownHostException unknownhostexception) { if (GuiConnecting.this.field_146373_h) { return; } GuiConnecting.logger.error("Couldn\'t connect to server", unknownhostexception); GuiConnecting.this.mc.displayGuiScreen(new GuiDisconnected(GuiConnecting.this.field_146374_i, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {"Unknown host"}))); } catch (Exception exception) { if (GuiConnecting.this.field_146373_h) { return; } GuiConnecting.logger.error("Couldn\'t connect to server", exception); String s = exception.toString(); if (inetaddress != null) { String s1 = inetaddress.toString() + ":" + p_146367_2_; s = s.replaceAll(s1, ""); } GuiConnecting.this.mc.displayGuiScreen(new GuiDisconnected(GuiConnecting.this.field_146374_i, "connect.failed", new ChatComponentTranslation("disconnect.genericReason", new Object[] {s}))); } } }).start(); }
public void launchIntegratedServer(String p_71371_1_, String p_71371_2_, WorldSettings p_71371_3_) { FMLClientHandler.instance().startIntegratedServer(p_71371_1_, p_71371_2_, p_71371_3_); this.loadWorld((WorldClient)null); System.gc(); ISaveHandler isavehandler = this.saveLoader.getSaveLoader(p_71371_1_, false); WorldInfo worldinfo = isavehandler.loadWorldInfo(); if (worldinfo == null && p_71371_3_ != null) { worldinfo = new WorldInfo(p_71371_3_, p_71371_1_); isavehandler.saveWorldInfo(worldinfo); } if (p_71371_3_ == null) { p_71371_3_ = new WorldSettings(worldinfo); } try { this.theIntegratedServer = new IntegratedServer(this, p_71371_1_, p_71371_2_, p_71371_3_); this.theIntegratedServer.startServerThread(); this.integratedServerIsRunning = true; } catch (Throwable throwable) { CrashReport crashreport = CrashReport.makeCrashReport(throwable, "Starting integrated server"); CrashReportCategory crashreportcategory = crashreport.makeCategory("Starting integrated server"); crashreportcategory.addCrashSection("Level ID", p_71371_1_); crashreportcategory.addCrashSection("Level Name", p_71371_2_); throw new ReportedException(crashreport); } this.loadingScreen.displayProgressMessage(I18n.format("menu.loadingLevel", new Object[0])); while (!this.theIntegratedServer.serverIsInRunLoop()) { if (!StartupQuery.check()) { loadWorld(null); displayGuiScreen(null); return; } String s2 = this.theIntegratedServer.getUserMessage(); if (s2 != null) { this.loadingScreen.resetProgresAndWorkingMessage(I18n.format(s2, new Object[0])); } else { this.loadingScreen.resetProgresAndWorkingMessage(""); } try { Thread.sleep(200L); } catch (InterruptedException interruptedexception) { ; } } this.displayGuiScreen((GuiScreen)null); SocketAddress socketaddress = this.theIntegratedServer.func_147137_ag().addLocalEndpoint(); NetworkManager networkmanager = NetworkManager.provideLocalClient(socketaddress); networkmanager.setNetHandler(new NetHandlerLoginClient(networkmanager, this, (GuiScreen)null)); networkmanager.scheduleOutboundPacket(new C00Handshake(5, socketaddress.toString(), 0, EnumConnectionState.LOGIN), new GenericFutureListener[0]); networkmanager.scheduleOutboundPacket(new C00PacketLoginStart(this.getSession().func_148256_e()), new GenericFutureListener[0]); this.myNetworkManager = networkmanager; }
void processLoginStart(C00PacketLoginStart packetIn);
void processLoginStart(C00PacketLoginStart var1);
void processLoginStart(C00PacketLoginStart p_147316_1_);