Fix Tree of Life rank 8 hireling repositioning

.gitignore

@@ -24,3 +24,5 @@
 hs_err_pid*
 replay_pid*
 
+.idea/
+*.iml

src/engine/devcmd/cmds/AddGoldCmd.java

@@ -14,6 +14,7 @@ import engine.gameManager.ChatManager;
 import engine.objects.AbstractGameObject;
 import engine.objects.Item;
 import engine.objects.PlayerCharacter;
+import engine.server.MBServerStatics;
 
 /**
  * @author Eighty
@@ -46,10 +47,10 @@ public class AddGoldCmd extends AbstractDevCmd {
             throwbackError(pc, "Quantity must be a number, " + words[0] + " is invalid");
             return;
         }
-        if (amt < 1 || amt > 10000000) {
-            throwbackError(pc, "Quantity must be between 1 and 10000000 (10 million)");
+        if (amt < 1 || amt > MBServerStatics.PLAYER_GOLD_LIMIT) {
+            throwbackError(pc, "Quantity must be between 1 and " + MBServerStatics.PLAYER_GOLD_LIMIT);
             return;
-        } else if ((curAmt + amt) > 10000000) {
+        } else if ((curAmt + amt) > MBServerStatics.PLAYER_GOLD_LIMIT) {
             throwbackError(pc, "This would place your inventory over 10,000,000 gold.");
             return;
         }

src/engine/devcmd/cmds/MakeItemCmd.java

@@ -16,6 +16,7 @@ import engine.devcmd.AbstractDevCmd;
 import engine.gameManager.DbManager;
 import engine.objects.*;
 import engine.powers.EffectsBase;
+import engine.server.MBServerStatics;
 
 import java.util.ArrayList;
 
@@ -31,47 +32,82 @@ public class MakeItemCmd extends AbstractDevCmd {
     @Override
     protected void _doCmd(PlayerCharacter pc, String[] words,
                           AbstractGameObject target) {
-
         if (words[0].equals("resources")) {
+
+            int resourceAmount = 1000;
+
+            if (words.length > 1) {
+                try {
+                    resourceAmount = Integer.parseInt(words[1]);
+                } catch (NumberFormatException e) {
+                    throwbackError(pc, "Resource amount must be a number.");
+                    return;
+                }
+            }
+
+            if (resourceAmount < 1)
+                resourceAmount = 1;
+
+            resourceAmount = Math.min(
+                    resourceAmount,
+                    MBServerStatics.RESOURCE_STACK_LIMIT
+            );
+
             for (int ibID : Warehouse.getMaxResources().keySet()) {
+
                 if (ibID == 7)
                     continue;
 
                 ItemBase ib = ItemBase.getItemBase(ibID);
 
-                short weight = ib.getWeight();
-                if (!pc.getCharItemManager().hasRoomInventory(weight)) {
-                    throwbackError(pc, "Not enough room in inventory for any more of this item");
+                if (ib == null)
+                    continue;
 
+                short weight = ib.getWeight();
+
+                if (!pc.getCharItemManager().hasRoomInventory(weight)) {
+                    throwbackError(pc, "Not enough room in inventory for any more resources.");
                     pc.getCharItemManager().updateInventory();
                     return;
                 }
 
-                boolean worked = false;
-                Item item = new Item(ib, pc.getObjectUUID(),
-                        OwnerType.PlayerCharacter, (byte) 0, (byte) 0, (short) ib.getDurability(), (short) ib.getDurability(),
-                        true, false, ItemContainerType.INVENTORY, (byte) 0,
-                        new ArrayList<>(), "");
+                Item item = new Item(
+                        ib,
+                        pc.getObjectUUID(),
+                        OwnerType.PlayerCharacter,
+                        (byte) 0,
+                        (byte) 0,
+                        (short) ib.getDurability(),
+                        (short) ib.getDurability(),
+                        true,
+                        false,
+                        ItemContainerType.INVENTORY,
+                        (byte) 0,
+                        new ArrayList<>(),
+                        ""
+                );
 
-                item.setNumOfItems(Warehouse.getMaxResources().get(ibID));
+                item.setNumOfItems(resourceAmount);
 
                 try {
                     item = DbManager.ItemQueries.ADD_ITEM(item);
-                    worked = true;
                 } catch (Exception e) {
-                    throwbackError(pc, "DB error 1: Unable to create item. " + e.getMessage());
+                    throwbackError(
+                            pc,
+                            "Unable to create resource " + ib.getName() + ": " + e.getMessage()
+                    );
                     return;
                 }
 
-                if (item == null || !worked) {
-                    throwbackError(pc, "DB error 2: Unable to create item.");
+                if (item == null) {
+                    throwbackError(pc, "Unable to create resource " + ib.getName() + ".");
                     return;
                 }
 
-
-                //add item to inventory
                 pc.getCharItemManager().addItemToInventory(item);
             }
+
+            pc.getCharItemManager().updateInventory();
             return;
         }
         if (words.length < 3 || words.length > 5) {
@@ -100,7 +136,7 @@ public class MakeItemCmd extends AbstractDevCmd {
                 return;
             }
             numItems = (numItems < 1) ? 1 : numItems;
-            numItems = (numItems > 5000) ? 5000 : numItems;
+            numItems = Math.min(numItems, MBServerStatics.RESOURCE_STACK_LIMIT);
         }
 
         int itembaseID;

src/engine/devcmd/cmds/ShutdownCmd.java

@@ -1,84 +0,0 @@
-// • ▌ ▄ ·.  ▄▄▄·  ▄▄ • ▪   ▄▄· ▄▄▄▄·  ▄▄▄·  ▐▄▄▄  ▄▄▄ .
-// ·██ ▐███▪▐█ ▀█ ▐█ ▀ ▪██ ▐█ ▌▪▐█ ▀█▪▐█ ▀█ •█▌ ▐█▐▌·
-// ▐█ ▌▐▌▐█·▄█▀▀█ ▄█ ▀█▄▐█·██ ▄▄▐█▀▀█▄▄█▀▀█ ▐█▐ ▐▌▐▀▀▀
-// ██ ██▌▐█▌▐█ ▪▐▌▐█▄▪▐█▐█▌▐███▌██▄▪▐█▐█ ▪▐▌██▐ █▌▐█▄▄▌
-// ▀▀  █▪▀▀▀ ▀  ▀ ·▀▀▀▀ ▀▀▀·▀▀▀ ·▀▀▀▀  ▀  ▀ ▀▀  █▪ ▀▀▀
-//      Magicbane Emulator Project © 2013 - 2022
-//                www.magicbane.com
-
-
-package engine.devcmd.cmds;
-
-import engine.devcmd.AbstractDevCmd;
-import engine.gameManager.GracefulShutdown;
-import engine.objects.AbstractGameObject;
-import engine.objects.PlayerCharacter;
-
-/**
- * Devcmd: graceful shutdown.
- *
- * Announces a countdown to every player, writes all online characters to the
- * database (skills/powers, stat modifiers, experience) and then stops the
- * login and world servers. Unlike './reboot' - which simply runs mbrestart.sh
- * and therefore kills the JVMs with SIGKILL - nothing still parked in a
- * deferred database job is lost.
- *
- * Usage: ./shutdown [seconds]  (default 60, maximum 3600)
- */
-public class ShutdownCmd extends AbstractDevCmd {
-
-    private static final int DEFAULT_DELAY_SECONDS = 60;
-    private static final int MAX_DELAY_SECONDS = 3600;
-
-    public ShutdownCmd() {
-        super("shutdown");
-    }
-
-    @Override
-    protected void _doCmd(PlayerCharacter pcSender, String[] args, AbstractGameObject target) {
-
-        int delay = DEFAULT_DELAY_SECONDS;
-
-        if (args.length > 0 && args[0].isEmpty() == false) {
-            try {
-                delay = Integer.parseInt(args[0].trim());
-            } catch (NumberFormatException e) {
-                this.sendUsage(pcSender);
-                return;
-            }
-        }
-
-        if (delay < 0)
-            delay = 0;
-
-        if (delay > MAX_DELAY_SECONDS)
-            delay = MAX_DELAY_SECONDS;
-
-        throwbackInfo(pcSender, "Graceful shutdown started: player data will be saved in " + delay + " second(s).");
-
-        final int delaySeconds = delay;
-
-        // The countdown sleeps, so run it off the message handling thread.
-
-        Thread shutdownThread = new Thread(new Runnable() {
-
-            @Override
-            public void run() {
-                GracefulShutdown.gracefulStop(delaySeconds);
-            }
-        }, "gracefulShutdown");
-
-        shutdownThread.setDaemon(false);
-        shutdownThread.start();
-    }
-
-    @Override
-    protected String _getHelpString() {
-        return "Gracefully shuts the server down: warns the players, saves every online character, then stops the servers";
-    }
-
-    @Override
-    protected String _getUsageString() {
-        return "' /shutdown [seconds]'";
-    }
-}

src/engine/devcmd/cmds/SlotTestCmd.java

@@ -39,6 +39,13 @@ public class SlotTestCmd extends AbstractDevCmd {
 
         Building building = (Building) target;
 
+        outString += "Rank: " + building.getRank() + "\r\n";
+        outString += "MaxSlots: " + building.getBlueprint().getMaxSlots() + "\r\n";
+        outString += "SlotsForRank: "
+                + building.getBlueprint().getSlotsForRank(building.getRank())
+                + "\r\n";
+        outString += "Hireling Count: " + building.getHirelings().size() + "\r\n\r\n";
+
         buildingLocations = BuildingManager._slotLocations.get(building.meshUUID);
 
         if (buildingLocations == null) {

src/engine/gameManager/BuildingManager.java

@@ -289,6 +289,34 @@ public enum BuildingManager {
 
     // Method transfers ownership of all hirelings in a building
 
+    public static void reslotHirelings(Building building) {
+
+        if (building == null)
+            return;
+
+        ArrayList<AbstractCharacter> hirelings =
+                new ArrayList<>(building.getHirelings().keySet());
+
+        building.getHirelings().clear();
+
+        for (AbstractCharacter hireling : hirelings) {
+
+            int newSlot = NPCManager.slotCharacterInBuilding(hireling);
+
+            if (newSlot == -1) {
+                Logger.error("Unable to re-slot hireling "
+                        + hireling.getObjectUUID()
+                        + " for building "
+                        + building.getObjectUUID());
+                continue;
+            }
+
+            hireling.setLoc(hireling.getBindLoc());
+            WorldGrid.updateObject(hireling);
+            InterestManager.setObjectDirty(hireling);
+        }
+    }
+
     public static void refreshHirelings(Building building) {
 
         if (building == null)

src/engine/gameManager/DevCmdManager.java

@@ -123,7 +123,6 @@ public enum DevCmdManager {
         DevCmdManager.registerDevCmd(new ShowOffsetCmd());
         DevCmdManager.registerDevCmd(new RealmInfoCmd());
         DevCmdManager.registerDevCmd(new RebootCmd());
-        DevCmdManager.registerDevCmd(new ShutdownCmd());
         DevCmdManager.registerDevCmd(new SetMineTypeCmd());
         DevCmdManager.registerDevCmd(new SetMineExpansion());
         DevCmdManager.registerDevCmd(new SetForceRenameCityCmd());

src/engine/gameManager/GracefulShutdown.java

@@ -1,202 +0,0 @@
-// • ▌ ▄ ·.  ▄▄▄·  ▄▄ • ▪   ▄▄· ▄▄▄▄·  ▄▄▄·  ▐▄▄▄  ▄▄▄ .
-// ·██ ▐███▪▐█ ▀█ ▐█ ▀ ▪██ ▐█ ▌▪▐█ ▀█▪▐█ ▀█ •█▌ ▐█▐▌·
-// ▐█ ▌▐▌▐█·▄█▀▀█ ▄█ ▀█▄▐█·██ ▄▄▐█▀▀█▄▄█▀▀█ ▐█▐ ▐▌▐▀▀▀
-// ██ ██▌▐█▌▐█ ▪▐▌▐█▄▪▐█▐█▌▐███▌██▄▪▐█▐█ ▪▐▌██▐ █▌▐█▄▄▌
-// ▀▀  █▪▀▀▀ ▀  ▀ ·▀▀▀▀ ▀▀▀·▀▀▀ ·▀▀▀▀  ▀  ▀ ▀▀  █▪ ▀▀▀
-//      Magicbane Emulator Project © 2013 - 2022
-//                www.magicbane.com
-
-
-package engine.gameManager;
-
-import engine.objects.PlayerCharacter;
-import engine.util.ThreadUtils;
-import org.pmw.tinylog.Logger;
-
-import java.util.ArrayList;
-import java.util.concurrent.atomic.AtomicBoolean;
-
-/**
- * Graceful shutdown support.
- *
- * The stock devops scripts stop the game with SIGKILL (mbkill.sh runs
- * 'kill -9'), which throws away everything still parked in a character's
- * deferred database job: experience is written five minutes after it is
- * earned and stats/skills thirty seconds after they change
- * (see {@link engine.jobs.DatabaseUpdateJob}). This class adds the missing
- * write-out:
- *
- * <ul>
- * <li>{@link #flushAllPlayers()} writes every online character's pending state
- * (skills/powers, stat modifiers, experience) immediately.</li>
- * <li>{@link #registerShutdownHook(String)} makes an orderly SIGTERM flush
- * before the JVM exits. SIGKILL cannot be intercepted by design, so it is
- * still the operator's job to log the players out first, or to use
- * {@link #gracefulStop(int)}.</li>
- * <li>{@link #gracefulStop(int)} announces a countdown to the players, flushes
- * them and then stops the login and world servers.</li>
- * </ul>
- */
-public class GracefulShutdown {
-
-    private static final AtomicBoolean flushing = new AtomicBoolean(false);
-    private static final AtomicBoolean stopping = new AtomicBoolean(false);
-
-    // Countdown marks, in seconds remaining, that are announced to the players.
-
-    private static final int[] ANNOUNCE_MARKS = {300, 180, 120, 60, 30, 10, 5, 3, 1};
-
-    /**
-     * Write every online character's deferred state to the database now.
-     * Idempotent and safe to call from a shutdown hook or repeatedly.
-     *
-     * @return the number of characters that were written successfully
-     */
-    public static int flushAllPlayers() {
-
-        if (flushing.compareAndSet(false, true) == false) {
-            Logger.warn("GracefulShutdown: a flush is already in progress, skipping");
-            return 0;
-        }
-
-        int saved = 0;
-        int failed = 0;
-
-        try {
-            ArrayList<PlayerCharacter> online = new ArrayList<>(SessionManager.getAllActivePlayerCharacters());
-
-            Logger.info("GracefulShutdown: flushing " + online.size() + " online character(s)");
-
-            for (PlayerCharacter pc : online) {
-
-                if (pc == null)
-                    continue;
-
-                try {
-                    pc.updateSkillsAndPowersToDatabase();
-                    DbManager.PlayerCharacterQueries.UPDATE_CHARACTER_STATS(pc);
-                    DbManager.PlayerCharacterQueries.UPDATE_CHARACTER_EXPERIENCE(pc);
-                    saved++;
-                    Logger.info("GracefulShutdown: saved " + pc.getCombinedName() + " (" + pc.getObjectUUID() + ')');
-                } catch (Exception e) {
-                    failed++;
-                    Logger.error("GracefulShutdown: could not save character " + pc.getObjectUUID() + ": " + e);
-                }
-            }
-
-            Logger.info("GracefulShutdown: flush finished, saved=" + saved + " failed=" + failed);
-            System.out.println("GracefulShutdown: flush finished, saved=" + saved + " failed=" + failed);
-
-        } catch (Exception e) {
-            Logger.error("GracefulShutdown: flush aborted: " + e);
-        } finally {
-            flushing.set(false);
-        }
-
-        return saved;
-    }
-
-    /**
-     * Broadcast a system-wide flash message to every player.
-     *
-     * @param text - message to display
-     */
-    public static void announce(String text) {
-
-        if (text == null || text.isEmpty())
-            return;
-
-        try {
-            ChatManager.chatSystemFlash(text);
-            Logger.info("GracefulShutdown: announced '" + text + '\'');
-        } catch (Exception e) {
-            Logger.error("GracefulShutdown: unable to announce: " + e);
-        }
-    }
-
-    /**
-     * Register the JVM shutdown hook used by an orderly SIGTERM
-     * (kill -TERM on the process, i.e. the signal the servers currently never
-     * receive). The hook flushes every online character before the JVM exits.
-     *
-     * @param serverName - name used in the log lines
-     */
-    public static void registerShutdownHook(final String serverName) {
-
-        try {
-            Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
-
-                @Override
-                public void run() {
-                    Logger.info("GracefulShutdown: " + serverName + " is terminating, flushing player data");
-                    System.out.println("GracefulShutdown: " + serverName + " is terminating, flushing player data");
-                    flushAllPlayers();
-                    Logger.info("GracefulShutdown: " + serverName + " shutdown hook finished");
-                    System.out.println("GracefulShutdown: " + serverName + " shutdown hook finished");
-                }
-            }, "gracefulShutdownHook"));
-
-            Logger.info("GracefulShutdown: shutdown hook registered for " + serverName);
-            System.out.println("GracefulShutdown: shutdown hook registered for " + serverName);
-
-        } catch (Exception e) {
-            Logger.error("GracefulShutdown: unable to register shutdown hook: " + e);
-        }
-    }
-
-    /**
-     * Announce a countdown, flush every online character and then stop the
-     * login and world servers. Only the first call has any effect.
-     *
-     * @param delaySeconds - seconds to wait before saving and stopping
-     *                     (0 stops immediately)
-     */
-    public static void gracefulStop(final int delaySeconds) {
-
-        if (stopping.compareAndSet(false, true) == false) {
-            Logger.warn("GracefulShutdown: a shutdown is already in progress");
-            return;
-        }
-
-        int remaining = Math.max(0, delaySeconds);
-
-        announce("Server is shutting down in " + remaining + " seconds. Please log out to save your character.");
-
-        while (remaining > 0) {
-
-            ThreadUtils.sleep(1000);
-            remaining--;
-
-            for (int mark : ANNOUNCE_MARKS)
-                if (mark == remaining)
-                    announce("Server is shutting down in " + remaining + " second(s).");
-        }
-
-        announce("Server is shutting down now. Saving all characters...");
-
-        flushAllPlayers();
-
-        stopServers();
-    }
-
-    /**
-     * Stop the login and world server processes the same way the devops
-     * scripts do. Called only after every character has been written out.
-     */
-    private static void stopServers() {
-
-        try {
-            Logger.info("GracefulShutdown: stopping the login and world servers");
-            System.out.println("GracefulShutdown: player data saved, stopping the login and world servers");
-            Runtime.getRuntime().exec("./mbkill.sh");
-        } catch (Exception e) {
-            Logger.error("GracefulShutdown: unable to run mbkill.sh: " + e);
-        }
-
-        // Give the script a moment to stop the login server before this JVM disappears.
-
-        ThreadUtils.sleep(2000);
-
-        System.exit(0);
-    }
-}

src/engine/mobileAI/Threads/MobAIThread.java

@@ -14,21 +14,6 @@ public class MobAIThread implements Runnable{
     public static int AI_PULSE_MOB_THRESHOLD = 200;
     public static int AI_PATROL_DIVISOR = 15;
     public static float AI_CAST_FREQUENCY;
-
-    /**
-     * Fixed-rate pacing for one full AI pass, in milliseconds (default 10 passes
-     * per second).
-     *
-     * The pass used to run with no delay whatsoever - `while (true)` straight into
-     * a sweep of every zone and every mob - which pinned one core for the entire
-     * lifetime of the world server (~100% of a core even in an empty world, two
-     * cores together with MobRespawnThread). Individual actions inside
-     * MobAI.DetermineAction are already gated by timestamps (lastAttackTime,
-     * nextCastTime, patrol delays), so running the sweep at a fixed rate removes
-     * the busy spin without changing behaviour. Raise this value to trade AI
-     * reaction time for CPU.
-     */
-    public static int AI_TICK_INTERVAL_MS = 100;
     // Thread constructor
 
     public MobAIThread() {
@@ -42,9 +27,6 @@ public class MobAIThread implements Runnable{
         AI_CAST_FREQUENCY = Float.parseFloat(ConfigManager.MB_AI_CAST_FREQUENCY.getValue());
         AI_BASE_AGGRO_RANGE = (int)(60 * Float.parseFloat(ConfigManager.MB_AI_AGGRO_RANGE.getValue()));
         while (true) {
-
-            long tickStart = System.currentTimeMillis();
-
             for (Zone zone : ZoneManager.getAllZones()) {
 
                 for (Mob mob : zone.zoneMobSet) {
@@ -58,16 +40,6 @@ public class MobAIThread implements Runnable{
                     }
                 }
             }
-
-            long sleep = AI_TICK_INTERVAL_MS - (System.currentTimeMillis() - tickStart);
-
-            if (sleep > 0) {
-                try {
-                    Thread.sleep(sleep);
-                } catch (InterruptedException ie) {
-                    return;
-                }
-            }
         }
     }
     public static void startAIThread() {

src/engine/mobileAI/Threads/MobRespawnThread.java

@@ -25,13 +25,6 @@ import org.pmw.tinylog.Logger;
 
 public class MobRespawnThread implements Runnable {
 
-    /**
-     * Fixed-rate pacing for one respawn sweep, in milliseconds. The sweep used to
-     * run with no delay at all, pinning a core for the lifetime of the world server
-     * (the 100 ms check below only throttles how often a mob may actually respawn,
-     * it never paused the loop). Keep this at or below the 100 ms respawn throttle.
-     */
-    public static int RESPAWN_TICK_INTERVAL_MS = 100;
 
     public MobRespawnThread() {
         Logger.info(" MobRespawnThread thread has started!");
@@ -43,8 +36,6 @@ public class MobRespawnThread implements Runnable {
 
         while (true) {
 
-            long tickStart = System.currentTimeMillis();
-
             try {
                 for (Zone zone : ZoneManager.getAllZones()) {
 
@@ -64,15 +55,6 @@ public class MobRespawnThread implements Runnable {
                 Logger.error(e);
             }
 
-            long sleep = RESPAWN_TICK_INTERVAL_MS - (System.currentTimeMillis() - tickStart);
-
-            if (sleep > 0) {
-                try {
-                    Thread.sleep(sleep);
-                } catch (InterruptedException ie) {
-                    return;
-                }
-            }
         }
     }
     public static void startRespawnThread() {

src/engine/net/client/ClientMessagePump.java

@@ -1259,7 +1259,7 @@ public class ClientMessagePump implements NetMsgHandler {
 
                 cost *= profit;
 
-                if (gold.getNumOfItems() + cost > 10000000) {
+                if (gold.getNumOfItems() + cost > MBServerStatics.PLAYER_GOLD_LIMIT) {
                     return;
                 }
 

src/engine/objects/Blueprint.java

@@ -335,7 +335,7 @@ public class Blueprint {
                 availableSlots = 3;
                 break;
             case 8:
-                availableSlots = 1;
+                availableSlots = Math.min(3, this.maxSlots);
                 break;
             default:
                 availableSlots = 0;

src/engine/objects/Building.java

@@ -427,6 +427,10 @@ public class Building extends AbstractWorldObject {
 
         BuildingManager.cleanupHirelings(this);
 
+        if (this.getBlueprint().getBuildingGroup() == BuildingGroup.TOL
+                && this.rank == 8)
+            BuildingManager.reslotHirelings(this);
+
         this.isDeranking.compareAndSet(true, false);
     }
 

src/engine/objects/CharacterItemManager.java

@@ -2335,15 +2335,14 @@ public class CharacterItemManager {
         }
 
 
-        if (this.getGoldInventory().getNumOfItems() + goldFrom2 > 10000000) {
+        if (this.getGoldInventory().getNumOfItems() + goldFrom2 > MBServerStatics.PLAYER_GOLD_LIMIT) {
             PlayerCharacter pc = (PlayerCharacter) this.absCharacter;
             if (pc.getClientConnection() != null)
                 ErrorPopupMsg.sendErrorPopup(pc, 202);
             return false;
         }
 
-
-        if (tradingWith.getGoldInventory().getNumOfItems() + goldFrom1 > 10000000) {
+        if (tradingWith.getGoldInventory().getNumOfItems() + goldFrom1 > MBServerStatics.PLAYER_GOLD_LIMIT) {
             PlayerCharacter pc = (PlayerCharacter) tradingWith.absCharacter;
             if (pc.getClientConnection() != null)
                 ErrorPopupMsg.sendErrorPopup(pc, 202);

src/engine/objects/Item.java

@@ -674,46 +674,6 @@ public class Item extends AbstractWorldObject {
     public static Item newGoldItem(AbstractWorldObject awo, ItemBase ib, Enum.ItemContainerType containerType) {
         return newGoldItem(awo, ib, containerType, true);
     }
-
-    //used for vault!
-    public static Item newGoldItem(int accountID, ItemBase ib, Enum.ItemContainerType containerType) {
-        return newGoldItem(accountID, ib, containerType, true);
-    }
-
-    private static Item newGoldItem(int accountID, ItemBase ib, Enum.ItemContainerType containerType, boolean persist) {
-
-        int ownerID;
-        OwnerType ownerType;
-
-        ownerID = accountID;
-        ownerType = OwnerType.Account;
-
-
-        Item newGold = new Item(ib, ownerID, ownerType,
-                (byte) 0, (byte) 0, (short) 0, (short) 0, true, false, containerType, (byte) 0,
-                new ArrayList<>(), "");
-
-        synchronized (newGold) {
-            newGold.numberOfItems = 0;
-        }
-
-        if (persist) {
-            try {
-                newGold = DbManager.ItemQueries.ADD_ITEM(newGold);
-                if (newGold != null) {
-                    synchronized (newGold) {
-                        newGold.numberOfItems = 0;
-                    }
-                }
-            } catch (Exception e) {
-                Logger.error(e);
-            }
-            DbManager.ItemQueries.ZERO_ITEM_STACK(newGold);
-        }
-
-        return newGold;
-    }
-
     private static Item newGoldItem(AbstractWorldObject awo, ItemBase ib, Enum.ItemContainerType containerType, boolean persist) {
 
         int ownerID;
@@ -771,10 +731,49 @@ public class Item extends AbstractWorldObject {
             }
             DbManager.ItemQueries.ZERO_ITEM_STACK(newGold);
         }
+
         newGold.containerType = containerType;
 
         return newGold;
     }
+    //used for vault!
+    public static Item newGoldItem(int accountID, ItemBase ib, Enum.ItemContainerType containerType) {
+        return newGoldItem(accountID, ib, containerType, true);
+    }
+
+    private static Item newGoldItem(int accountID, ItemBase ib, Enum.ItemContainerType containerType, boolean persist) {
+
+        int ownerID;
+        OwnerType ownerType;
+
+        ownerID = accountID;
+        ownerType = OwnerType.Account;
+
+
+        Item newGold = new Item(ib, ownerID, ownerType,
+                (byte) 0, (byte) 0, (short) 0, (short) 0, true, false, containerType, (byte) 0,
+                new ArrayList<>(), "");
+
+        synchronized (newGold) {
+            newGold.numberOfItems = 0;
+        }
+
+        if (persist) {
+            try {
+                newGold = DbManager.ItemQueries.ADD_ITEM(newGold);
+                if (newGold != null) {
+                    synchronized (newGold) {
+                        newGold.numberOfItems = 0;
+                    }
+                }
+            } catch (Exception e) {
+                Logger.error(e);
+            }
+            DbManager.ItemQueries.ZERO_ITEM_STACK(newGold);
+        }
+
+        return newGold;
+    }
 
     // This is to be used for trades - the new item is not stored in the database
     public static Item newGoldItemTemp(AbstractWorldObject awo, ItemBase ib) {

src/engine/objects/PlayerCharacter.java

@@ -1239,12 +1239,17 @@ public class PlayerCharacter extends AbstractCharacter {
             playerCharacter.deactivateCharacter();
             return null;
         }
+        // Ebonreach: give new characters starter gold.
+        Item starterGold = Item.newGoldItem(playerCharacter, ItemBase.getItemBase(7), Enum.ItemContainerType.INVENTORY);
+
+        if (starterGold != null)
+            DbManager.ItemQueries.UPDATE_GOLD(starterGold, 10000);
 
         // Get any new skills that belong to the player
         playerCharacter.calculateSkills();
 
         a.setLastCharacter(playerCharacter.getObjectUUID());
-        playerCharacter.charItemManager.load();
+        playerCharacter.getCharItemManager().load();
 
         playerCharacter.activateCharacter();
 

src/engine/objects/Warehouse.java

@@ -99,29 +99,29 @@ public class Warehouse extends AbstractWorldObject {
 
     public static ConcurrentHashMap<Integer, Integer> getMaxResources() {
         if (maxResources.size() != 23) {
-            maxResources.put(7, 100000000);
-            maxResources.put(1580000, 10000);
-            maxResources.put(1580001, 2000);
-            maxResources.put(1580002, 2000);
-            maxResources.put(1580003, 1000);
-            maxResources.put(1580004, 10000);
-            maxResources.put(1580005, 3000);
-            maxResources.put(1580006, 3000);
-            maxResources.put(1580007, 1000);
-            maxResources.put(1580008, 3000);
-            maxResources.put(1580009, 2000);
-            maxResources.put(1580010, 2000);
-            maxResources.put(1580011, 1000);
-            maxResources.put(1580012, 2000);
-            maxResources.put(1580013, 3000);
-            maxResources.put(1580014, 1000);
-            maxResources.put(1580015, 1000);
-            maxResources.put(1580016, 1000);
-            maxResources.put(1580017, 500);
-            maxResources.put(1580018, 500);
-            maxResources.put(1580019, 500);
-            maxResources.put(1580020, 500);
-            maxResources.put(1580021, 500);
+            maxResources.put(7, 1000000000);
+            maxResources.put(1580000, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580001, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580002, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580003, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580004, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580005, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580006, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580007, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580008, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580009, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580010, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580011, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580012, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580013, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580014, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580015, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580016, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580017, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580018, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580019, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580020, MBServerStatics.RESOURCE_STACK_LIMIT);
+            maxResources.put(1580021, MBServerStatics.RESOURCE_STACK_LIMIT);
         }
 
         return maxResources;

src/engine/server/MBServerStatics.java

@@ -33,15 +33,16 @@ public class MBServerStatics {
     // hit box
     // calcs
     public static final boolean PRINT_INCOMING_OPCODES = false; // print
-    public static final int BANK_GOLD_LIMIT = 25000000;
+    public static final int BANK_GOLD_LIMIT = 1000000000;
     // incoming
     // opcodes to
     // console
-    public static final int PLAYER_GOLD_LIMIT = 10000000;
+    public static final int PLAYER_GOLD_LIMIT = 500000000;
     // buildings, npcs
     /*
      * Login cache flags
      */
+    public static final int RESOURCE_STACK_LIMIT = 1000000000;
     public static final boolean SKIP_CACHE_LOGIN = false; // skip caching														// login server
     public static final boolean SKIP_CACHE_LOGIN_PLAYER = false; // skip caching															// on login
     public static final boolean SKIP_CACHE_LOGIN_ITEM = false; // skip caching

src/engine/server/login/LoginServer.java

@@ -96,11 +96,6 @@ public class LoginServer {
             // Start the Login Server
 
             loginServer.init();
-
-            // flush any cached character state on an orderly termination
-            // (the login server holds no players, so this normally logs 0).
-
-            GracefulShutdown.registerShutdownHook("LoginServer");
             loginServer.exec();
 
             exit(0);
@@ -150,42 +145,29 @@ public class LoginServer {
 
     }
 
-    /**
-     * Returns true when something is already listening on the given TCP port.
-     *
-     * This used to shell out to `lsof -i tcp:<port>` through /bin/bash and read the
-     * child's output until EOF. With no timeout and no waitFor() a child that blocks
-     * is fatal: lsof has been observed stuck in uninterruptible I/O (D state) while
-     * scanning the busy world server inside the container, which left the login
-     * server permanently inside its startup path. LoginServer.exec() never returned
-     * from checkServerHealth(), the accept loop never started, and clients could open
-     * a TCP connection to the port and then wait forever for the 100 byte DH
-     * handshake - surfacing as "Failed to open a server connection" after the
-     * client's own timeout.
-     *
-     * A bind probe is equivalent for this purpose, needs no external tool and cannot
-     * hang. SO_REUSEADDR does not allow stealing a port that is actively listening,
-     * so a successful bind still means the port is free.
-     */
     public static boolean isPortInUse(int port) {
 
-        java.net.ServerSocket probe = null;
+        ProcessBuilder builder = new ProcessBuilder("/bin/bash", "-c", "lsof -i tcp:" + port + " | tail -n +2 | awk '{print $2}'");
+        builder.redirectErrorStream(true);
+        Process process = null;
+        String line = null;
+        boolean portInUse = false;
 
         try {
-            probe = new java.net.ServerSocket();
-            probe.setReuseAddress(true);
-            probe.bind(new java.net.InetSocketAddress(port));
-            return false;
+            process = builder.start();
+
+            InputStream is = process.getInputStream();
+            BufferedReader reader = new BufferedReader(new InputStreamReader(is));
+
+            while ((line = reader.readLine()) != null) {
+                portInUse = true;
+            }
+
         } catch (IOException e) {
-            return true;
-        } finally {
-            if (probe != null)
-                try {
-                    probe.close();
-                } catch (IOException e) {
-                    // the bind result is what matters; closing cannot change it
-                }
+            e.printStackTrace();
         }
+
+        return portInUse;
     }
 
     private void exec() {

src/engine/server/world/WorldServer.java

@@ -109,11 +109,6 @@ public class WorldServer {
 
 			worldServer.init();
 
-			// flush every online character if the JVM is asked to terminate
-			// in an orderly way (kill -TERM); SIGKILL cannot be intercepted.
-
-			GracefulShutdown.registerShutdownHook("WorldServer");
-
 			int retVal = worldServer.exec();
 
 			if (retVal != 0)