2012-06-14 09:06:06 -04:00
|
|
|
|
|
|
|
|
|
#include "Globals.h" // NOTE: MSVC stupidness requires this to be the same across all modules
|
|
|
|
|
|
2012-09-23 18:09:57 -04:00
|
|
|
|
#include "Root.h"
|
|
|
|
|
#include "Server.h"
|
|
|
|
|
#include "World.h"
|
|
|
|
|
#include "WebAdmin.h"
|
|
|
|
|
#include "FurnaceRecipe.h"
|
|
|
|
|
#include "GroupManager.h"
|
2012-06-14 09:06:06 -04:00
|
|
|
|
#include "CraftingRecipes.h"
|
2012-09-23 18:09:57 -04:00
|
|
|
|
#include "PluginManager.h"
|
|
|
|
|
#include "MonsterConfig.h"
|
2013-08-19 05:39:13 -04:00
|
|
|
|
#include "Entities/Player.h"
|
2012-09-29 09:59:32 -04:00
|
|
|
|
#include "Blocks/BlockHandler.h"
|
|
|
|
|
#include "Items/ItemHandler.h"
|
2012-09-23 18:09:57 -04:00
|
|
|
|
#include "Chunk.h"
|
2012-10-31 15:54:42 -04:00
|
|
|
|
#include "Protocol/ProtocolRecognizer.h" // for protocol version constants
|
2013-06-29 11:30:05 -04:00
|
|
|
|
#include "CommandOutput.h"
|
2013-08-14 16:39:12 -04:00
|
|
|
|
#include "DeadlockDetect.h"
|
2013-09-29 16:37:50 -04:00
|
|
|
|
#include "OSSupport/Timer.h"
|
2012-06-14 09:06:06 -04:00
|
|
|
|
|
|
|
|
|
#include "../iniFile/iniFile.h"
|
|
|
|
|
|
|
|
|
|
#include <iostream>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cRoot* cRoot::s_Root = 0;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cRoot::cRoot()
|
2012-08-22 07:22:26 -04:00
|
|
|
|
: m_Server( NULL )
|
|
|
|
|
, m_MonsterConfig( NULL )
|
|
|
|
|
, m_GroupManager( NULL )
|
2012-06-14 09:06:06 -04:00
|
|
|
|
, m_CraftingRecipes(NULL)
|
2012-08-22 07:22:26 -04:00
|
|
|
|
, m_FurnaceRecipe( NULL )
|
|
|
|
|
, m_WebAdmin( NULL )
|
|
|
|
|
, m_PluginManager( NULL )
|
|
|
|
|
, m_Log( NULL )
|
2012-06-14 09:06:06 -04:00
|
|
|
|
, m_bStop( false )
|
|
|
|
|
, m_bRestart( false )
|
2012-08-22 07:22:26 -04:00
|
|
|
|
, m_InputThread( NULL )
|
|
|
|
|
, m_pDefaultWorld( NULL )
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
|
|
|
|
s_Root = this;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cRoot::~cRoot()
|
|
|
|
|
{
|
|
|
|
|
s_Root = 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2012-08-18 06:38:15 -04:00
|
|
|
|
void cRoot::InputThread(void * a_Params)
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2012-08-18 06:38:15 -04:00
|
|
|
|
cRoot & self = *(cRoot*)a_Params;
|
2012-06-14 09:06:06 -04:00
|
|
|
|
|
2013-06-29 11:30:05 -04:00
|
|
|
|
cLogCommandOutputCallback Output;
|
|
|
|
|
|
2013-07-24 16:25:27 -04:00
|
|
|
|
while (!(self.m_bStop || self.m_bRestart) && std::cin.good())
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
|
|
|
|
std::string Command;
|
|
|
|
|
std::getline(std::cin, Command);
|
2013-07-24 16:25:27 -04:00
|
|
|
|
if (!Command.empty())
|
|
|
|
|
{
|
|
|
|
|
self.ExecuteConsoleCommand(Command, Output);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!(self.m_bStop || self.m_bRestart))
|
|
|
|
|
{
|
|
|
|
|
// We have come here because the std::cin has received an EOF and the server is still running; stop the server:
|
|
|
|
|
self.m_bStop = true;
|
2012-06-14 09:06:06 -04:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2012-11-11 09:15:59 -05:00
|
|
|
|
void cRoot::Start(void)
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2013-08-14 16:39:12 -04:00
|
|
|
|
cDeadlockDetect dd;
|
2012-06-14 09:06:06 -04:00
|
|
|
|
delete m_Log;
|
|
|
|
|
m_Log = new cMCLogger();
|
|
|
|
|
|
|
|
|
|
m_bStop = false;
|
|
|
|
|
while (!m_bStop)
|
|
|
|
|
{
|
2013-10-07 04:45:42 -04:00
|
|
|
|
cTimer Time;
|
|
|
|
|
long long mseconds = Time.GetNowTime();
|
|
|
|
|
|
2012-06-14 09:06:06 -04:00
|
|
|
|
m_bRestart = false;
|
|
|
|
|
|
|
|
|
|
LoadGlobalSettings();
|
|
|
|
|
|
|
|
|
|
LOG("Creating new server instance...");
|
|
|
|
|
m_Server = new cServer();
|
|
|
|
|
|
2012-11-11 09:23:47 -05:00
|
|
|
|
LOG("Reading server config...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
cIniFile IniFile("settings.ini");
|
2012-11-11 09:23:47 -05:00
|
|
|
|
if (!IniFile.ReadFile())
|
2012-11-10 10:13:09 -05:00
|
|
|
|
{
|
2013-08-05 09:24:23 -04:00
|
|
|
|
LOGWARNING("settings.ini inaccessible, all settings are reset to default values");
|
2012-11-10 10:13:09 -05:00
|
|
|
|
}
|
2012-11-11 09:15:59 -05:00
|
|
|
|
m_PrimaryServerVersion = IniFile.GetValueI("Server", "PrimaryServerVersion", 0);
|
|
|
|
|
if (m_PrimaryServerVersion == 0)
|
|
|
|
|
{
|
|
|
|
|
m_PrimaryServerVersion = cProtocolRecognizer::PROTO_VERSION_LATEST;
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
// Make a note in the log that the primary server version is explicitly set in the ini file
|
|
|
|
|
LOGINFO("settings.ini: [Server].PrimaryServerVersion set to %d.", m_PrimaryServerVersion);
|
|
|
|
|
}
|
2012-10-31 15:54:42 -04:00
|
|
|
|
|
2012-11-11 09:23:47 -05:00
|
|
|
|
LOG("Starting server...");
|
|
|
|
|
if (!m_Server->InitServer(IniFile))
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGERROR("Failure starting server, aborting...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
IniFile.WriteFile();
|
|
|
|
|
|
2013-10-05 17:08:16 -04:00
|
|
|
|
LOG("Initialising WebAdmin...");
|
|
|
|
|
m_WebAdmin = new cWebAdmin();
|
|
|
|
|
m_WebAdmin->Init();
|
2012-06-14 09:06:06 -04:00
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Loading settings...");
|
2013-08-05 09:24:23 -04:00
|
|
|
|
m_GroupManager = new cGroupManager();
|
2012-06-14 09:06:06 -04:00
|
|
|
|
m_CraftingRecipes = new cCraftingRecipes;
|
2013-08-05 09:24:23 -04:00
|
|
|
|
m_FurnaceRecipe = new cFurnaceRecipe();
|
2012-06-14 09:06:06 -04:00
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Loading worlds...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
LoadWorlds();
|
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Loading plugin manager...");
|
2013-02-15 08:00:59 -05:00
|
|
|
|
m_PluginManager = new cPluginManager();
|
2012-06-14 09:06:06 -04:00
|
|
|
|
m_PluginManager->ReloadPluginsNow();
|
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Loading MonsterConfig...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
m_MonsterConfig = new cMonsterConfig;
|
|
|
|
|
|
|
|
|
|
// This sets stuff in motion
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Starting Authenticator...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
m_Authenticator.Start();
|
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Starting worlds...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
StartWorlds();
|
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Starting deadlock detector...");
|
2013-08-14 16:39:12 -04:00
|
|
|
|
dd.Start();
|
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Finalising startup...");
|
2013-03-04 16:13:08 -05:00
|
|
|
|
m_Server->Start();
|
2013-10-05 17:08:16 -04:00
|
|
|
|
|
|
|
|
|
LOG("Starting WebAdmin...");
|
|
|
|
|
m_WebAdmin->Start();
|
2012-06-14 09:06:06 -04:00
|
|
|
|
|
2013-03-04 16:13:08 -05:00
|
|
|
|
#if !defined(ANDROID_NDK)
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Starting InputThread...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
m_InputThread = new cThread( InputThread, this, "cRoot::InputThread" );
|
2013-03-04 16:13:08 -05:00
|
|
|
|
m_InputThread->Start( false ); // We should NOT wait? Otherwise we can<61>t stop the server from other threads than the input thread
|
|
|
|
|
#endif
|
2012-06-14 09:06:06 -04:00
|
|
|
|
|
2013-09-29 16:37:50 -04:00
|
|
|
|
long long finishmseconds = Time.GetNowTime();
|
|
|
|
|
finishmseconds -= mseconds;
|
2013-09-28 15:36:01 -04:00
|
|
|
|
|
2013-09-30 16:17:52 -04:00
|
|
|
|
LOG("Startup complete, took %i ms!", finishmseconds);
|
2013-09-28 15:36:01 -04:00
|
|
|
|
|
2013-03-04 16:13:08 -05:00
|
|
|
|
while (!m_bStop && !m_bRestart) // These are modified by external threads
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2013-03-04 16:13:08 -05:00
|
|
|
|
cSleep::MilliSleep(1000);
|
2012-06-14 09:06:06 -04:00
|
|
|
|
}
|
|
|
|
|
|
2013-03-04 16:13:08 -05:00
|
|
|
|
#if !defined(ANDROID_NDK)
|
|
|
|
|
delete m_InputThread; m_InputThread = NULL;
|
|
|
|
|
#endif
|
2012-06-14 09:06:06 -04:00
|
|
|
|
|
|
|
|
|
// Deallocate stuffs
|
|
|
|
|
LOG("Shutting down server...");
|
2013-08-14 16:39:12 -04:00
|
|
|
|
m_Server->Shutdown();
|
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Shutting down deadlock detector...");
|
2013-08-14 16:39:12 -04:00
|
|
|
|
dd.Stop();
|
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Stopping world threads...");
|
2012-07-15 16:07:38 -04:00
|
|
|
|
StopWorlds();
|
2013-08-14 16:39:12 -04:00
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Stopping authenticator...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
m_Authenticator.Stop();
|
2012-07-15 16:36:34 -04:00
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Freeing MonsterConfig...");
|
2013-08-14 16:39:12 -04:00
|
|
|
|
delete m_MonsterConfig; m_MonsterConfig = NULL;
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Stopping WebAdmin...");
|
2013-08-14 16:39:12 -04:00
|
|
|
|
delete m_WebAdmin; m_WebAdmin = NULL;
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Unloading recipes...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
delete m_FurnaceRecipe; m_FurnaceRecipe = NULL;
|
|
|
|
|
delete m_CraftingRecipes; m_CraftingRecipes = NULL;
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Forgetting groups...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
delete m_GroupManager; m_GroupManager = 0;
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Unloading worlds...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
UnloadWorlds();
|
2012-07-15 16:36:34 -04:00
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOGD("Stopping plugin manager...");
|
2013-02-05 14:57:22 -05:00
|
|
|
|
delete m_PluginManager; m_PluginManager = NULL;
|
|
|
|
|
|
2012-07-15 16:36:34 -04:00
|
|
|
|
cItemHandler::Deinit();
|
|
|
|
|
cBlockHandler::Deinit();
|
|
|
|
|
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOG("Cleaning up...");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
//delete HeartBeat; HeartBeat = 0;
|
|
|
|
|
delete m_Server; m_Server = 0;
|
2013-09-28 15:36:01 -04:00
|
|
|
|
LOG("Shutdown successful!");
|
2012-06-14 09:06:06 -04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
delete m_Log; m_Log = 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void cRoot::LoadGlobalSettings()
|
|
|
|
|
{
|
2012-10-06 16:04:58 -04:00
|
|
|
|
// Nothing needed yet
|
2012-06-14 09:06:06 -04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void cRoot::LoadWorlds(void)
|
|
|
|
|
{
|
|
|
|
|
cIniFile IniFile("settings.ini"); IniFile.ReadFile();
|
|
|
|
|
|
|
|
|
|
// First get the default world
|
|
|
|
|
AString DefaultWorldName = IniFile.GetValueSet("Worlds", "DefaultWorld", "world");
|
2012-08-22 07:22:26 -04:00
|
|
|
|
m_pDefaultWorld = new cWorld( DefaultWorldName.c_str() );
|
|
|
|
|
m_WorldsByName[ DefaultWorldName ] = m_pDefaultWorld;
|
2012-06-14 09:06:06 -04:00
|
|
|
|
|
|
|
|
|
// Then load the other worlds
|
|
|
|
|
unsigned int KeyNum = IniFile.FindKey("Worlds");
|
|
|
|
|
unsigned int NumWorlds = IniFile.GetNumValues( KeyNum );
|
|
|
|
|
if (NumWorlds <= 0)
|
|
|
|
|
{
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
for (unsigned int i = 0; i < NumWorlds; i++)
|
|
|
|
|
{
|
|
|
|
|
AString ValueName = IniFile.GetValueName(KeyNum, i );
|
|
|
|
|
if (ValueName.compare("World") != 0)
|
|
|
|
|
{
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
AString WorldName = IniFile.GetValue(KeyNum, i );
|
|
|
|
|
if (WorldName.empty())
|
|
|
|
|
{
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
cWorld* NewWorld = new cWorld( WorldName.c_str() );
|
2012-08-22 07:22:26 -04:00
|
|
|
|
m_WorldsByName[ WorldName ] = NewWorld;
|
2012-06-14 09:06:06 -04:00
|
|
|
|
} // for i - Worlds
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void cRoot::StartWorlds(void)
|
|
|
|
|
{
|
2013-08-11 14:16:41 -04:00
|
|
|
|
for (WorldMap::iterator itr = m_WorldsByName.begin(); itr != m_WorldsByName.end(); ++itr)
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2013-08-11 14:16:41 -04:00
|
|
|
|
itr->second->Start();
|
2012-06-14 09:06:06 -04:00
|
|
|
|
itr->second->InitializeSpawn();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2012-07-15 16:07:38 -04:00
|
|
|
|
void cRoot::StopWorlds(void)
|
|
|
|
|
{
|
2013-08-11 14:16:41 -04:00
|
|
|
|
for (WorldMap::iterator itr = m_WorldsByName.begin(); itr != m_WorldsByName.end(); ++itr)
|
2012-07-15 16:07:38 -04:00
|
|
|
|
{
|
2013-08-11 14:16:41 -04:00
|
|
|
|
itr->second->Stop();
|
2012-07-15 16:07:38 -04:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2012-06-14 09:06:06 -04:00
|
|
|
|
void cRoot::UnloadWorlds(void)
|
|
|
|
|
{
|
2012-08-22 07:22:26 -04:00
|
|
|
|
m_pDefaultWorld = NULL;
|
|
|
|
|
for( WorldMap::iterator itr = m_WorldsByName.begin(); itr != m_WorldsByName.end(); ++itr )
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
|
|
|
|
delete itr->second;
|
|
|
|
|
}
|
2012-08-22 07:22:26 -04:00
|
|
|
|
m_WorldsByName.clear();
|
2012-06-14 09:06:06 -04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cWorld* cRoot::GetDefaultWorld()
|
|
|
|
|
{
|
2012-08-22 07:22:26 -04:00
|
|
|
|
return m_pDefaultWorld;
|
2012-06-14 09:06:06 -04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cWorld* cRoot::GetWorld( const AString & a_WorldName )
|
|
|
|
|
{
|
2012-08-22 07:22:26 -04:00
|
|
|
|
WorldMap::iterator itr = m_WorldsByName.find( a_WorldName );
|
|
|
|
|
if( itr != m_WorldsByName.end() )
|
2012-06-14 09:06:06 -04:00
|
|
|
|
return itr->second;
|
|
|
|
|
return 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
bool cRoot::ForEachWorld(cWorldListCallback & a_Callback)
|
|
|
|
|
{
|
2012-08-22 07:22:26 -04:00
|
|
|
|
for (WorldMap::iterator itr = m_WorldsByName.begin(), itr2 = itr; itr != m_WorldsByName.end(); itr = itr2)
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2012-06-19 16:31:21 -04:00
|
|
|
|
++itr2;
|
2012-06-14 09:06:06 -04:00
|
|
|
|
if (a_Callback.Item(itr->second))
|
|
|
|
|
{
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2013-08-11 14:16:41 -04:00
|
|
|
|
void cRoot::TickCommands(void)
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2013-04-27 17:05:34 -04:00
|
|
|
|
// Execute any pending commands:
|
2013-06-29 11:30:05 -04:00
|
|
|
|
cCommandQueue PendingCommands;
|
2013-04-27 17:05:34 -04:00
|
|
|
|
{
|
|
|
|
|
cCSLock Lock(m_CSPendingCommands);
|
|
|
|
|
std::swap(PendingCommands, m_PendingCommands);
|
|
|
|
|
}
|
2013-06-29 11:30:05 -04:00
|
|
|
|
for (cCommandQueue::iterator itr = PendingCommands.begin(), end = PendingCommands.end(); itr != end; ++itr)
|
2013-04-27 17:05:34 -04:00
|
|
|
|
{
|
2013-06-29 11:30:05 -04:00
|
|
|
|
ExecuteConsoleCommand(itr->m_Command, *(itr->m_Output));
|
2013-04-27 17:05:34 -04:00
|
|
|
|
}
|
2012-06-14 09:06:06 -04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2013-06-29 11:30:05 -04:00
|
|
|
|
void cRoot::QueueExecuteConsoleCommand(const AString & a_Cmd, cCommandOutputCallback & a_Output)
|
|
|
|
|
{
|
|
|
|
|
// Some commands are built-in:
|
|
|
|
|
if (a_Cmd == "stop")
|
|
|
|
|
{
|
|
|
|
|
m_bStop = true;
|
|
|
|
|
}
|
|
|
|
|
else if (a_Cmd == "restart")
|
|
|
|
|
{
|
|
|
|
|
m_bRestart = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Put the command into a queue (Alleviates FS #363):
|
|
|
|
|
cCSLock Lock(m_CSPendingCommands);
|
|
|
|
|
m_PendingCommands.push_back(cCommand(a_Cmd, &a_Output));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void cRoot::QueueExecuteConsoleCommand(const AString & a_Cmd)
|
2013-04-27 17:05:34 -04:00
|
|
|
|
{
|
2013-04-27 17:14:31 -04:00
|
|
|
|
// Some commands are built-in:
|
|
|
|
|
if (a_Cmd == "stop")
|
|
|
|
|
{
|
|
|
|
|
m_bStop = true;
|
|
|
|
|
}
|
|
|
|
|
else if (a_Cmd == "restart")
|
|
|
|
|
{
|
|
|
|
|
m_bRestart = true;
|
|
|
|
|
}
|
|
|
|
|
|
2013-04-27 17:05:34 -04:00
|
|
|
|
// Put the command into a queue (Alleviates FS #363):
|
|
|
|
|
cCSLock Lock(m_CSPendingCommands);
|
2013-06-29 11:30:05 -04:00
|
|
|
|
m_PendingCommands.push_back(cCommand(a_Cmd, new cLogCommandDeleteSelfOutputCallback));
|
2013-04-27 17:05:34 -04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2013-06-29 11:30:05 -04:00
|
|
|
|
void cRoot::ExecuteConsoleCommand(const AString & a_Cmd, cCommandOutputCallback & a_Output)
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2013-06-29 11:30:05 -04:00
|
|
|
|
// Some commands are built-in:
|
|
|
|
|
if (a_Cmd == "stop")
|
|
|
|
|
{
|
|
|
|
|
m_bStop = true;
|
|
|
|
|
}
|
|
|
|
|
else if (a_Cmd == "restart")
|
|
|
|
|
{
|
|
|
|
|
m_bRestart = true;
|
|
|
|
|
}
|
|
|
|
|
|
2013-02-15 08:00:59 -05:00
|
|
|
|
LOG("Executing console command: \"%s\"", a_Cmd.c_str());
|
2013-06-29 11:30:05 -04:00
|
|
|
|
m_Server->ExecuteConsoleCommand(a_Cmd, a_Output);
|
2012-06-14 09:06:06 -04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void cRoot::KickUser(int a_ClientID, const AString & a_Reason)
|
|
|
|
|
{
|
|
|
|
|
m_Server->KickUser(a_ClientID, a_Reason);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void cRoot::AuthenticateUser(int a_ClientID)
|
|
|
|
|
{
|
|
|
|
|
m_Server->AuthenticateUser(a_ClientID);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
int cRoot::GetTotalChunkCount(void)
|
|
|
|
|
{
|
|
|
|
|
int res = 0;
|
2012-08-22 07:22:26 -04:00
|
|
|
|
for ( WorldMap::iterator itr = m_WorldsByName.begin(); itr != m_WorldsByName.end(); ++itr )
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
|
|
|
|
res += itr->second->GetNumChunks();
|
|
|
|
|
}
|
|
|
|
|
return res;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void cRoot::SaveAllChunks(void)
|
|
|
|
|
{
|
2012-08-22 07:22:26 -04:00
|
|
|
|
for (WorldMap::iterator itr = m_WorldsByName.begin(); itr != m_WorldsByName.end(); ++itr)
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
|
|
|
|
itr->second->SaveAllChunks();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2013-08-17 17:58:37 -04:00
|
|
|
|
void cRoot::BroadcastChat(const AString & a_Message)
|
|
|
|
|
{
|
|
|
|
|
for (WorldMap::iterator itr = m_WorldsByName.begin(), end = m_WorldsByName.end(); itr != end; ++itr)
|
|
|
|
|
{
|
|
|
|
|
itr->second->BroadcastChat(a_Message);
|
|
|
|
|
} // for itr - m_WorldsByName[]
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2012-06-14 09:06:06 -04:00
|
|
|
|
bool cRoot::ForEachPlayer(cPlayerListCallback & a_Callback)
|
|
|
|
|
{
|
2012-08-22 07:22:26 -04:00
|
|
|
|
for (WorldMap::iterator itr = m_WorldsByName.begin(), itr2 = itr; itr != m_WorldsByName.end(); itr = itr2)
|
2012-06-14 09:06:06 -04:00
|
|
|
|
{
|
2012-06-19 16:31:21 -04:00
|
|
|
|
++itr2;
|
2012-06-14 09:06:06 -04:00
|
|
|
|
if (!itr->second->ForEachPlayer(a_Callback))
|
|
|
|
|
{
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2012-08-15 08:08:11 -04:00
|
|
|
|
|
2012-08-22 19:05:12 -04:00
|
|
|
|
bool cRoot::FindAndDoWithPlayer(const AString & a_PlayerName, cPlayerListCallback & a_Callback)
|
|
|
|
|
{
|
|
|
|
|
class cCallback : public cPlayerListCallback
|
|
|
|
|
{
|
|
|
|
|
unsigned int BestRating;
|
|
|
|
|
unsigned int NameLength;
|
|
|
|
|
const AString PlayerName;
|
|
|
|
|
|
|
|
|
|
cPlayerListCallback & m_Callback;
|
|
|
|
|
virtual bool Item (cPlayer * a_pPlayer)
|
|
|
|
|
{
|
|
|
|
|
unsigned int Rating = RateCompareString (PlayerName, a_pPlayer->GetName());
|
|
|
|
|
if (Rating > 0 && Rating >= BestRating)
|
|
|
|
|
{
|
|
|
|
|
BestMatch = a_pPlayer;
|
|
|
|
|
if( Rating > BestRating ) NumMatches = 0;
|
|
|
|
|
BestRating = Rating;
|
|
|
|
|
++NumMatches;
|
|
|
|
|
}
|
|
|
|
|
if (Rating == NameLength) // Perfect match
|
|
|
|
|
{
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public:
|
|
|
|
|
cCallback (const AString & a_PlayerName, cPlayerListCallback & a_Callback)
|
|
|
|
|
: m_Callback( a_Callback )
|
|
|
|
|
, BestMatch( NULL )
|
|
|
|
|
, BestRating( 0 )
|
|
|
|
|
, NumMatches( 0 )
|
|
|
|
|
, NameLength( a_PlayerName.length() )
|
|
|
|
|
, PlayerName( a_PlayerName )
|
|
|
|
|
{}
|
|
|
|
|
|
|
|
|
|
cPlayer * BestMatch;
|
|
|
|
|
unsigned int NumMatches;
|
|
|
|
|
} Callback (a_PlayerName, a_Callback);
|
|
|
|
|
ForEachPlayer( Callback );
|
|
|
|
|
|
|
|
|
|
if (Callback.NumMatches == 1)
|
|
|
|
|
{
|
|
|
|
|
return a_Callback.Item (Callback.BestMatch);
|
|
|
|
|
}
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2013-02-15 08:00:59 -05:00
|
|
|
|
AString cRoot::GetProtocolVersionTextFromInt(int a_ProtocolVersion)
|
|
|
|
|
{
|
|
|
|
|
return cProtocolRecognizer::GetVersionTextFromInt(a_ProtocolVersion);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
2013-06-29 11:30:05 -04:00
|
|
|
|
void cRoot::LogChunkStats(cCommandOutputCallback & a_Output)
|
2012-08-15 08:08:11 -04:00
|
|
|
|
{
|
|
|
|
|
int SumNumValid = 0;
|
|
|
|
|
int SumNumDirty = 0;
|
|
|
|
|
int SumNumInLighting = 0;
|
|
|
|
|
int SumNumInGenerator = 0;
|
|
|
|
|
int SumMem = 0;
|
2012-08-22 07:22:26 -04:00
|
|
|
|
for (WorldMap::iterator itr = m_WorldsByName.begin(), end = m_WorldsByName.end(); itr != end; ++itr)
|
2012-08-15 08:08:11 -04:00
|
|
|
|
{
|
|
|
|
|
cWorld * World = itr->second;
|
|
|
|
|
int NumInGenerator = World->GetGeneratorQueueLength();
|
|
|
|
|
int NumInSaveQueue = World->GetStorageSaveQueueLength();
|
|
|
|
|
int NumInLoadQueue = World->GetStorageLoadQueueLength();
|
|
|
|
|
int NumValid = 0;
|
|
|
|
|
int NumDirty = 0;
|
|
|
|
|
int NumInLighting = 0;
|
|
|
|
|
World->GetChunkStats(NumValid, NumDirty, NumInLighting);
|
2013-06-29 11:30:05 -04:00
|
|
|
|
a_Output.Out("World %s:", World->GetName().c_str());
|
|
|
|
|
a_Output.Out(" Num loaded chunks: %d", NumValid);
|
|
|
|
|
a_Output.Out(" Num dirty chunks: %d", NumDirty);
|
|
|
|
|
a_Output.Out(" Num chunks in lighting queue: %d", NumInLighting);
|
|
|
|
|
a_Output.Out(" Num chunks in generator queue: %d", NumInGenerator);
|
|
|
|
|
a_Output.Out(" Num chunks in storage load queue: %d", NumInLoadQueue);
|
|
|
|
|
a_Output.Out(" Num chunks in storage save queue: %d", NumInSaveQueue);
|
2012-08-15 08:08:11 -04:00
|
|
|
|
int Mem = NumValid * sizeof(cChunk);
|
2013-06-29 11:30:05 -04:00
|
|
|
|
a_Output.Out(" Memory used by chunks: %d KiB (%d MiB)", (Mem + 1023) / 1024, (Mem + 1024 * 1024 - 1) / (1024 * 1024));
|
|
|
|
|
a_Output.Out(" Per-chunk memory size breakdown:");
|
|
|
|
|
a_Output.Out(" block types: %6d bytes (%3d KiB)", sizeof(cChunkDef::BlockTypes), (sizeof(cChunkDef::BlockTypes) + 1023) / 1024);
|
|
|
|
|
a_Output.Out(" block metadata: %6d bytes (%3d KiB)", sizeof(cChunkDef::BlockNibbles), (sizeof(cChunkDef::BlockNibbles) + 1023) / 1024);
|
|
|
|
|
a_Output.Out(" block lighting: %6d bytes (%3d KiB)", 2 * sizeof(cChunkDef::BlockNibbles), (2 * sizeof(cChunkDef::BlockNibbles) + 1023) / 1024);
|
|
|
|
|
a_Output.Out(" heightmap: %6d bytes (%3d KiB)", sizeof(cChunkDef::HeightMap), (sizeof(cChunkDef::HeightMap) + 1023) / 1024);
|
|
|
|
|
a_Output.Out(" biomemap: %6d bytes (%3d KiB)", sizeof(cChunkDef::BiomeMap), (sizeof(cChunkDef::BiomeMap) + 1023) / 1024);
|
2012-08-15 08:08:11 -04:00
|
|
|
|
int Rest = sizeof(cChunk) - sizeof(cChunkDef::BlockTypes) - 3 * sizeof(cChunkDef::BlockNibbles) - sizeof(cChunkDef::HeightMap) - sizeof(cChunkDef::BiomeMap);
|
2013-06-29 11:30:05 -04:00
|
|
|
|
a_Output.Out(" other: %6d bytes (%3d KiB)", Rest, (Rest + 1023) / 1024);
|
2012-08-15 08:08:11 -04:00
|
|
|
|
SumNumValid += NumValid;
|
|
|
|
|
SumNumDirty += NumDirty;
|
|
|
|
|
SumNumInLighting += NumInLighting;
|
|
|
|
|
SumNumInGenerator += NumInGenerator;
|
|
|
|
|
SumMem += Mem;
|
|
|
|
|
}
|
2013-06-29 11:30:05 -04:00
|
|
|
|
a_Output.Out("Totals:");
|
|
|
|
|
a_Output.Out(" Num loaded chunks: %d", SumNumValid);
|
|
|
|
|
a_Output.Out(" Num dirty chunks: %d", SumNumDirty);
|
|
|
|
|
a_Output.Out(" Num chunks in lighting queue: %d", SumNumInLighting);
|
|
|
|
|
a_Output.Out(" Num chunks in generator queue: %d", SumNumInGenerator);
|
|
|
|
|
a_Output.Out(" Memory used by chunks: %d KiB (%d MiB)", (SumMem + 1023) / 1024, (SumMem + 1024 * 1024 - 1) / (1024 * 1024));
|
2012-08-15 08:08:11 -04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|