BLOCKFANTASY
/
LOOHP-Limbo
Template
mirror of https://github.com/LOOHP/Limbo.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

Fixed stop command

This commit is contained in:
LOOHP 2020-08-04 01:47:43 +08:00
parent c8e826e25d
commit 2a48ead90d
2 changed files with 24 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/com/loohp/limbo/Console.java
View File

@ -37,17 +37,7 @@ public class Console {
String[] input = CustomStringUtils.splitStringToArgs(reader.readLine()); String[] input = CustomStringUtils.splitStringToArgs(reader.readLine());
if (input[0].equalsIgnoreCase("stop")) { if (input[0].equalsIgnoreCase("stop")) {
for (ClientConnection client : Limbo.getInstance().getServerConnection().getClients()) { Limbo.getInstance().stopServer();
client.getSocket().close();
while (client.getSocket().isConnected()) {
try {
TimeUnit.MILLISECONDS.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
System.exit(0);
} else if (input[0].equalsIgnoreCase("say")) { } else if (input[0].equalsIgnoreCase("say")) {
if (input.length > 1) { if (input.length > 1) {
String message = "[Server] " + String.join(" ", Arrays.copyOfRange(input, 1, input.length)); String message = "[Server] " + String.join(" ", Arrays.copyOfRange(input, 1, input.length));

23
src/com/loohp/limbo/Limbo.java
View File

@ -9,6 +9,7 @@ import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.json.simple.JSONObject; import org.json.simple.JSONObject;
import org.json.simple.parser.JSONParser; import org.json.simple.parser.JSONParser;
@ -16,6 +17,7 @@ import org.json.simple.parser.ParseException;
import com.loohp.limbo.File.ServerProperties; import com.loohp.limbo.File.ServerProperties;
import com.loohp.limbo.Location.Location; import com.loohp.limbo.Location.Location;
import com.loohp.limbo.Server.ClientConnection;
import com.loohp.limbo.Server.ServerConnection; import com.loohp.limbo.Server.ServerConnection;
import com.loohp.limbo.Server.Packets.Packet; import com.loohp.limbo.Server.Packets.Packet;
import com.loohp.limbo.Server.Packets.PacketIn; import com.loohp.limbo.Server.Packets.PacketIn;
@ -195,4 +197,25 @@ public class Limbo {
return base; return base;
} }
@SuppressWarnings("deprecation")
public void stopServer() {
Limbo.getInstance().getConsole().sendMessage("Stopping Server...");
for (ClientConnection client : Limbo.getInstance().getServerConnection().getClients()) {
try {
client.getSocket().close();
} catch (IOException e) {
e.printStackTrace();
client.destroy();
}
}
while (!Limbo.getInstance().getServerConnection().getClients().isEmpty()) {
try {
TimeUnit.MILLISECONDS.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.exit(0);
}
} }