|
@@ -17,79 +17,20 @@ package com.l2jserver.status;
|
|
|
import java.io.BufferedReader;
|
|
|
import java.io.File;
|
|
|
import java.io.FileInputStream;
|
|
|
-import java.io.FileOutputStream;
|
|
|
import java.io.IOException;
|
|
|
import java.io.InputStream;
|
|
|
import java.io.InputStreamReader;
|
|
|
-import java.io.OutputStreamWriter;
|
|
|
import java.io.PrintWriter;
|
|
|
-import java.lang.management.ManagementFactory;
|
|
|
-import java.lang.management.ThreadInfo;
|
|
|
-import java.lang.management.ThreadMXBean;
|
|
|
import java.net.InetAddress;
|
|
|
import java.net.Socket;
|
|
|
-import java.sql.Connection;
|
|
|
-import java.sql.PreparedStatement;
|
|
|
-import java.sql.SQLException;
|
|
|
-import java.text.DecimalFormat;
|
|
|
-import java.text.SimpleDateFormat;
|
|
|
-import java.util.Calendar;
|
|
|
-import java.util.Map;
|
|
|
-import java.util.Map.Entry;
|
|
|
-import java.util.NoSuchElementException;
|
|
|
import java.util.Properties;
|
|
|
-import java.util.StringTokenizer;
|
|
|
-
|
|
|
-import javolution.util.FastComparator;
|
|
|
-import javolution.util.FastTable;
|
|
|
|
|
|
import com.l2jserver.Config;
|
|
|
-import com.l2jserver.L2DatabaseFactory;
|
|
|
-import com.l2jserver.gameserver.Announcements;
|
|
|
-import com.l2jserver.gameserver.GameTimeController;
|
|
|
-import com.l2jserver.gameserver.GmListTable;
|
|
|
-import com.l2jserver.gameserver.LoginServerThread;
|
|
|
-import com.l2jserver.gameserver.Shutdown;
|
|
|
-import com.l2jserver.gameserver.ThreadPoolManager;
|
|
|
-import com.l2jserver.gameserver.cache.HtmCache;
|
|
|
-import com.l2jserver.gameserver.datatables.ItemTable;
|
|
|
-import com.l2jserver.gameserver.datatables.MultiSell;
|
|
|
-import com.l2jserver.gameserver.datatables.NpcTable;
|
|
|
-import com.l2jserver.gameserver.datatables.SkillTable;
|
|
|
-import com.l2jserver.gameserver.datatables.SpawnTable;
|
|
|
-import com.l2jserver.gameserver.datatables.TeleportLocationTable;
|
|
|
-import com.l2jserver.gameserver.instancemanager.DayNightSpawnManager;
|
|
|
-import com.l2jserver.gameserver.instancemanager.Manager;
|
|
|
-import com.l2jserver.gameserver.instancemanager.QuestManager;
|
|
|
-import com.l2jserver.gameserver.instancemanager.RaidBossSpawnManager;
|
|
|
-import com.l2jserver.gameserver.instancemanager.ZoneManager;
|
|
|
-import com.l2jserver.gameserver.model.L2ItemInstance;
|
|
|
-import com.l2jserver.gameserver.model.L2Object;
|
|
|
-import com.l2jserver.gameserver.model.L2World;
|
|
|
-import com.l2jserver.gameserver.model.TradeItem;
|
|
|
-import com.l2jserver.gameserver.model.TradeList;
|
|
|
-import com.l2jserver.gameserver.model.actor.L2Character;
|
|
|
-import com.l2jserver.gameserver.model.actor.L2Npc;
|
|
|
-import com.l2jserver.gameserver.model.actor.L2Summon;
|
|
|
-import com.l2jserver.gameserver.model.actor.instance.L2DoorInstance;
|
|
|
-import com.l2jserver.gameserver.model.actor.instance.L2MonsterInstance;
|
|
|
-import com.l2jserver.gameserver.model.actor.instance.L2PcInstance;
|
|
|
-import com.l2jserver.gameserver.model.itemcontainer.Inventory;
|
|
|
-import com.l2jserver.gameserver.network.SystemMessageId;
|
|
|
-import com.l2jserver.gameserver.network.clientpackets.Say2;
|
|
|
-import com.l2jserver.gameserver.network.serverpackets.CharInfo;
|
|
|
-import com.l2jserver.gameserver.network.serverpackets.CreatureSay;
|
|
|
-import com.l2jserver.gameserver.network.serverpackets.ExBrExtraUserInfo;
|
|
|
-import com.l2jserver.gameserver.network.serverpackets.InventoryUpdate;
|
|
|
-import com.l2jserver.gameserver.network.serverpackets.SystemMessage;
|
|
|
-import com.l2jserver.gameserver.network.serverpackets.UserInfo;
|
|
|
-import com.l2jserver.gameserver.taskmanager.DecayTaskManager;
|
|
|
-import com.l2jserver.gameserver.util.GMAudit;
|
|
|
+import com.l2jserver.gameserver.handler.ITelnetHandler;
|
|
|
+import com.l2jserver.gameserver.handler.TelnetHandler;
|
|
|
|
|
|
public class GameStatusThread extends Thread
|
|
|
{
|
|
|
- //private static final Logger _log = Logger.getLogger(AdminTeleport.class.getName());
|
|
|
-
|
|
|
private final Socket _cSocket;
|
|
|
|
|
|
private final PrintWriter _print;
|
|
@@ -114,7 +55,7 @@ public class GameStatusThread extends Thread
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
- //only print output if the message is rejected
|
|
|
+ // only print output if the message is rejected
|
|
|
if (type == 5)
|
|
|
System.out.println("TELNET | " + text);
|
|
|
}
|
|
@@ -184,7 +125,7 @@ public class GameStatusThread extends Thread
|
|
|
|
|
|
public GameStatusThread(Socket client, int uptime, String StatusPW) throws IOException
|
|
|
{
|
|
|
- this.setPriority(Thread.MAX_PRIORITY);
|
|
|
+ setPriority(Thread.MAX_PRIORITY);
|
|
|
_cSocket = client;
|
|
|
_uptime = uptime;
|
|
|
|
|
@@ -246,657 +187,18 @@ public class GameStatusThread extends Thread
|
|
|
_cSocket.close();
|
|
|
break;
|
|
|
}
|
|
|
- if (_usrCommand.equals("help"))
|
|
|
- {
|
|
|
- _print.println("The following is a list of all available commands: ");
|
|
|
- _print.println("help - shows this help.");
|
|
|
- _print.println("status - displays basic server statistics.");
|
|
|
- _print.println("gamestat privatestore - displays info about stores");
|
|
|
- _print.println("performance - shows server performance statistics.");
|
|
|
- _print.println("forcegc - forced garbage collection.");
|
|
|
- _print.println("purge - removes finished threads from thread pools.");
|
|
|
- _print.println("memusage - displays memory amounts in JVM.");
|
|
|
- _print.println("announce <text> - announces <text> in game.");
|
|
|
- _print.println("msg <nick> <text> - Sends a whisper to char <nick> with <text>.");
|
|
|
- _print.println("gmchat <text> - Sends a message to all GMs with <text>.");
|
|
|
- _print.println("gmlist - lists all gms online.");
|
|
|
- _print.println("kick - kick player <name> from server.");
|
|
|
- _print.println("shutdown <time> - shuts down server in <time> seconds.");
|
|
|
- _print.println("restart <time> - restarts down server in <time> seconds.");
|
|
|
- _print.println("abort - aborts shutdown/restart.");
|
|
|
- _print.println("give <player> <itemid> <amount>");
|
|
|
- _print.println("enchant <player> <itemType> <enchant> (itemType: 1 - Helmet, 2 - Chest, 3 - Gloves, 4 - Feet, 5 - Legs, 6 - Right Hand, 7 - Left Hand, 8 - Left Ear, 9 - Right Ear , 10 - Left Finger, 11 - Right Finger, 12- Necklace, 13 - Underwear, 14 - Back, 15 - Belt, 0 - No Enchant)");
|
|
|
- _print.println("debug <cmd> - executes the debug command (see 'help debug').");
|
|
|
- _print.println("reload <type> - reload data");
|
|
|
- _print.println("jail <player> [time]");
|
|
|
- _print.println("unjail <player>");
|
|
|
- _print.println("quit - closes telnet session.");
|
|
|
- }
|
|
|
- else if (_usrCommand.equals("help debug"))
|
|
|
- {
|
|
|
- _print.println("The following is a list of all available debug commands: ");
|
|
|
- _print.println("full - Dumps complete debug information to an file (recommended)");
|
|
|
- _print.println("decay - prints info about the DecayManager");
|
|
|
- _print.println("PacketTP - prints info about the General Packet ThreadPool");
|
|
|
- _print.println("IOPacketTP - prints info about the I/O Packet ThreadPool");
|
|
|
- _print.println("GeneralTP - prints info about the General ThreadPool");
|
|
|
- }
|
|
|
- else if (_usrCommand.equals("status"))
|
|
|
- {
|
|
|
- _print.print(this.getServerStatus());
|
|
|
- _print.flush();
|
|
|
- }
|
|
|
- else if (_usrCommand.equals("forcegc"))
|
|
|
- {
|
|
|
- System.gc();
|
|
|
- StringBuilder sb = new StringBuilder();
|
|
|
- sb.append("RAM Used: " + ((Runtime.getRuntime().totalMemory() - Runtime.getRuntime().freeMemory()) / 1048576)); // 1024 * 1024 = 1048576
|
|
|
- _print.println(sb.toString());
|
|
|
- }
|
|
|
- else if (_usrCommand.equals("performance"))
|
|
|
- {
|
|
|
- for (String line : ThreadPoolManager.getInstance().getStats())
|
|
|
- {
|
|
|
- _print.println(line);
|
|
|
- }
|
|
|
- _print.flush();
|
|
|
- }
|
|
|
- else if (_usrCommand.equals("purge"))
|
|
|
- {
|
|
|
- ThreadPoolManager.getInstance().purge();
|
|
|
- _print.println("STATUS OF THREAD POOLS AFTER PURGE COMMAND:");
|
|
|
- _print.println("");
|
|
|
- for (String line : ThreadPoolManager.getInstance().getStats())
|
|
|
- {
|
|
|
- _print.println(line);
|
|
|
- }
|
|
|
- _print.flush();
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("memusage"))
|
|
|
- {
|
|
|
- double max = Runtime.getRuntime().maxMemory() / 1024; // maxMemory is the upper
|
|
|
- // limit the jvm can use
|
|
|
- double allocated = Runtime.getRuntime().totalMemory() / 1024; // totalMemory the
|
|
|
- // size of the
|
|
|
- // current
|
|
|
- // allocation pool
|
|
|
- double nonAllocated = max - allocated; // non allocated memory till jvm limit
|
|
|
- double cached = Runtime.getRuntime().freeMemory() / 1024; // freeMemory the
|
|
|
- // unused memory in
|
|
|
- // the allocation pool
|
|
|
- double used = allocated - cached; // really used memory
|
|
|
- double useable = max - used; // allocated, but non-used and non-allocated memory
|
|
|
-
|
|
|
- DecimalFormat df = new DecimalFormat(" (0.0000'%')");
|
|
|
- DecimalFormat df2 = new DecimalFormat(" # 'KB'");
|
|
|
-
|
|
|
- _print.println("+----");// ...
|
|
|
- _print.println("| Allowed Memory:" + df2.format(max));
|
|
|
- _print.println("| |= Allocated Memory:" + df2.format(allocated) + df.format(allocated / max * 100));
|
|
|
- _print.println("| |= Non-Allocated Memory:" + df2.format(nonAllocated) + df.format(nonAllocated / max * 100));
|
|
|
- _print.println("| Allocated Memory:" + df2.format(allocated));
|
|
|
- _print.println("| |= Used Memory:" + df2.format(used) + df.format(used / max * 100));
|
|
|
- _print.println("| |= Unused (cached) Memory:" + df2.format(cached) + df.format(cached / max * 100));
|
|
|
- _print.println("| Useable Memory:" + df2.format(useable) + df.format(useable / max * 100)); // ...
|
|
|
- _print.println("+----");
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("announce"))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- _usrCommand = _usrCommand.substring(9);
|
|
|
- Announcements.getInstance().announceToAll(_usrCommand);
|
|
|
- _print.println("Announcement Sent!");
|
|
|
- }
|
|
|
- catch (StringIndexOutOfBoundsException e)
|
|
|
- {
|
|
|
- _print.println("Please Enter Some Text To Announce!");
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("msg"))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- String val = _usrCommand.substring(4);
|
|
|
- StringTokenizer st = new StringTokenizer(val);
|
|
|
- String name = st.nextToken();
|
|
|
- String message = val.substring(name.length() + 1);
|
|
|
- L2PcInstance reciever = L2World.getInstance().getPlayer(name);
|
|
|
- CreatureSay cs = new CreatureSay(0, Say2.TELL, "Telnet Priv", message);
|
|
|
- if (reciever != null)
|
|
|
- {
|
|
|
- reciever.sendPacket(cs);
|
|
|
- _print.println("Telnet Priv->" + name + ": " + message);
|
|
|
- _print.println("Message Sent!");
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- _print.println("Unable To Find Username: " + name);
|
|
|
- }
|
|
|
- }
|
|
|
- catch (StringIndexOutOfBoundsException e)
|
|
|
- {
|
|
|
- _print.println("Please Enter Some Text!");
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("gmchat"))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- _usrCommand = _usrCommand.substring(7);
|
|
|
- CreatureSay cs = new CreatureSay(0, Say2.ALLIANCE, "Telnet GM Broadcast from " + _cSocket.getInetAddress().getHostAddress(), _usrCommand);
|
|
|
- GmListTable.broadcastToGMs(cs);
|
|
|
- _print.println("Your Message Has Been Sent To " + getOnlineGMS() + " GM(s).");
|
|
|
- }
|
|
|
- catch (StringIndexOutOfBoundsException e)
|
|
|
- {
|
|
|
- _print.println("Please Enter Some Text To Announce!");
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.equals("gmlist"))
|
|
|
- {
|
|
|
- int igm = 0;
|
|
|
- String gmList = "";
|
|
|
-
|
|
|
- for (String player : GmListTable.getInstance().getAllGmNames(true))
|
|
|
- {
|
|
|
- gmList = gmList + ", " + player;
|
|
|
- igm++;
|
|
|
- }
|
|
|
- _print.println("There are currently " + igm + " GM(s) online...");
|
|
|
- if (!gmList.isEmpty())
|
|
|
- _print.println(gmList);
|
|
|
- }
|
|
|
- /*else if (_usrCommand.startsWith("unblock"))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- _usrCommand = _usrCommand.substring(8);
|
|
|
- if (LoginServer.getInstance().unblockIp(_usrCommand))
|
|
|
- {
|
|
|
- _log.warning("IP removed via TELNET by host: " + _csocket.getInetAddress().getHostAddress());
|
|
|
- _print.println("The IP " + _usrCommand + " has been removed from the hack protection list!");
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- _print.println("IP not found in hack protection list...");
|
|
|
- }
|
|
|
- //TODO: with packet
|
|
|
- }
|
|
|
- catch (StringIndexOutOfBoundsException e)
|
|
|
- {
|
|
|
- _print.println("Please Enter the IP to Unblock!");
|
|
|
- }
|
|
|
- }*/
|
|
|
- else if (_usrCommand.startsWith("kick"))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- _usrCommand = _usrCommand.substring(5);
|
|
|
- L2PcInstance player = L2World.getInstance().getPlayer(_usrCommand);
|
|
|
- if (player != null)
|
|
|
- {
|
|
|
- player.sendMessage("You are kicked by gm");
|
|
|
- player.logout();
|
|
|
- _print.println("Player kicked");
|
|
|
- }
|
|
|
- }
|
|
|
- catch (StringIndexOutOfBoundsException e)
|
|
|
- {
|
|
|
- _print.println("Please enter player name to kick");
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("shutdown"))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- int val = Integer.parseInt(_usrCommand.substring(9));
|
|
|
- Shutdown.getInstance().startTelnetShutdown(_cSocket.getInetAddress().getHostAddress(), val, false);
|
|
|
- _print.println("Server Will Shutdown In " + val + " Seconds!");
|
|
|
- _print.println("Type \"abort\" To Abort Shutdown!");
|
|
|
- }
|
|
|
- catch (StringIndexOutOfBoundsException e)
|
|
|
- {
|
|
|
- _print.println("Please Enter * amount of seconds to shutdown!");
|
|
|
- }
|
|
|
- catch (Exception NumberFormatException)
|
|
|
- {
|
|
|
- _print.println("Numbers Only!");
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("restart"))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- int val = Integer.parseInt(_usrCommand.substring(8));
|
|
|
- Shutdown.getInstance().startTelnetShutdown(_cSocket.getInetAddress().getHostAddress(), val, true);
|
|
|
- _print.println("Server Will Restart In " + val + " Seconds!");
|
|
|
- _print.println("Type \"abort\" To Abort Restart!");
|
|
|
- }
|
|
|
- catch (StringIndexOutOfBoundsException e)
|
|
|
- {
|
|
|
- _print.println("Please Enter * amount of seconds to restart!");
|
|
|
- }
|
|
|
- catch (Exception NumberFormatException)
|
|
|
- {
|
|
|
- _print.println("Numbers Only!");
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("abort"))
|
|
|
- {
|
|
|
- Shutdown.getInstance().telnetAbort(_cSocket.getInetAddress().getHostAddress());
|
|
|
- _print.println("OK! - Shutdown/Restart Aborted.");
|
|
|
- }
|
|
|
- else if (_usrCommand.equals("quit"))
|
|
|
- { /* Do Nothing :p - Just here to save us from the "Command Not Understood" Text */
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("give"))
|
|
|
- {
|
|
|
- StringTokenizer st = new StringTokenizer(_usrCommand.substring(5));
|
|
|
-
|
|
|
- try
|
|
|
- {
|
|
|
- L2PcInstance player = L2World.getInstance().getPlayer(st.nextToken());
|
|
|
- int itemId = Integer.parseInt(st.nextToken());
|
|
|
- int amount = Integer.parseInt(st.nextToken());
|
|
|
-
|
|
|
- if (player != null)
|
|
|
- {
|
|
|
- L2ItemInstance item = player.getInventory().addItem("Status-Give", itemId, amount, null, null);
|
|
|
- InventoryUpdate iu = new InventoryUpdate();
|
|
|
- iu.addItem(item);
|
|
|
- player.sendPacket(iu);
|
|
|
- SystemMessage sm = SystemMessage.getSystemMessage(SystemMessageId.YOU_PICKED_UP_S1_S2);
|
|
|
- sm.addItemName(itemId);
|
|
|
- sm.addItemNumber(amount);
|
|
|
- player.sendPacket(sm);
|
|
|
- _print.println("ok");
|
|
|
- GMAudit.auditGMAction("Telnet Admin", "Give Item", player.getName(), "item: " + itemId + " amount: " + amount);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- _print.println("Player not found");
|
|
|
- }
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("enchant"))
|
|
|
- {
|
|
|
- StringTokenizer st = new StringTokenizer(_usrCommand.substring(8), " ");
|
|
|
- int enchant = 0, itemType = 0;
|
|
|
-
|
|
|
- try
|
|
|
- {
|
|
|
- L2PcInstance player = L2World.getInstance().getPlayer(st.nextToken());
|
|
|
- itemType = Integer.parseInt(st.nextToken());
|
|
|
- enchant = Integer.parseInt(st.nextToken());
|
|
|
-
|
|
|
- switch (itemType)
|
|
|
- {
|
|
|
- case 1:
|
|
|
- itemType = Inventory.PAPERDOLL_HEAD;
|
|
|
- break;
|
|
|
- case 2:
|
|
|
- itemType = Inventory.PAPERDOLL_CHEST;
|
|
|
- break;
|
|
|
- case 3:
|
|
|
- itemType = Inventory.PAPERDOLL_GLOVES;
|
|
|
- break;
|
|
|
- case 4:
|
|
|
- itemType = Inventory.PAPERDOLL_FEET;
|
|
|
- break;
|
|
|
- case 5:
|
|
|
- itemType = Inventory.PAPERDOLL_LEGS;
|
|
|
- break;
|
|
|
- case 6:
|
|
|
- itemType = Inventory.PAPERDOLL_RHAND;
|
|
|
- break;
|
|
|
- case 7:
|
|
|
- itemType = Inventory.PAPERDOLL_LHAND;
|
|
|
- break;
|
|
|
- case 8:
|
|
|
- itemType = Inventory.PAPERDOLL_LEAR;
|
|
|
- break;
|
|
|
- case 9:
|
|
|
- itemType = Inventory.PAPERDOLL_REAR;
|
|
|
- break;
|
|
|
- case 10:
|
|
|
- itemType = Inventory.PAPERDOLL_LFINGER;
|
|
|
- break;
|
|
|
- case 11:
|
|
|
- itemType = Inventory.PAPERDOLL_RFINGER;
|
|
|
- break;
|
|
|
- case 12:
|
|
|
- itemType = Inventory.PAPERDOLL_NECK;
|
|
|
- break;
|
|
|
- case 13:
|
|
|
- itemType = Inventory.PAPERDOLL_UNDER;
|
|
|
- break;
|
|
|
- case 14:
|
|
|
- itemType = Inventory.PAPERDOLL_CLOAK;
|
|
|
- break;
|
|
|
- case 15:
|
|
|
- itemType = Inventory.PAPERDOLL_BELT;
|
|
|
- break;
|
|
|
- default:
|
|
|
- itemType = 0;
|
|
|
- }
|
|
|
-
|
|
|
- if (enchant > 65535)
|
|
|
- enchant = 65535;
|
|
|
- else if (enchant < 0)
|
|
|
- enchant = 0;
|
|
|
-
|
|
|
- boolean success = false;
|
|
|
-
|
|
|
- if (player != null && itemType > 0)
|
|
|
- {
|
|
|
- success = setEnchant(player, enchant, itemType);
|
|
|
- if (success)
|
|
|
- _print.println("Item enchanted successfully.");
|
|
|
- }
|
|
|
- else if (!success)
|
|
|
- _print.println("Item failed to enchant.");
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("jail"))
|
|
|
- {
|
|
|
- StringTokenizer st = new StringTokenizer(_usrCommand.substring(5));
|
|
|
- try
|
|
|
- {
|
|
|
- String playerName = st.nextToken();
|
|
|
- L2PcInstance playerObj = L2World.getInstance().getPlayer(playerName);
|
|
|
- int delay = 0;
|
|
|
- try
|
|
|
- {
|
|
|
- delay = Integer.parseInt(st.nextToken());
|
|
|
- }
|
|
|
- catch (NumberFormatException nfe)
|
|
|
- {
|
|
|
- }
|
|
|
- catch (NoSuchElementException nsee)
|
|
|
- {
|
|
|
- }
|
|
|
- //L2PcInstance playerObj = L2World.getInstance().getPlayer(player);
|
|
|
-
|
|
|
- if (playerObj != null)
|
|
|
- {
|
|
|
- playerObj.setPunishLevel(L2PcInstance.PunishLevel.JAIL, delay);
|
|
|
- _print.println("Character " + playerObj.getName() + " jailed for " + (delay > 0 ? delay + " minutes." : "ever!"));
|
|
|
- }
|
|
|
- else
|
|
|
- jailOfflinePlayer(playerName, delay);
|
|
|
- }
|
|
|
- catch (NoSuchElementException nsee)
|
|
|
- {
|
|
|
- _print.println("Specify a character name.");
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- if (Config.DEBUG)
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("unjail"))
|
|
|
- {
|
|
|
- StringTokenizer st = new StringTokenizer(_usrCommand.substring(7));
|
|
|
- try
|
|
|
- {
|
|
|
- String playerName = st.nextToken();
|
|
|
- L2PcInstance playerObj = L2World.getInstance().getPlayer(playerName);
|
|
|
-
|
|
|
- if (playerObj != null)
|
|
|
- {
|
|
|
- playerObj.setPunishLevel(L2PcInstance.PunishLevel.NONE, 0);
|
|
|
- _print.println("Character " + playerObj.getName() + " removed from jail");
|
|
|
- }
|
|
|
- else
|
|
|
- unjailOfflinePlayer(playerName);
|
|
|
- }
|
|
|
- catch (NoSuchElementException nsee)
|
|
|
- {
|
|
|
- _print.println("Specify a character name.");
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- if (Config.DEBUG)
|
|
|
- e.printStackTrace();
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("debug") && _usrCommand.length() > 6)
|
|
|
+
|
|
|
+ final ITelnetHandler handler = TelnetHandler.getInstance().getCommandHandler(_usrCommand);
|
|
|
+ if (handler != null)
|
|
|
+ handler.useCommand(_usrCommand, _print, _cSocket, _uptime);
|
|
|
+
|
|
|
+ else if (_usrCommand.equalsIgnoreCase("quit") || _usrCommand.equalsIgnoreCase("exit") || _usrCommand.length() == 0)
|
|
|
{
|
|
|
- StringTokenizer st = new StringTokenizer(_usrCommand.substring(6));
|
|
|
- FileOutputStream fos = null;
|
|
|
- OutputStreamWriter out = null;
|
|
|
- try
|
|
|
- {
|
|
|
- String dbg = st.nextToken();
|
|
|
-
|
|
|
- if (dbg.equals("decay"))
|
|
|
- {
|
|
|
- _print.print(DecayTaskManager.getInstance().toString());
|
|
|
- }
|
|
|
- else if (dbg.equals("ai"))
|
|
|
- {
|
|
|
- /*
|
|
|
- _print.println("AITaskManagerStats");
|
|
|
- for(String line : AITaskManager.getInstance().getStats())
|
|
|
- {
|
|
|
- _print.println(line);
|
|
|
- }
|
|
|
- */
|
|
|
- }
|
|
|
- else if (dbg.equals("aiflush"))
|
|
|
- {
|
|
|
- //AITaskManager.getInstance().flush();
|
|
|
- }
|
|
|
- else if (dbg.equals("PacketTP"))
|
|
|
- {
|
|
|
- String str = ThreadPoolManager.getInstance().getPacketStats();
|
|
|
- _print.println(str);
|
|
|
- int i = 0;
|
|
|
- File f = new File("./log/StackTrace-PacketTP-" + i + ".txt");
|
|
|
- while (f.exists())
|
|
|
- {
|
|
|
- i++;
|
|
|
- f = new File("./log/StackTrace-PacketTP-" + i + ".txt");
|
|
|
- }
|
|
|
- f.getParentFile().mkdirs();
|
|
|
- fos = new FileOutputStream(f);
|
|
|
- out = new OutputStreamWriter(fos, "UTF-8");
|
|
|
- out.write(str);
|
|
|
- }
|
|
|
- else if (dbg.equals("IOPacketTP"))
|
|
|
- {
|
|
|
- String str = ThreadPoolManager.getInstance().getIOPacketStats();
|
|
|
- _print.println(str);
|
|
|
- int i = 0;
|
|
|
- File f = new File("./log/StackTrace-IOPacketTP-" + i + ".txt");
|
|
|
- while (f.exists())
|
|
|
- {
|
|
|
- i++;
|
|
|
- f = new File("./log/StackTrace-IOPacketTP-" + i + ".txt");
|
|
|
- }
|
|
|
- f.getParentFile().mkdirs();
|
|
|
- fos = new FileOutputStream(f);
|
|
|
- out = new OutputStreamWriter(fos, "UTF-8");
|
|
|
- out.write(str);
|
|
|
- }
|
|
|
- else if (dbg.equals("GeneralTP"))
|
|
|
- {
|
|
|
- String str = ThreadPoolManager.getInstance().getGeneralStats();
|
|
|
- _print.println(str);
|
|
|
- int i = 0;
|
|
|
- File f = new File("./log/StackTrace-GeneralTP-" + i + ".txt");
|
|
|
- while (f.exists())
|
|
|
- {
|
|
|
- i++;
|
|
|
- f = new File("./log/StackTrace-GeneralTP-" + i + ".txt");
|
|
|
- }
|
|
|
- f.getParentFile().mkdirs();
|
|
|
- fos = new FileOutputStream(f);
|
|
|
- out = new OutputStreamWriter(fos, "UTF-8");
|
|
|
- out.write(str);
|
|
|
- }
|
|
|
- else if (dbg.equals("full"))
|
|
|
- {
|
|
|
- this.debugAll();
|
|
|
- }
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- }
|
|
|
- finally
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- out.close();
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- }
|
|
|
-
|
|
|
- try
|
|
|
- {
|
|
|
- fos.close();
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("reload"))
|
|
|
- {
|
|
|
- StringTokenizer st = new StringTokenizer(_usrCommand.substring(7));
|
|
|
- try
|
|
|
- {
|
|
|
- String type = st.nextToken();
|
|
|
-
|
|
|
- if (type.equals("multisell"))
|
|
|
- {
|
|
|
- _print.print("Reloading multisell... ");
|
|
|
- MultiSell.getInstance().reload();
|
|
|
- _print.println("done");
|
|
|
- }
|
|
|
- else if (type.equals("skill"))
|
|
|
- {
|
|
|
- _print.print("Reloading skills... ");
|
|
|
- SkillTable.getInstance().reload();
|
|
|
- _print.println("done");
|
|
|
- }
|
|
|
- else if (type.equals("npc"))
|
|
|
- {
|
|
|
- _print.print("Reloading npc templates... ");
|
|
|
- NpcTable.getInstance().reloadAllNpc();
|
|
|
- QuestManager.getInstance().reloadAllQuests();
|
|
|
- _print.println("done");
|
|
|
- }
|
|
|
- else if (type.equals("html"))
|
|
|
- {
|
|
|
- _print.print("Reloading html cache... ");
|
|
|
- HtmCache.getInstance().reload();
|
|
|
- _print.println("done");
|
|
|
- }
|
|
|
- else if (type.equals("item"))
|
|
|
- {
|
|
|
- _print.print("Reloading item templates... ");
|
|
|
- ItemTable.getInstance().reload();
|
|
|
- _print.println("done");
|
|
|
- }
|
|
|
- else if (type.equals("instancemanager"))
|
|
|
- {
|
|
|
- _print.print("Reloading instance managers... ");
|
|
|
- Manager.reloadAll();
|
|
|
- _print.println("done");
|
|
|
- }
|
|
|
- else if (type.equals("zone"))
|
|
|
- {
|
|
|
- _print.print("Reloading zone tables... ");
|
|
|
- ZoneManager.getInstance().reload();
|
|
|
- _print.println("done");
|
|
|
- }
|
|
|
- else if (type.equals("teleports"))
|
|
|
- {
|
|
|
- _print.print("Reloading telport location table... ");
|
|
|
- TeleportLocationTable.getInstance().reloadAll();
|
|
|
- _print.println("done");
|
|
|
- }
|
|
|
- else if (type.equals("spawns"))
|
|
|
- {
|
|
|
- _print.print("Reloading spawns... ");
|
|
|
- RaidBossSpawnManager.getInstance().cleanUp();
|
|
|
- DayNightSpawnManager.getInstance().cleanUp();
|
|
|
- L2World.getInstance().deleteVisibleNpcSpawns();
|
|
|
- NpcTable.getInstance().reloadAllNpc();
|
|
|
- SpawnTable.getInstance().reloadAll();
|
|
|
- RaidBossSpawnManager.getInstance().reloadBosses();
|
|
|
- _print.println("done\n");
|
|
|
- }
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.startsWith("gamestat"))
|
|
|
- {
|
|
|
- StringTokenizer st = new StringTokenizer(_usrCommand.substring(9));
|
|
|
- try
|
|
|
- {
|
|
|
- String type = st.nextToken();
|
|
|
-
|
|
|
- // name;type;x;y;itemId:enchant:price...
|
|
|
- if (type.equals("privatestore"))
|
|
|
- {
|
|
|
- for (L2PcInstance player : L2World.getInstance().getAllPlayersArray())
|
|
|
- {
|
|
|
- if (player.getPrivateStoreType() == 0)
|
|
|
- continue;
|
|
|
-
|
|
|
- TradeList list = null;
|
|
|
- String content = "";
|
|
|
-
|
|
|
- if (player.getPrivateStoreType() == 1) // sell
|
|
|
- {
|
|
|
- list = player.getSellList();
|
|
|
- for (TradeItem item : list.getItems())
|
|
|
- {
|
|
|
- content += item.getItem().getItemId() + ":" + item.getEnchant() + ":" + item.getPrice() + ":";
|
|
|
- }
|
|
|
- content = player.getName() + ";" + "sell;" + player.getX() + ";" + player.getY() + ";" + content;
|
|
|
- _print.println(content);
|
|
|
- continue;
|
|
|
- }
|
|
|
- else if (player.getPrivateStoreType() == 3) // buy
|
|
|
- {
|
|
|
- list = player.getBuyList();
|
|
|
- for (TradeItem item : list.getItems())
|
|
|
- {
|
|
|
- content += item.getItem().getItemId() + ":" + item.getEnchant() + ":" + item.getPrice() + ":";
|
|
|
- }
|
|
|
- content = player.getName() + ";" + "buy;" + player.getX() + ";" + player.getY() + ";" + content;
|
|
|
- _print.println(content);
|
|
|
- continue;
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
- catch (Exception e)
|
|
|
- {
|
|
|
- }
|
|
|
- }
|
|
|
- else if (_usrCommand.length() == 0)
|
|
|
- { /* Do Nothing Again - Same reason as the quit part */
|
|
|
+ /* Do Nothing :p - Just here to save us from the "Command Not Understood" Text */
|
|
|
}
|
|
|
+ else
|
|
|
+ _print.print("Command: " + _usrCommand + " was not found!");
|
|
|
+
|
|
|
_print.print("");
|
|
|
_print.flush();
|
|
|
}
|
|
@@ -913,404 +215,4 @@ public class GameStatusThread extends Thread
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
- private boolean setEnchant(L2PcInstance activeChar, int ench, int armorType)
|
|
|
- {
|
|
|
- // now we need to find the equipped weapon of the targeted character...
|
|
|
- int curEnchant = 0; // display purposes only
|
|
|
- L2ItemInstance itemInstance = null;
|
|
|
-
|
|
|
- // only attempt to enchant if there is a weapon equipped
|
|
|
- L2ItemInstance parmorInstance = activeChar.getInventory().getPaperdollItem(armorType);
|
|
|
- if (parmorInstance != null && parmorInstance.getLocationSlot() == armorType)
|
|
|
- {
|
|
|
- itemInstance = parmorInstance;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- // for bows/crossbows and double handed weapons
|
|
|
- parmorInstance = activeChar.getInventory().getPaperdollItem(Inventory.PAPERDOLL_RHAND);
|
|
|
- if (parmorInstance != null && parmorInstance.getLocationSlot() == Inventory.PAPERDOLL_RHAND)
|
|
|
- itemInstance = parmorInstance;
|
|
|
- }
|
|
|
-
|
|
|
- if (itemInstance != null)
|
|
|
- {
|
|
|
- curEnchant = itemInstance.getEnchantLevel();
|
|
|
-
|
|
|
- // set enchant value
|
|
|
- activeChar.getInventory().unEquipItemInSlot(armorType);
|
|
|
- itemInstance.setEnchantLevel(ench);
|
|
|
- activeChar.getInventory().equipItem(itemInstance);
|
|
|
-
|
|
|
- // send packets
|
|
|
- InventoryUpdate iu = new InventoryUpdate();
|
|
|
- iu.addModifiedItem(itemInstance);
|
|
|
- activeChar.sendPacket(iu);
|
|
|
- activeChar.broadcastPacket(new CharInfo(activeChar));
|
|
|
- activeChar.sendPacket(new UserInfo(activeChar));
|
|
|
- activeChar.broadcastPacket(new ExBrExtraUserInfo(activeChar));
|
|
|
-
|
|
|
- // informations
|
|
|
- activeChar.sendMessage("Changed enchantment of " + activeChar.getName() + "'s " + itemInstance.getItem().getName() + " from " + curEnchant + " to " + ench + ".");
|
|
|
- activeChar.sendMessage("Admin has changed the enchantment of your " + itemInstance.getItem().getName() + " from " + curEnchant + " to " + ench + ".");
|
|
|
-
|
|
|
- // log
|
|
|
- GMAudit.auditGMAction("TelnetAdministrator", "enchant", activeChar.getName(), itemInstance.getItem().getName() + "(" + itemInstance.getObjectId() + ")" + " from " + curEnchant + " to " + ench);
|
|
|
- return true;
|
|
|
- }
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- private void jailOfflinePlayer(String name, int delay)
|
|
|
- {
|
|
|
- Connection con = null;
|
|
|
- try
|
|
|
- {
|
|
|
- con = L2DatabaseFactory.getInstance().getConnection();
|
|
|
-
|
|
|
- PreparedStatement statement = con.prepareStatement("UPDATE characters SET x=?, y=?, z=?, punish_level=?, punish_timer=? WHERE char_name=?");
|
|
|
- statement.setInt(1, -114356);
|
|
|
- statement.setInt(2, -249645);
|
|
|
- statement.setInt(3, -2984);
|
|
|
- statement.setInt(4, L2PcInstance.PunishLevel.JAIL.value());
|
|
|
- statement.setLong(5, delay * 60000L);
|
|
|
- statement.setString(6, name);
|
|
|
-
|
|
|
- statement.execute();
|
|
|
- int count = statement.getUpdateCount();
|
|
|
- statement.close();
|
|
|
-
|
|
|
- if (count == 0)
|
|
|
- _print.println("Character not found!");
|
|
|
- else
|
|
|
- _print.println("Character " + name + " jailed for " + (delay > 0 ? delay + " minutes." : "ever!"));
|
|
|
- }
|
|
|
- catch (SQLException se)
|
|
|
- {
|
|
|
- _print.println("SQLException while jailing player");
|
|
|
- if (Config.DEBUG)
|
|
|
- se.printStackTrace();
|
|
|
- }
|
|
|
- finally
|
|
|
- {
|
|
|
- L2DatabaseFactory.close(con);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private void unjailOfflinePlayer(String name)
|
|
|
- {
|
|
|
- Connection con = null;
|
|
|
- try
|
|
|
- {
|
|
|
- con = L2DatabaseFactory.getInstance().getConnection();
|
|
|
-
|
|
|
- PreparedStatement statement = con.prepareStatement("UPDATE characters SET x=?, y=?, z=?, punish_level=?, punish_timer=? WHERE char_name=?");
|
|
|
- statement.setInt(1, 17836);
|
|
|
- statement.setInt(2, 170178);
|
|
|
- statement.setInt(3, -3507);
|
|
|
- statement.setInt(4, 0);
|
|
|
- statement.setLong(5, 0);
|
|
|
- statement.setString(6, name);
|
|
|
-
|
|
|
- statement.execute();
|
|
|
- int count = statement.getUpdateCount();
|
|
|
- statement.close();
|
|
|
-
|
|
|
- if (count == 0)
|
|
|
- _print.println("Character not found!");
|
|
|
- else
|
|
|
- _print.println("Character " + name + " set free.");
|
|
|
- }
|
|
|
- catch (SQLException se)
|
|
|
- {
|
|
|
- _print.println("SQLException while jailing player");
|
|
|
- if (Config.DEBUG)
|
|
|
- se.printStackTrace();
|
|
|
- }
|
|
|
- finally
|
|
|
- {
|
|
|
- L2DatabaseFactory.close(con);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private int getOnlineGMS()
|
|
|
- {
|
|
|
- return GmListTable.getInstance().getAllGms(true).size();
|
|
|
- }
|
|
|
-
|
|
|
- private String getUptime(int time)
|
|
|
- {
|
|
|
- int uptime = (int) System.currentTimeMillis() - time;
|
|
|
- uptime = uptime / 1000;
|
|
|
- int h = uptime / 3600;
|
|
|
- int m = (uptime - (h * 3600)) / 60;
|
|
|
- int s = ((uptime - (h * 3600)) - (m * 60));
|
|
|
- return h + "hrs " + m + "mins " + s + "secs";
|
|
|
- }
|
|
|
-
|
|
|
- private String gameTime()
|
|
|
- {
|
|
|
- int t = GameTimeController.getInstance().getGameTime();
|
|
|
- int h = t / 60;
|
|
|
- int m = t % 60;
|
|
|
- SimpleDateFormat format = new SimpleDateFormat("H:mm");
|
|
|
- Calendar cal = Calendar.getInstance();
|
|
|
- cal.set(Calendar.HOUR_OF_DAY, h);
|
|
|
- cal.set(Calendar.MINUTE, m);
|
|
|
- return format.format(cal.getTime());
|
|
|
- }
|
|
|
-
|
|
|
- public String getServerStatus()
|
|
|
- {
|
|
|
- int playerCount = 0, objectCount = 0;
|
|
|
- int max = LoginServerThread.getInstance().getMaxPlayer();
|
|
|
-
|
|
|
- playerCount = L2World.getInstance().getAllPlayersCount();
|
|
|
- objectCount = L2World.getInstance().getAllVisibleObjectsCount();
|
|
|
-
|
|
|
- int itemCount = 0;
|
|
|
- int itemVoidCount = 0;
|
|
|
- int monsterCount = 0;
|
|
|
- int minionCount = 0;
|
|
|
- int minionsGroupCount = 0;
|
|
|
- int npcCount = 0;
|
|
|
- int charCount = 0;
|
|
|
- int pcCount = 0;
|
|
|
- int detachedCount = 0;
|
|
|
- int doorCount = 0;
|
|
|
- int summonCount = 0;
|
|
|
- int AICount = 0;
|
|
|
-
|
|
|
- for (L2Object obj : L2World.getInstance().getAllVisibleObjectsArray())
|
|
|
- {
|
|
|
- if (obj == null)
|
|
|
- continue;
|
|
|
- if (obj instanceof L2Character)
|
|
|
- if (((L2Character) obj).hasAI())
|
|
|
- AICount++;
|
|
|
- if (obj instanceof L2ItemInstance)
|
|
|
- if (((L2ItemInstance) obj).getLocation() == L2ItemInstance.ItemLocation.VOID)
|
|
|
- itemVoidCount++;
|
|
|
- else
|
|
|
- itemCount++;
|
|
|
-
|
|
|
- else if (obj instanceof L2MonsterInstance)
|
|
|
- {
|
|
|
- monsterCount++;
|
|
|
- if (((L2MonsterInstance) obj).hasMinions())
|
|
|
- {
|
|
|
- minionCount += ((L2MonsterInstance) obj).getMinionList().countSpawnedMinions();
|
|
|
- minionsGroupCount += ((L2MonsterInstance) obj).getMinionList().lazyCountSpawnedMinionsGroups();
|
|
|
- }
|
|
|
- }
|
|
|
- else if (obj instanceof L2Npc)
|
|
|
- npcCount++;
|
|
|
- else if (obj instanceof L2PcInstance)
|
|
|
- {
|
|
|
- pcCount++;
|
|
|
- if (((L2PcInstance) obj).getClient() != null && ((L2PcInstance) obj).getClient().isDetached())
|
|
|
- detachedCount++;
|
|
|
- }
|
|
|
- else if (obj instanceof L2Summon)
|
|
|
- summonCount++;
|
|
|
- else if (obj instanceof L2DoorInstance)
|
|
|
- doorCount++;
|
|
|
- else if (obj instanceof L2Character)
|
|
|
- charCount++;
|
|
|
- }
|
|
|
-
|
|
|
- StringBuilder sb = new StringBuilder();
|
|
|
- sb.append("Server Status: ");
|
|
|
- sb.append("\r\n ---> Player Count: " + playerCount + "/" + max);
|
|
|
- sb.append("\r\n ---> Offline Count: " + detachedCount + "/" + playerCount);
|
|
|
- sb.append("\r\n +--> Object Count: " + objectCount);
|
|
|
- sb.append("\r\n +--> AI Count: " + AICount);
|
|
|
- sb.append("\r\n +.... L2Item(Void): " + itemVoidCount);
|
|
|
- sb.append("\r\n +.......... L2Item: " + itemCount);
|
|
|
- sb.append("\r\n +....... L2Monster: " + monsterCount);
|
|
|
- sb.append("\r\n +......... Minions: " + minionCount);
|
|
|
- sb.append("\r\n +.. Minions Groups: " + minionsGroupCount);
|
|
|
- sb.append("\r\n +........... L2Npc: " + npcCount);
|
|
|
- sb.append("\r\n +............ L2Pc: " + pcCount);
|
|
|
- sb.append("\r\n +........ L2Summon: " + summonCount);
|
|
|
- sb.append("\r\n +.......... L2Door: " + doorCount);
|
|
|
- sb.append("\r\n +.......... L2Char: " + charCount);
|
|
|
- sb.append("\r\n ---> Ingame Time: " + gameTime());
|
|
|
- sb.append("\r\n ---> Server Uptime: " + getUptime(_uptime));
|
|
|
- sb.append("\r\n ---> GM Count: " + getOnlineGMS());
|
|
|
- sb.append("\r\n ---> Threads: " + Thread.activeCount());
|
|
|
- sb.append("\r\n RAM Used: " + ((Runtime.getRuntime().totalMemory() - Runtime.getRuntime().freeMemory()) / 1048576)); // 1024 * 1024 = 1048576
|
|
|
- sb.append("\r\n");
|
|
|
-
|
|
|
- return sb.toString();
|
|
|
- }
|
|
|
-
|
|
|
- @SuppressWarnings("serial")
|
|
|
- public void debugAll() throws IOException
|
|
|
- {
|
|
|
- Calendar cal = Calendar.getInstance();
|
|
|
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss Z");
|
|
|
-
|
|
|
- StringBuilder sb = new StringBuilder();
|
|
|
- sb.append(sdf.format(cal.getTime()));
|
|
|
- sb.append("\n\nL2J Server Version: " + Config.SERVER_VERSION);
|
|
|
- sb.append("\nDP Revision: " + Config.DATAPACK_VERSION);
|
|
|
- sb.append("\n\n");
|
|
|
- sb.append(this.getServerStatus());
|
|
|
- sb.append("\n\n");
|
|
|
- sb.append("\n## Java Platform Information ##");
|
|
|
- sb.append("\nJava Runtime Name: " + System.getProperty("java.runtime.name"));
|
|
|
- sb.append("\nJava Version: " + System.getProperty("java.version"));
|
|
|
- sb.append("\nJava Class Version: " + System.getProperty("java.class.version"));
|
|
|
- sb.append("\n");
|
|
|
- sb.append("\n## Virtual Machine Information ##");
|
|
|
- sb.append("\nVM Name: " + System.getProperty("java.vm.name"));
|
|
|
- sb.append("\nVM Version: " + System.getProperty("java.vm.version"));
|
|
|
- sb.append("\nVM Vendor: " + System.getProperty("java.vm.vendor"));
|
|
|
- sb.append("\nVM Info: " + System.getProperty("java.vm.info"));
|
|
|
- sb.append("\n");
|
|
|
- sb.append("\n## OS Information ##");
|
|
|
- sb.append("\nName: " + System.getProperty("os.name"));
|
|
|
- sb.append("\nArchiteture: " + System.getProperty("os.arch"));
|
|
|
- sb.append("\nVersion: " + System.getProperty("os.version"));
|
|
|
- sb.append("\n");
|
|
|
- sb.append("\n## Runtime Information ##");
|
|
|
- sb.append("\nCPU Count: " + Runtime.getRuntime().availableProcessors());
|
|
|
- sb.append("\nCurrent Free Heap Size: " + (Runtime.getRuntime().freeMemory() / 1024 / 1024) + " mb");
|
|
|
- sb.append("\nCurrent Heap Size: " + (Runtime.getRuntime().totalMemory() / 1024 / 1024) + " mb");
|
|
|
- sb.append("\nMaximum Heap Size: " + (Runtime.getRuntime().maxMemory() / 1024 / 1024) + " mb");
|
|
|
-
|
|
|
- sb.append("\n");
|
|
|
- sb.append("\n## Class Path Information ##\n");
|
|
|
- String cp = System.getProperty("java.class.path");
|
|
|
- String[] libs = cp.split(File.pathSeparator);
|
|
|
- for (String lib : libs)
|
|
|
- {
|
|
|
- sb.append(lib);
|
|
|
- sb.append("\n");
|
|
|
- }
|
|
|
-
|
|
|
- sb.append("\n");
|
|
|
- sb.append("## Threads Information ##\n");
|
|
|
- Map<Thread, StackTraceElement[]> allThread = Thread.getAllStackTraces();
|
|
|
-
|
|
|
- FastTable<Entry<Thread, StackTraceElement[]>> entries = new FastTable<Entry<Thread, StackTraceElement[]>>();
|
|
|
- entries.setValueComparator(new FastComparator<Entry<Thread, StackTraceElement[]>>()
|
|
|
- {
|
|
|
-
|
|
|
- @Override
|
|
|
- public boolean areEqual(Entry<Thread, StackTraceElement[]> e1, Entry<Thread, StackTraceElement[]> e2)
|
|
|
- {
|
|
|
- return e1.getKey().getName().equals(e2.getKey().getName());
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int compare(Entry<Thread, StackTraceElement[]> e1, Entry<Thread, StackTraceElement[]> e2)
|
|
|
- {
|
|
|
- return e1.getKey().getName().compareTo(e2.getKey().getName());
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int hashCodeOf(Entry<Thread, StackTraceElement[]> e)
|
|
|
- {
|
|
|
- return e.hashCode();
|
|
|
- }
|
|
|
-
|
|
|
- });
|
|
|
- entries.addAll(allThread.entrySet());
|
|
|
- entries.sort();
|
|
|
- for (Entry<Thread, StackTraceElement[]> entry : entries)
|
|
|
- {
|
|
|
- StackTraceElement[] stes = entry.getValue();
|
|
|
- Thread t = entry.getKey();
|
|
|
- sb.append("--------------\n");
|
|
|
- sb.append(t.toString() + " (" + t.getId() + ")\n");
|
|
|
- sb.append("State: " + t.getState() + "\n");
|
|
|
- sb.append("isAlive: " + t.isAlive() + " | isDaemon: " + t.isDaemon() + " | isInterrupted: " + t.isInterrupted() + "\n");
|
|
|
- sb.append("\n");
|
|
|
- for (StackTraceElement ste : stes)
|
|
|
- {
|
|
|
- sb.append(ste.toString());
|
|
|
- sb.append("\n");
|
|
|
- }
|
|
|
- sb.append("\n");
|
|
|
- }
|
|
|
-
|
|
|
- sb.append("\n");
|
|
|
- this.checkForDeadlocks(sb);
|
|
|
-
|
|
|
- sb.append("\n\n## Thread Pool Manager Statistics ##\n");
|
|
|
- for (String line : ThreadPoolManager.getInstance().getStats())
|
|
|
- {
|
|
|
- sb.append(line);
|
|
|
- sb.append("\n");
|
|
|
- }
|
|
|
-
|
|
|
- int i = 0;
|
|
|
- File f = new File("./log/Debug-" + i + ".txt");
|
|
|
- while (f.exists())
|
|
|
- {
|
|
|
- i++;
|
|
|
- f = new File("./log/Debug-" + i + ".txt");
|
|
|
- }
|
|
|
- f.getParentFile().mkdirs();
|
|
|
- FileOutputStream fos = new FileOutputStream(f);
|
|
|
- OutputStreamWriter out = new OutputStreamWriter(fos, "UTF-8");
|
|
|
- out.write(sb.toString());
|
|
|
- out.flush();
|
|
|
- out.close();
|
|
|
- fos.close();
|
|
|
-
|
|
|
- _print.println("Debug output saved to log/" + f.getName());
|
|
|
- _print.flush();
|
|
|
- }
|
|
|
-
|
|
|
- private void checkForDeadlocks(StringBuilder sb)
|
|
|
- {
|
|
|
- ThreadMXBean mbean = ManagementFactory.getThreadMXBean();
|
|
|
- long[] ids = findDeadlockedThreads(mbean);
|
|
|
- if (ids != null && ids.length > 0)
|
|
|
- {
|
|
|
- Thread[] threads = new Thread[ids.length];
|
|
|
- for (int i = 0; i < threads.length; i++)
|
|
|
- {
|
|
|
- threads[i] = findMatchingThread(mbean.getThreadInfo(ids[i]));
|
|
|
- }
|
|
|
- sb.append("Deadlocked Threads:\n");
|
|
|
- sb.append("-------------------\n");
|
|
|
- for (Thread thread : threads)
|
|
|
- {
|
|
|
- System.err.println(thread);
|
|
|
- for (StackTraceElement ste : thread.getStackTrace())
|
|
|
- {
|
|
|
- sb.append("\t" + ste);
|
|
|
- sb.append("\n");
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private long[] findDeadlockedThreads(ThreadMXBean mbean)
|
|
|
- {
|
|
|
- // JDK 1.5 only supports the findMonitorDeadlockedThreads()
|
|
|
- // method, so you need to comment out the following three lines
|
|
|
- if (mbean.isSynchronizerUsageSupported())
|
|
|
- {
|
|
|
- return mbean.findDeadlockedThreads();
|
|
|
- }
|
|
|
- return mbean.findMonitorDeadlockedThreads();
|
|
|
- }
|
|
|
-
|
|
|
- private Thread findMatchingThread(ThreadInfo inf)
|
|
|
- {
|
|
|
- for (Thread thread : Thread.getAllStackTraces().keySet())
|
|
|
- {
|
|
|
- if (thread.getId() == inf.getThreadId())
|
|
|
- {
|
|
|
- return thread;
|
|
|
- }
|
|
|
- }
|
|
|
- throw new IllegalStateException("Deadlocked Thread not found");
|
|
|
- }
|
|
|
}
|