Root.cpp

Go to the documentation of this file.

 
#include "Globals.h"  // NOTE: MSVC stupidness requires this to be the same across all modules
 
#include "Root.h"
#include "main.h"
 
// STD lib hreaders:
#include <iostream>
 
// OS-specific headers:
#if defined(_WIN32)
    #include <psapi.h>
#elif defined(__unix__) || (defined(__APPLE__) && defined(__MACH__))
    #include <signal.h>
    #if defined(__linux__)
        #include <fstream>
 
        #if !defined(__GLIBC__)
            #include <sys/select.h>
        #endif
    #elif defined(__APPLE__)
        #include <mach/mach.h>
    #elif defined(__FreeBSD__)
        #include <kvm.h>
        #include <fcntl.h>
        #include <sys/sysctl.h>
        #include <sys/user.h>
    #endif
#endif
 
#include "Server.h"
#include "World.h"
#include "WebAdmin.h"
#include "BrewingRecipes.h"
#include "FurnaceRecipe.h"
#include "CraftingRecipes.h"
#include "Protocol/RecipeMapper.h"
#include "Bindings/PluginManager.h"
#include "MonsterConfig.h"
#include "Entities/Player.h"
#include "Blocks/BlockHandler.h"
#include "Items/ItemHandler.h"
#include "Chunk.h"
#include "Protocol/ProtocolRecognizer.h"  // for protocol version constants
#include "CommandOutput.h"
#include "DeadlockDetect.h"
#include "LoggerListeners.h"
#include "BuildInfo.h"
#include "IniFile.h"
#include "OverridesSettingsRepository.h"
#include "Logger.h"
#include "ClientHandle.h"
 
 
 
 
 
#ifdef __clang__
    #pragma clang diagnostic push
    #pragma clang diagnostic ignored "-Wglobal-constructors"
#endif
 
decltype(cRoot::s_Root)      cRoot::s_Root;
decltype(cRoot::s_NextState) cRoot::s_NextState;
decltype(cRoot::s_StopEvent) cRoot::s_StopEvent;
 
#ifdef __clang__
    #pragma clang diagnostic pop
#endif
 
 
 
 
 
cRoot::cRoot(void) :
    m_pDefaultWorld(nullptr),
    m_Server(nullptr),
    m_MonsterConfig(nullptr),
    m_CraftingRecipes(nullptr),
    m_FurnaceRecipe(nullptr),
    m_BrewingRecipes(nullptr),
    m_WebAdmin(nullptr),
    m_PluginManager(nullptr),
    m_MojangAPI(nullptr)
{
    s_Root = this;
    TransitionNextState(NextState::Run);
}
 
 
 
 
 
cRoot::~cRoot()
{
    s_Root = nullptr;
}
 
 
 
 
 
bool cRoot::Run(cSettingsRepositoryInterface & a_OverridesRepo)
{
    auto consoleLogListener = MakeConsoleListener(g_RunAsService);
    auto consoleAttachment = cLogger::GetInstance().AttachListener(std::move(consoleLogListener));
 
    cLogger::cAttachment fileAttachment;
    if (!a_OverridesRepo.HasValue("Server","DisableLogFile"))
    {
        auto fileLogListenerRet = MakeFileListener();
        if (!fileLogListenerRet.first)
        {
            throw std::runtime_error("failed to open log file");
        }
        fileAttachment = cLogger::GetInstance().AttachListener(std::move(fileLogListenerRet.second));
    }
 
    LOG("--- Started Log ---");
 
#ifdef BUILD_ID
    LOG("Cuberite " BUILD_SERIES_NAME " (id: " BUILD_ID ")");
    LOG("from commit " BUILD_COMMIT_ID " built at: " BUILD_DATETIME);
#endif
 
    cDeadlockDetect dd;
    auto BeginTime = std::chrono::steady_clock::now();
 
    LoadGlobalSettings();
 
    LOG("Creating new server instance...");
    m_Server = new cServer();
 
    LOG("Reading server config...");
 
    m_SettingsFilename = "settings.ini";
    if (a_OverridesRepo.HasValue("Server","ConfigFile"))
    {
        m_SettingsFilename = a_OverridesRepo.GetValue("Server","ConfigFile");
    }
 
    auto IniFile = std::make_unique<cIniFile>();
    bool IsNewIniFile = !IniFile->ReadFile(m_SettingsFilename);
 
    if (IsNewIniFile)
    {
        LOGWARN("Regenerating settings.ini, all settings will be reset");
        IniFile->AddHeaderComment(" This is the main server configuration");
        IniFile->AddHeaderComment(" Most of the settings here can be configured using the webadmin interface, if enabled in webadmin.ini");
    }
 
    auto settingsRepo = std::make_unique<cOverridesSettingsRepository>(std::move(IniFile), a_OverridesRepo);
 
    LOG("Starting server...");
 
    // cClientHandle::FASTBREAK_PERCENTAGE = settingsRepo->GetValueSetI("AntiCheat", "FastBreakPercentage", 97) / 100.0f;
    cClientHandle::FASTBREAK_PERCENTAGE = 0;  // AntiCheat disabled due to bugs. We will enabled it once they are fixed. See #3506.
 
    m_MojangAPI = new cMojangAPI;
    bool ShouldAuthenticate = settingsRepo->GetValueSetB("Authentication", "Authenticate", true);
    m_MojangAPI->Start(*settingsRepo, ShouldAuthenticate);  // Mojang API needs to be started before plugins, so that plugins may use it for DB upgrades on server init
    if (!m_Server->InitServer(*settingsRepo, ShouldAuthenticate))
    {
        settingsRepo->Flush();
        throw std::runtime_error("failure starting server");
    }
 
    m_WebAdmin = new cWebAdmin();
    m_WebAdmin->Init();
 
    LOGD("Loading settings...");
    m_RankManager.reset(new cRankManager());
    m_RankManager->Initialize(*m_MojangAPI);
    m_CraftingRecipes = new cCraftingRecipes();
    m_RecipeMapper.reset(new cRecipeMapper());
    m_FurnaceRecipe   = new cFurnaceRecipe();
    m_BrewingRecipes.reset(new cBrewingRecipes());
 
    LOGD("Loading worlds...");
    LoadWorlds(dd, *settingsRepo, IsNewIniFile);
 
    LOGD("Loading plugin manager...");
    m_PluginManager = new cPluginManager(dd);
    m_PluginManager->ReloadPluginsNow(*settingsRepo);
 
    LOGD("Loading MonsterConfig...");
    m_MonsterConfig = new cMonsterConfig;
 
    // This sets stuff in motion
    LOGD("Starting Authenticator...");
    m_Authenticator.Start(*settingsRepo);
 
    LOGD("Starting worlds...");
    StartWorlds(dd);
 
    if (settingsRepo->GetValueSetB("DeadlockDetect", "Enabled", true))
    {
        LOGD("Starting deadlock detector...");
        dd.Start(settingsRepo->GetValueSetI("DeadlockDetect", "IntervalSec", 20));
    }
 
    settingsRepo->Flush();
 
    LOGD("Finalising startup...");
    if (m_Server->Start())
    {
        m_WebAdmin->Start();
 
        LOG("Startup complete, took %ldms!", static_cast<long int>(std::chrono::duration_cast<std::chrono::milliseconds>(std::chrono::steady_clock::now() - BeginTime).count()));
 
        // Save the current time
        m_StartTime = std::chrono::steady_clock::now();
 
        HandleInput();
        s_StopEvent.Wait();
 
        // Stop the server:
        m_WebAdmin->Stop();
 
        LOG("Shutting down server...");
        m_Server->Shutdown();
    }  // if (m_Server->Start()
 
    delete m_MojangAPI; m_MojangAPI = nullptr;
 
    LOGD("Shutting down deadlock detector...");
    dd.Stop();
 
    LOGD("Stopping world threads...");
    StopWorlds(dd);
 
    LOGD("Stopping authenticator...");
    m_Authenticator.Stop();
 
    LOGD("Freeing MonsterConfig...");
    delete m_MonsterConfig; m_MonsterConfig = nullptr;
    delete m_WebAdmin; m_WebAdmin = nullptr;
 
    LOGD("Unloading recipes...");
    delete m_FurnaceRecipe;   m_FurnaceRecipe = nullptr;
    delete m_CraftingRecipes; m_CraftingRecipes = nullptr;
 
    LOGD("Stopping plugin manager...");
    delete m_PluginManager; m_PluginManager = nullptr;
 
    LOG("Cleaning up...");
    delete m_Server; m_Server = nullptr;
 
    LOG("Shutdown successful!");
    LOG("--- Stopped Log ---");
 
    return s_NextState == NextState::Restart;
}
 
 
 
 
 
void cRoot::Stop()
{
    TransitionNextState(NextState::Stop);
}
 
 
 
 
 
void cRoot::Restart()
{
    TransitionNextState(NextState::Restart);
}
 
 
 
 
 
void cRoot::LoadGlobalSettings()
{
    // Nothing needed yet
}
 
 
 
 
 
void cRoot::LoadWorlds(cDeadlockDetect & a_dd, cSettingsRepositoryInterface & a_Settings, bool a_IsNewIniFile)
{
    if (a_IsNewIniFile)
    {
        a_Settings.AddValue("Worlds", "DefaultWorld", "world");
        a_Settings.AddValue("Worlds", "World", "world_nether");
        a_Settings.AddValue("Worlds", "World", "world_the_end");
        a_Settings.AddValue("WorldPaths", "world", "world");
        a_Settings.AddValue("WorldPaths", "world_nether", "world_nether");
        a_Settings.AddValue("WorldPaths", "world_the_end", "world_the_end");
 
        const AStringVector WorldNames{ "world", "world_nether", "world_the_end" };
        m_pDefaultWorld = &m_WorldsByName.try_emplace("world", "world", "world", a_dd, WorldNames).first->second;
        m_WorldsByName.try_emplace("world_nether", "world_nether", "world_nether", a_dd, WorldNames, dimNether, "world");
        m_WorldsByName.try_emplace("world_the_end", "world_the_end", "world_the_end", a_dd, WorldNames, dimEnd, "world");
        return;
    }
 
    // Build a list of all world names
    auto Worlds = a_Settings.GetValues("Worlds");
    AStringVector WorldNames(Worlds.size());
    for (const auto & World : Worlds)
    {
        WorldNames.push_back(World.second);
    }
 
    // Get the default world
    AString DefaultWorldName = a_Settings.GetValueSet("Worlds", "DefaultWorld", "world");
    AString DefaultWorldPath = a_Settings.GetValueSet("WorldPaths", DefaultWorldName, DefaultWorldName);
    m_pDefaultWorld = &m_WorldsByName.try_emplace(DefaultWorldName, DefaultWorldName, DefaultWorldPath, a_dd, WorldNames).first->second;
 
    // Then load the other worlds
    if (Worlds.size() <= 0)
    {
        return;
    }
 
    /* Here are the world creation rules. Note that these only apply for a world which is in settings.ini but has no world.ini file.
    If an ini file is present, it overrides the world linkages and the dimension type in cWorld::start()
    The creation rules are as follows:
 
    - If a world exists in settings.ini but has no world.ini, then:
        - If the world name is x_nether, create a world.ini with the dimension type "nether".
            - If a world called x exists, set it as x_nether's overworld.
            - Otherwise set the default world as x_nether's overworld.
 
        - If the world name is x_the_end or x_end, create a world.ini with the dimension type "end".
            - If a world called x exists, set it as x_the_end's overworld.
            - Otherwise set the default world as x_the_end's overworld.
 
        - If the world name is x (and doesn't end with _the_end, _end or _nether)
            - Create a world.ini with a dimension type of "overworld".
            - If a world called x_nether exists, set it as x's nether world.
            - Otherwise set x's nether world to blank.h
            - If a world called x_the_end or x_end exists, set it as x's end world.
            - Otherwise set x's nether world to blank.
 
    */
 
    bool FoundAdditionalWorlds = false;
    for (const auto & WorldNameValue : Worlds)
    {
        AString ValueName = WorldNameValue.first;
        if (ValueName.compare("World") != 0)
        {
            continue;
        }
        AString WorldName = WorldNameValue.second;
        if (WorldName.empty())
        {
            continue;
        }
        FoundAdditionalWorlds = true;
        AString LowercaseName = StrToLower(WorldName);
        AString WorldPath = a_Settings.GetValueSet("WorldPaths", WorldName, WorldName);
        AString NetherAppend = "_nether";
        AString EndAppend1 = "_the_end";
        AString EndAppend2 = "_end";
 
        // The default world is an overworld with no links
        eDimension Dimension = dimOverworld;
        AString LinkTo;
 
        // if the world is called x_nether
        if ((LowercaseName.size() > NetherAppend.size()) && (LowercaseName.substr(LowercaseName.size() - NetherAppend.size()) == NetherAppend))
        {
            // The world is called x_nether, see if a world called x exists. If yes, choose it as the linked world,
            // otherwise, choose the default world as the linked world.
            // As before, any ini settings will completely override this if an ini is already present.
 
            LinkTo = WorldName.substr(0, WorldName.size() - NetherAppend.size());
            if (GetWorld(LinkTo) == nullptr)
            {
                LinkTo = DefaultWorldName;
            }
            Dimension = dimNether;
        }
        // if the world is called x_the_end
        else if ((LowercaseName.size() > EndAppend1.size()) && (LowercaseName.substr(LowercaseName.size() - EndAppend1.size()) == EndAppend1))
        {
            // The world is called x_the_end, see if a world called x exists. If yes, choose it as the linked world,
            // otherwise, choose the default world as the linked world.
            // As before, any ini settings will completely override this if an ini is already present.
 
            LinkTo = WorldName.substr(0, WorldName.size() - EndAppend1.size());
            if (GetWorld(LinkTo) == nullptr)
            {
                LinkTo = DefaultWorldName;
            }
            Dimension = dimEnd;
        }
        // if the world is called x_end
        else if ((LowercaseName.size() > EndAppend2.size()) && (LowercaseName.substr(LowercaseName.size() - EndAppend2.size()) == EndAppend2))
        {
            // The world is called x_end, see if a world called x exists. If yes, choose it as the linked world,
            // otherwise, choose the default world as the linked world.
            // As before, any ini settings will completely override this if an ini is already present.
 
            LinkTo = WorldName.substr(0, WorldName.size() - EndAppend2.size());
            if (GetWorld(LinkTo) == nullptr)
            {
                LinkTo = DefaultWorldName;
            }
            Dimension = dimEnd;
        }
        m_WorldsByName.try_emplace(WorldName, WorldName, WorldPath, a_dd, WorldNames, Dimension, LinkTo);
    }  // for i - Worlds
 
    if (!FoundAdditionalWorlds)
    {
        if (a_Settings.GetKeyComment("Worlds", 0) != " World=secondworld")
        {
            a_Settings.DeleteKeyComment("Worlds", 0);
            a_Settings.AddKeyComment("Worlds", " World=secondworld");
        }
    }
}
 
 
 
 
 
void cRoot::StartWorlds(cDeadlockDetect & a_DeadlockDetect)
{
    for (auto & Entry : m_WorldsByName)
    {
        auto & World = Entry.second;
        World.Start();
        World.InitializeSpawn();
        m_PluginManager->CallHookWorldStarted(World);
    }
}
 
 
 
 
 
void cRoot::StopWorlds(cDeadlockDetect & a_DeadlockDetect)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.Stop(a_DeadlockDetect);
    }
}
 
 
 
 
 
cWorld * cRoot::GetDefaultWorld()
{
    ASSERT(m_pDefaultWorld != nullptr);
    return m_pDefaultWorld;
}
 
 
 
 
 
cWorld * cRoot::GetWorld(const AString & a_WorldName)
{
    const auto FindResult = m_WorldsByName.find(a_WorldName);
    if (FindResult != m_WorldsByName.cend())
    {
        return &FindResult->second;
    }
 
    return nullptr;
}
 
 
 
 
 
bool cRoot::ForEachWorld(cWorldListCallback a_Callback)
{
    for (auto & World : m_WorldsByName)
    {
        if (a_Callback(World.second))
        {
            return false;
        }
    }
    return true;
}
 
 
 
 
 
void cRoot::QueueExecuteConsoleCommand(const AString & a_Cmd, cCommandOutputCallback & a_Output)
{
    const auto KickPlayers = [this]
    {
        // Kick all players from the server with custom disconnect message
 
        bool SentDisconnect = false;
        cRoot::Get()->ForEachPlayer(
            [&](cPlayer & a_Player)
            {
                a_Player.GetClientHandle()->Kick(m_Server->GetShutdownMessage());
                SentDisconnect = true;
                return false;
            }
        );
 
        if (SentDisconnect)
        {
            std::this_thread::sleep_for(std::chrono::seconds(1));
        }
    };
 
    // Some commands are built-in:
    if (a_Cmd == "stop")
    {
        KickPlayers();
        cRoot::Stop();
        return;
    }
    else if (a_Cmd == "restart")
    {
        KickPlayers();
        cRoot::Restart();
        return;
    }
 
    LOG("Executing console command: \"%s\"", a_Cmd.c_str());
    m_Server->ExecuteConsoleCommand(a_Cmd, a_Output);
}
 
 
 
 
 
void cRoot::QueueExecuteConsoleCommand(const AString & a_Cmd)
{
    // Put the command into a queue (Alleviates FS #363):
    QueueExecuteConsoleCommand(a_Cmd, *new cLogCommandDeleteSelfOutputCallback);
}
 
 
 
 
 
void cRoot::KickUser(int a_ClientID, const AString & a_Reason)
{
    m_Server->KickUser(a_ClientID, a_Reason);
}
 
 
 
 
 
size_t cRoot::GetTotalChunkCount(void)
{
    size_t Count = 0;
    for (const auto & Entry : m_WorldsByName)
    {
        Count += Entry.second.GetNumChunks();
    }
    return Count;
}
 
 
 
 
 
void cRoot::SaveAllChunks(void)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.QueueSaveAllChunks();
    }
}
 
 
 
 
 
void cRoot::SaveAllChunksNow(void)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.SaveAllChunks();
    }
}
 
 
 
 
 
void cRoot::SetSavingEnabled(bool a_SavingEnabled)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.SetSavingEnabled(a_SavingEnabled);
    }
}
 
 
 
 
 
void cRoot::SendPlayerLists(cPlayer * a_DestPlayer)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.SendPlayerList(a_DestPlayer);
    }
}
 
 
 
 
 
void cRoot::BroadcastPlayerListsAddPlayer(const cPlayer & a_Player, const cClientHandle * a_Exclude)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.BroadcastPlayerListAddPlayer(a_Player);
    }
}
 
 
 
 
 
void cRoot::BroadcastPlayerListsRemovePlayer(const cPlayer & a_Player, const cClientHandle * a_Exclude)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.BroadcastPlayerListRemovePlayer(a_Player);
    }
}
 
 
 
 
 
void cRoot::BroadcastPlayerListsHeaderFooter(const cCompositeChat & a_Header, const cCompositeChat & a_Footer)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.BroadcastPlayerListHeaderFooter(a_Header, a_Footer);
    }
}
 
 
 
 
 
void cRoot::BroadcastChat(const AString & a_Message, eMessageType a_ChatPrefix)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.BroadcastChat(a_Message, nullptr, a_ChatPrefix);
    }
}
 
 
 
 
 
void cRoot::BroadcastChat(const cCompositeChat & a_Message)
{
    for (auto & Entry : m_WorldsByName)
    {
        Entry.second.BroadcastChat(a_Message);
    }
}
 
 
 
 
 
bool cRoot::ForEachPlayer(cPlayerListCallback a_Callback)
{
    for (auto & Entry : m_WorldsByName)
    {
        if (!Entry.second.ForEachPlayer(a_Callback))
        {
            return false;
        }
    }
    return true;
}
 
 
 
 
 
bool cRoot::FindAndDoWithPlayer(const AString & a_PlayerName, cPlayerListCallback a_Callback)
{
    class cCallback
    {
        size_t        m_BestRating;
        size_t        m_NameLength;
        const AString m_PlayerName;
 
    public:
 
        bool operator () (cPlayer & a_Player)
        {
            size_t Rating = RateCompareString (m_PlayerName, a_Player.GetName());
            if ((Rating > 0) && (Rating >= m_BestRating))
            {
                m_BestMatch = a_Player.GetName();
                if (Rating > m_BestRating)
                {
                    m_NumMatches = 0;
                }
                m_BestRating = Rating;
                ++m_NumMatches;
            }
            return (Rating == m_NameLength);  // Perfect match
        }
 
        cCallback (const AString & a_CBPlayerName) :
            m_BestRating(0),
            m_NameLength(a_CBPlayerName.length()),
            m_PlayerName(a_CBPlayerName),
            m_BestMatch(),
            m_NumMatches(0)
        {}
 
        AString m_BestMatch;
        unsigned  m_NumMatches;
    } Callback (a_PlayerName);
    ForEachPlayer(Callback);
 
    if (Callback.m_NumMatches == 1)
    {
        return DoWithPlayer(Callback.m_BestMatch, a_Callback);
    }
    return false;
}
 
 
 
 
 
bool cRoot::DoWithPlayerByUUID(const cUUID & a_PlayerUUID, cPlayerListCallback a_Callback)
{
    for (auto & Entry : m_WorldsByName)
    {
        if (Entry.second.DoWithPlayerByUUID(a_PlayerUUID, a_Callback))
        {
            return true;
        }
    }
    return false;
}
 
 
 
 
 
bool cRoot::DoWithPlayer(const AString & a_PlayerName, cPlayerListCallback a_Callback)
{
    for (auto & Entry : m_WorldsByName)
    {
        if (Entry.second.DoWithPlayer(a_PlayerName, a_Callback))
        {
            return true;
        }
    }
    return false;
}
 
 
 
 
 
AString cRoot::GetProtocolVersionTextFromInt(int a_ProtocolVersion)
{
    return cMultiVersionProtocol::GetVersionTextFromInt(static_cast<cProtocol::Version>(a_ProtocolVersion));
}
 
 
 
 
 
int cRoot::GetVirtualRAMUsage(void)
{
    #ifdef _WIN32
        PROCESS_MEMORY_COUNTERS_EX pmc;
        if (GetProcessMemoryInfo(GetCurrentProcess(), (PROCESS_MEMORY_COUNTERS *)&pmc, sizeof(pmc)))
        {
            return (int)(pmc.PrivateUsage / 1024);
        }
        return -1;
    #elif defined(__linux__)
        // Code adapted from https://stackoverflow.com/questions/63166/how-to-determine-cpu-and-memory-consumption-from-inside-a-process
        std::ifstream StatFile("/proc/self/status");
        if (!StatFile.good())
        {
            return -1;
        }
        while (StatFile.good())
        {
            AString Line;
            std::getline(StatFile, Line);
            if (strncmp(Line.c_str(), "VmSize:", 7) == 0)
            {
                int res = atoi(Line.c_str() + 8);
                return (res == 0) ? -1 : res;  // If parsing failed, return -1
            }
        }
        return -1;
    #elif defined (__APPLE__)
        // Code adapted from https://stackoverflow.com/questions/63166/how-to-determine-cpu-and-memory-consumption-from-inside-a-process
        struct task_basic_info t_info;
        mach_msg_type_number_t t_info_count = TASK_BASIC_INFO_COUNT;
 
        if (KERN_SUCCESS == task_info(
            mach_task_self(),
            TASK_BASIC_INFO,
            reinterpret_cast<task_info_t>(&t_info),
            &t_info_count
        ))
        {
            return static_cast<int>(t_info.virtual_size / 1024);
        }
        return -1;
    #else
        LOGINFO("%s: Unknown platform, cannot query memory usage", __FUNCTION__);
        return -1;
    #endif
}
 
 
 
 
 
int cRoot::GetPhysicalRAMUsage(void)
{
    #ifdef _WIN32
        PROCESS_MEMORY_COUNTERS pmc;
        if (GetProcessMemoryInfo(GetCurrentProcess(), &pmc, sizeof(pmc)))
        {
            return (int)(pmc.WorkingSetSize / 1024);
        }
        return -1;
    #elif defined(__linux__)
        // Code adapted from https://stackoverflow.com/questions/63166/how-to-determine-cpu-and-memory-consumption-from-inside-a-process
        std::ifstream StatFile("/proc/self/status");
        if (!StatFile.good())
        {
            return -1;
        }
        while (StatFile.good())
        {
            AString Line;
            std::getline(StatFile, Line);
            if (strncmp(Line.c_str(), "VmRSS:", 6) == 0)
            {
                int res = atoi(Line.c_str() + 7);
                return (res == 0) ? -1 : res;  // If parsing failed, return -1
            }
        }
        return -1;
    #elif defined (__APPLE__)
        // Code adapted from https://stackoverflow.com/questions/63166/how-to-determine-cpu-and-memory-consumption-from-inside-a-process
        struct task_basic_info t_info;
        mach_msg_type_number_t t_info_count = TASK_BASIC_INFO_COUNT;
 
        if (KERN_SUCCESS == task_info(
            mach_task_self(),
            TASK_BASIC_INFO,
            reinterpret_cast<task_info_t>(&t_info),
            &t_info_count
        ))
        {
            return static_cast<int>(t_info.resident_size / 1024);
        }
        return -1;
    #elif defined (__FreeBSD__)
        /*
        struct rusage self_usage;
        int status = getrusage(RUSAGE_SELF, &self_usage);
        if (!status)
        {
            return static_cast<int>(self_usage.ru_maxrss);
        }
        return -1;
        */
        // Good to watch: https://www.youtube.com/watch?v=Os5cK0H8EOA - getrusage.
        // Unfortunately, it only gives peak memory usage a.k.a max resident set size
        // So it is better to use FreeBSD kvm function to get the size of resident pages.
 
        static kvm_t* kd = NULL;
 
        if (kd == NULL)
        {
            kd = kvm_open(NULL, "/dev/null", NULL, O_RDONLY, "kvm_open");  // returns a descriptor used to access kernel virtual memory
        }
        if (kd != NULL)
        {
            int pc = 0;  // number of processes found
            struct kinfo_proc* kp;
            kp = kvm_getprocs(kd, KERN_PROC_PID, getpid(), &pc);
            if ((kp != NULL) && (pc >= 1))
            {
                return static_cast<int>(kp->ki_rssize * getpagesize() / 1024);
            }
        }
        return -1;
    #else
        LOGINFO("%s: Unknown platform, cannot query memory usage", __FUNCTION__);
        return -1;
    #endif
}
 
 
 
 
 
void cRoot::LogChunkStats(cCommandOutputCallback & a_Output)
{
    int SumNumValid = 0;
    int SumNumDirty = 0;
    int SumNumInLighting = 0;
    size_t SumNumInGenerator = 0;
    int SumMem = 0;
    for (auto & Entry : m_WorldsByName)
    {
        auto & World = Entry.second;
        const auto NumInGenerator = World.GetGeneratorQueueLength();
        const auto NumInSaveQueue = World.GetStorageSaveQueueLength();
        const auto NumInLoadQueue = World.GetStorageLoadQueueLength();
        int NumValid = 0;
        int NumDirty = 0;
        int NumInLighting = 0;
        World.GetChunkStats(NumValid, NumDirty, NumInLighting);
        a_Output.OutLn(fmt::format(FMT_STRING("World {}:"), World.GetName()));
        a_Output.OutLn(fmt::format(FMT_STRING("  Num loaded chunks: {}"), NumValid));
        a_Output.OutLn(fmt::format(FMT_STRING("  Num dirty chunks: {}"), NumDirty));
        a_Output.OutLn(fmt::format(FMT_STRING("  Num chunks in lighting queue: {}"), NumInLighting));
        a_Output.OutLn(fmt::format(FMT_STRING("  Num chunks in generator queue: {}"), NumInGenerator));
        a_Output.OutLn(fmt::format(FMT_STRING("  Num chunks in storage load queue: {}"), NumInLoadQueue));
        a_Output.OutLn(fmt::format(FMT_STRING("  Num chunks in storage save queue: {}"), NumInSaveQueue));
        int Mem = NumValid * static_cast<int>(sizeof(cChunk));
        a_Output.OutLn(fmt::format(FMT_STRING("  Memory used by chunks: {} KiB ({} MiB)"), (Mem + 1023) / 1024, (Mem + 1024 * 1024 - 1) / (1024 * 1024)));
        SumNumValid += NumValid;
        SumNumDirty += NumDirty;
        SumNumInLighting += NumInLighting;
        SumNumInGenerator += NumInGenerator;
        SumMem += Mem;
    }
    a_Output.OutLn("Totals:");
    a_Output.OutLn(fmt::format(FMT_STRING("  Num loaded chunks: {}"), SumNumValid));
    a_Output.OutLn(fmt::format(FMT_STRING("  Num dirty chunks: {}"), SumNumDirty));
    a_Output.OutLn(fmt::format(FMT_STRING("  Num chunks in lighting queue: {}"), SumNumInLighting));
    a_Output.OutLn(fmt::format(FMT_STRING("  Num chunks in generator queue: {}"), SumNumInGenerator));
    a_Output.OutLn(fmt::format(FMT_STRING("  Memory used by chunks: {} KiB ({} MiB)"), (SumMem + 1023) / 1024, (SumMem + 1024 * 1024 - 1) / (1024 * 1024)));
    a_Output.OutLn("Per-chunk memory size breakdown:");
    a_Output.OutLn(fmt::format(FMT_STRING("  block types:    {:06} bytes ({:3} KiB)"), sizeof(cChunkDef::BlockTypes), (sizeof(cChunkDef::BlockTypes) + 1023) / 1024));
    a_Output.OutLn(fmt::format(FMT_STRING("  block metadata: {:06} bytes ({:3} KiB)"), sizeof(cChunkDef::BlockNibbles), (sizeof(cChunkDef::BlockNibbles) + 1023) / 1024));
    a_Output.OutLn(fmt::format(FMT_STRING("  block lighting: {:06} bytes ({:3} KiB)"), 2 * sizeof(cChunkDef::BlockNibbles), (2 * sizeof(cChunkDef::BlockNibbles) + 1023) / 1024));
    a_Output.OutLn(fmt::format(FMT_STRING("  heightmap:      {:06} bytes ({:3} KiB)"), sizeof(cChunkDef::HeightMap), (sizeof(cChunkDef::HeightMap) + 1023) / 1024));
    a_Output.OutLn(fmt::format(FMT_STRING("  biomemap:       {:06} bytes ({:3} KiB)"), sizeof(cChunkDef::BiomeMap), (sizeof(cChunkDef::BiomeMap) + 1023) / 1024));
}
 
 
 
 
 
int cRoot::GetFurnaceFuelBurnTime(const cItem & a_Fuel)
{
    cFurnaceRecipe * FR = Get()->GetFurnaceRecipe();
    return FR->GetBurnTime(a_Fuel);
}
 
 
 
 
 
AStringVector cRoot::GetPlayerTabCompletionMultiWorld(const AString & a_Text)
{
    AStringVector Results;
    ForEachWorld([&](cWorld & a_World)
        {
            a_World.TabCompleteUserName(a_Text, Results);
            return false;
        }
    );
    return Results;
}
 
 
 
 
 
void cRoot::HandleInput()
{
    if (g_RunAsService)
    {
        // Ignore input when running as a service, cin was never opened in that case:
        return;
    }
 
    cLogCommandOutputCallback Output;
    AString Command;
 
    while (s_NextState == NextState::Run)
    {
#ifndef _WIN32
        timeval Timeout{ 0, 0 };
        Timeout.tv_usec = 100 * 1000;  // 100 msec
 
        fd_set ReadSet;
        FD_ZERO(&ReadSet);
        FD_SET(STDIN_FILENO, &ReadSet);
 
        if (select(STDIN_FILENO + 1, &ReadSet, nullptr, nullptr, &Timeout) <= 0)
        {
            // Don't call getline because there's nothing to read
            continue;
        }
#endif
 
        if (!std::getline(std::cin, Command))
        {
            cRoot::Stop();
            return;
        }
 
        if (s_NextState != NextState::Run)
        {
            // Already shutting down, can't execute commands
            break;
        }
 
        if (!Command.empty())
        {
            // Execute and clear command string when submitted
            QueueExecuteConsoleCommand(TrimString(Command), Output);
        }
    }
}
 
 
 
 
 
void cRoot::TransitionNextState(NextState a_NextState)
{
    {
        auto Current = s_NextState.load();
        do
        {
            // Stopping is final, so stops override restarts:
            if (Current == NextState::Stop)
            {
                return;
            }
        }
        while (!s_NextState.compare_exchange_strong(Current, a_NextState));
    }
 
    if (s_NextState == NextState::Run)
    {
        return;
    }
 
    s_StopEvent.Set();
 
#ifdef WIN32
    DWORD Length;
    INPUT_RECORD Record
    {
        KEY_EVENT,
        {
            {
                TRUE,
                1,
                VK_RETURN,
                static_cast<WORD>(MapVirtualKey(VK_RETURN, MAPVK_VK_TO_VSC)),
                { { VK_RETURN } },
                0
            }
        }
    };
 
    // Can't kill the input thread since it breaks cin (getline doesn't block / receive input on restart)
    // Apparently no way to unblock getline apart from CancelIoEx, but xoft wants Windows XP support
    // Only thing I can think of for now. Also, ignore the retval since sometimes there's no cin.
    WriteConsoleInput(GetStdHandle(STD_INPUT_HANDLE), &Record, 1, &Length);
#endif
}