diff --git a/src/main.cpp b/src/main.cpp index 7a6b3e47c..32a46e5cf 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -93,11 +93,12 @@ with this program; if not, write to the Free Software Foundation, Inc., #ifdef HAVE_TOUCHSCREENGUI #include "touchscreengui.h" #endif + /* Settings. These are loaded from the config file. */ -Settings main_settings; +static Settings main_settings; Settings *g_settings = &main_settings; std::string g_settings_path; @@ -125,6 +126,66 @@ std::ostream *derr_server_ptr = &errorstream; std::ostream *dout_client_ptr = &infostream; std::ostream *derr_client_ptr = &errorstream; +#define DEBUGFILE "debug.txt" +#define DEFAULT_SERVER_PORT 30000 + +typedef std::map OptionList; + +struct GameParams { + u16 socket_port; + std::string world_path; + SubgameSpec game_spec; + bool is_dedicated_server; + int log_level; +}; + +/********************************************************************** + * Private functions + **********************************************************************/ + +static bool get_cmdline_opts(int argc, char *argv[], Settings *cmd_args); +static void set_allowed_options(OptionList *allowed_options); + +static void print_help(const OptionList &allowed_options); +static void print_allowed_options(const OptionList &allowed_options); +static void print_version(); +static void print_worldspecs(const std::vector &worldspecs, + std::ostream &os); +static void print_modified_quicktune_values(); + +static void list_game_ids(); +static void list_worlds(); +static void setup_log_params(const Settings &cmd_args); +static bool create_userdata_path(); +static bool init_common(int *log_level, const Settings &cmd_args); +static void startup_message(); +static bool read_config_file(const Settings &cmd_args); +static void init_debug_streams(int *log_level, const Settings &cmd_args); + +static bool game_configure(GameParams *game_params, const Settings &cmd_args); +static void game_configure_port(GameParams *game_params, const Settings &cmd_args); + +static bool game_configure_world(GameParams *game_params, const Settings &cmd_args); +static bool get_world_from_cmdline(GameParams *game_params, const Settings &cmd_args); +static bool get_world_from_config(GameParams *game_params, const Settings &cmd_args); +static bool auto_select_world(GameParams *game_params); +static std::string get_clean_world_path(const std::string &path); + +static bool game_configure_subgame(GameParams *game_params, const Settings &cmd_args); +static bool get_game_from_cmdline(GameParams *game_params, const Settings &cmd_args); +static bool determine_subgame(GameParams *game_params); + +static bool run_dedicated_server(const GameParams &game_params, const Settings &cmd_args); +static bool migrate_database(const GameParams &game_params, const Settings &cmd_args, + Server *server); + +#ifndef SERVER +static bool print_video_modes(); +static void speed_tests(); +#endif + +/**********************************************************************/ + #ifndef SERVER /* Random stuff @@ -285,7 +346,7 @@ public: } #endif // handle mouse events - if(event.EventType == irr::EET_MOUSE_INPUT_EVENT) { + if (event.EventType == irr::EET_MOUSE_INPUT_EVENT) { if (noMenuActive() == false) { left_active = false; middle_active = false; @@ -312,8 +373,9 @@ public: } } } - if(event.EventType == irr::EET_LOG_TEXT_EVENT) { - dstream<< std::string("Irrlicht log: ") + std::string(event.LogEvent.Text)< map1; - tempf = -324; - const s16 ii = 300; - for(s16 y = 0; y < ii; y++) { - for(s16 x = 0; x < ii; x++) { - map1[v2s16(x, y)] = tempf; - tempf += 1; - } - } - for(s16 y = ii - 1; y >= 0; y--) { - for(s16 x = 0; x < ii; x++) { - tempf = map1[v2s16(x, y)]; - } - } - } - - { - infostream << "Around 5000/ms should do well here." << std::endl; - TimeTaker timer("Testing mutex speed"); - - JMutex m; - u32 n = 0; - u32 i = 0; - do { - n += 10000; - for(; i < n; i++) { - m.Lock(); - m.Unlock(); - } - } - // Do at least 10ms - while(timer.getTimerTime() < 10); - - u32 dtime = timer.stop(); - u32 per_ms = n / dtime; - infostream << "Done. " << dtime << "ms, " << per_ms << "/ms" << std::endl; - } -} - -static void print_worldspecs(const std::vector &worldspecs, std::ostream &os) -{ - for(u32 i = 0; i < worldspecs.size(); i++) { - std::string name = worldspecs[i].name; - std::string path = worldspecs[i].path; - if (name.find(" ") != std::string::npos) - name = std::string("'") + name + "'"; - path = std::string("'") + path + "'"; - name = padStringRight(name, 14); - os << " " << name << " " << path << std::endl; - } -} +static OptionList allowed_options; int main(int argc, char *argv[]) { - int retval = 0; - - /* - Initialization - */ + int retval; log_add_output_maxlev(&main_stderr_log_out, LMT_ACTION); log_add_output_all_levs(&main_dstream_no_stderr_log_out); log_register_thread("main"); - /* - Parse command line - */ - - // List all allowed options - std::map allowed_options; - allowed_options.insert(std::make_pair("help", ValueSpec(VALUETYPE_FLAG, - _("Show allowed options")))); - allowed_options.insert(std::make_pair("version", ValueSpec(VALUETYPE_FLAG, - _("Show version information")))); - allowed_options.insert(std::make_pair("config", ValueSpec(VALUETYPE_STRING, - _("Load configuration from specified file")))); - allowed_options.insert(std::make_pair("port", ValueSpec(VALUETYPE_STRING, - _("Set network port (UDP)")))); - allowed_options.insert(std::make_pair("disable-unittests", ValueSpec(VALUETYPE_FLAG, - _("Disable unit tests")))); - allowed_options.insert(std::make_pair("enable-unittests", ValueSpec(VALUETYPE_FLAG, - _("Enable unit tests")))); - allowed_options.insert(std::make_pair("map-dir", ValueSpec(VALUETYPE_STRING, - _("Same as --world (deprecated)")))); - allowed_options.insert(std::make_pair("world", ValueSpec(VALUETYPE_STRING, - _("Set world path (implies local game) ('list' lists all)")))); - allowed_options.insert(std::make_pair("worldname", ValueSpec(VALUETYPE_STRING, - _("Set world by name (implies local game)")))); - allowed_options.insert(std::make_pair("quiet", ValueSpec(VALUETYPE_FLAG, - _("Print to console errors only")))); - allowed_options.insert(std::make_pair("info", ValueSpec(VALUETYPE_FLAG, - _("Print more information to console")))); - allowed_options.insert(std::make_pair("verbose", ValueSpec(VALUETYPE_FLAG, - _("Print even more information to console")))); - allowed_options.insert(std::make_pair("trace", ValueSpec(VALUETYPE_FLAG, - _("Print enormous amounts of information to log and console")))); - allowed_options.insert(std::make_pair("logfile", ValueSpec(VALUETYPE_STRING, - _("Set logfile path ('' = no logging)")))); - allowed_options.insert(std::make_pair("gameid", ValueSpec(VALUETYPE_STRING, - _("Set gameid (\"--gameid list\" prints available ones)")))); - allowed_options.insert(std::make_pair("migrate", ValueSpec(VALUETYPE_STRING, - _("Migrate from current map backend to another (Only works when using minetestserver or with --server)")))); -#ifndef SERVER - allowed_options.insert(std::make_pair("videomodes", ValueSpec(VALUETYPE_FLAG, - _("Show available video modes")))); - allowed_options.insert(std::make_pair("speedtests", ValueSpec(VALUETYPE_FLAG, - _("Run speed tests")))); - allowed_options.insert(std::make_pair("address", ValueSpec(VALUETYPE_STRING, - _("Address to connect to. ('' = local game)")))); - allowed_options.insert(std::make_pair("random-input", ValueSpec(VALUETYPE_FLAG, - _("Enable random user input, for testing")))); - allowed_options.insert(std::make_pair("server", ValueSpec(VALUETYPE_FLAG, - _("Run dedicated server")))); - allowed_options.insert(std::make_pair("name", ValueSpec(VALUETYPE_STRING, - _("Set player name")))); - allowed_options.insert(std::make_pair("password", ValueSpec(VALUETYPE_STRING, - _("Set password")))); - allowed_options.insert(std::make_pair("go", ValueSpec(VALUETYPE_FLAG, - _("Disable main menu")))); -#endif Settings cmd_args; - - bool ret = cmd_args.parseCommandLine(argc, argv, allowed_options); - - if (ret == false || cmd_args.getFlag("help") || cmd_args.exists("nonopt1")) { - dstream << _("Allowed options:") << std::endl; - for(std::map::iterator - i = allowed_options.begin(); - i != allowed_options.end(); ++i) { - std::ostringstream os1(std::ios::binary); - os1 << " --"<first; - if (i->second.type == VALUETYPE_FLAG) { - } else - os1 << _(" "); - dstream << padStringRight(os1.str(), 24); - - if (i->second.help != NULL) - dstream << i->second.help; - dstream << std::endl; - } - - return cmd_args.getFlag("help") ? 0 : 1; + bool cmd_args_ok = get_cmdline_opts(argc, argv, &cmd_args); + if (!cmd_args_ok + || cmd_args.getFlag("help") + || cmd_args.exists("nonopt1")) { + print_help(allowed_options); + return cmd_args_ok ? 0 : 1; } if (cmd_args.getFlag("version")) { -#ifdef SERVER - dstream << "minetestserver " << minetest_version_hash << std::endl; -#else - dstream << "Minetest " << minetest_version_hash << std::endl; - dstream << "Using Irrlicht " << IRRLICHT_SDK_VERSION << std::endl; -#endif - dstream << "Build info: " << minetest_build_info << std::endl; + print_version(); return 0; } - /* - Low-level initialization - */ - - // Quiet mode, print errors only - if (cmd_args.getFlag("quiet")) { - log_remove_output(&main_stderr_log_out); - log_add_output_maxlev(&main_stderr_log_out, LMT_ERROR); - } - // If trace is enabled, enable logging of certain things - if (cmd_args.getFlag("trace")) { - dstream << _("Enabling trace level debug output") << std::endl; - log_trace_level_enabled = true; - dout_con_ptr = &verbosestream; // this is somewhat old crap - socket_enable_debug_output = true; // socket doesn't use log.h - } - // In certain cases, output info level on stderr - if (cmd_args.getFlag("info") || cmd_args.getFlag("verbose") || - cmd_args.getFlag("trace") || cmd_args.getFlag("speedtests")) - log_add_output(&main_stderr_log_out, LMT_INFO); - // In certain cases, output verbose level on stderr - if (cmd_args.getFlag("verbose") || cmd_args.getFlag("trace")) - log_add_output(&main_stderr_log_out, LMT_VERBOSE); + setup_log_params(cmd_args); porting::signal_handler_init(); - bool &kill = *porting::signal_handler_killstatus(); - porting::initializePaths(); -#ifdef __ANDROID__ - porting::initAndroid(); - - porting::setExternalStorageDir(porting::jnienv); - if (!fs::PathExists(porting::path_user)) { - fs::CreateDir(porting::path_user); + if (!create_userdata_path()) { + errorstream << "Cannot create user data directory" << std::endl; + return 1; } - porting::copyAssets(); -#else - // Create user data directory - fs::CreateDir(porting::path_user); -#endif - - infostream << "path_share = " << porting::path_share << std::endl; - infostream << "path_user = " << porting::path_user << std::endl; // Initialize debug stacks debug_stacks_init(); @@ -917,58 +820,330 @@ int main(int argc, char *argv[]) // List gameids if requested if (cmd_args.exists("gameid") && cmd_args.get("gameid") == "list") { - std::set gameids = getAvailableGameIds(); - for(std::set::const_iterator i = gameids.begin(); - i != gameids.end(); i++) - dstream<<(*i)< worldspecs = getAvailableWorlds(); - print_worldspecs(worldspecs, dstream); + list_worlds(); return 0; } - // Print startup message - infostream<set("server_dedicated", + game_params.is_dedicated_server ? "true" : "false"); + + if (game_params.is_dedicated_server) + return run_dedicated_server(game_params, cmd_args) ? 0 : 1; + +#ifndef SERVER + ClientLauncher launcher; + retval = launcher.run(game_params, cmd_args) ? 0 : 1; +#else + retval = 0; +#endif + + // Update configuration file + if (g_settings_path != "") + g_settings->updateConfigFile(g_settings_path.c_str()); + + print_modified_quicktune_values(); + + // Stop httpfetch thread (if started) + httpfetch_cleanup(); + + END_DEBUG_EXCEPTION_HANDLER(errorstream) + + return retval; +} + + +/***************************************************************************** + * Startup / Init + *****************************************************************************/ + + +static bool get_cmdline_opts(int argc, char *argv[], Settings *cmd_args) +{ + set_allowed_options(&allowed_options); + + return cmd_args->parseCommandLine(argc, argv, allowed_options); +} + +static void set_allowed_options(OptionList *allowed_options) +{ + allowed_options->clear(); + + allowed_options->insert(std::make_pair("help", ValueSpec(VALUETYPE_FLAG, + _("Show allowed options")))); + allowed_options->insert(std::make_pair("version", ValueSpec(VALUETYPE_FLAG, + _("Show version information")))); + allowed_options->insert(std::make_pair("config", ValueSpec(VALUETYPE_STRING, + _("Load configuration from specified file")))); + allowed_options->insert(std::make_pair("port", ValueSpec(VALUETYPE_STRING, + _("Set network port (UDP)")))); + allowed_options->insert(std::make_pair("disable-unittests", ValueSpec(VALUETYPE_FLAG, + _("Disable unit tests")))); + allowed_options->insert(std::make_pair("enable-unittests", ValueSpec(VALUETYPE_FLAG, + _("Enable unit tests")))); + allowed_options->insert(std::make_pair("map-dir", ValueSpec(VALUETYPE_STRING, + _("Same as --world (deprecated)")))); + allowed_options->insert(std::make_pair("world", ValueSpec(VALUETYPE_STRING, + _("Set world path (implies local game) ('list' lists all)")))); + allowed_options->insert(std::make_pair("worldname", ValueSpec(VALUETYPE_STRING, + _("Set world by name (implies local game)")))); + allowed_options->insert(std::make_pair("quiet", ValueSpec(VALUETYPE_FLAG, + _("Print to console errors only")))); + allowed_options->insert(std::make_pair("info", ValueSpec(VALUETYPE_FLAG, + _("Print more information to console")))); + allowed_options->insert(std::make_pair("verbose", ValueSpec(VALUETYPE_FLAG, + _("Print even more information to console")))); + allowed_options->insert(std::make_pair("trace", ValueSpec(VALUETYPE_FLAG, + _("Print enormous amounts of information to log and console")))); + allowed_options->insert(std::make_pair("logfile", ValueSpec(VALUETYPE_STRING, + _("Set logfile path ('' = no logging)")))); + allowed_options->insert(std::make_pair("gameid", ValueSpec(VALUETYPE_STRING, + _("Set gameid (\"--gameid list\" prints available ones)")))); + allowed_options->insert(std::make_pair("migrate", ValueSpec(VALUETYPE_STRING, + _("Migrate from current map backend to another (Only works when using minetestserver or with --server)")))); +#ifndef SERVER + allowed_options->insert(std::make_pair("videomodes", ValueSpec(VALUETYPE_FLAG, + _("Show available video modes")))); + allowed_options->insert(std::make_pair("speedtests", ValueSpec(VALUETYPE_FLAG, + _("Run speed tests")))); + allowed_options->insert(std::make_pair("address", ValueSpec(VALUETYPE_STRING, + _("Address to connect to. ('' = local game)")))); + allowed_options->insert(std::make_pair("random-input", ValueSpec(VALUETYPE_FLAG, + _("Enable random user input, for testing")))); + allowed_options->insert(std::make_pair("server", ValueSpec(VALUETYPE_FLAG, + _("Run dedicated server")))); + allowed_options->insert(std::make_pair("name", ValueSpec(VALUETYPE_STRING, + _("Set player name")))); + allowed_options->insert(std::make_pair("password", ValueSpec(VALUETYPE_STRING, + _("Set password")))); + allowed_options->insert(std::make_pair("go", ValueSpec(VALUETYPE_FLAG, + _("Disable main menu")))); +#endif + +} + +static void print_help(const OptionList &allowed_options) +{ + dstream << _("Allowed options:") << std::endl; + print_allowed_options(allowed_options); +} + +static void print_allowed_options(const OptionList &allowed_options) +{ + for (OptionList::const_iterator i = allowed_options.begin(); + i != allowed_options.end(); ++i) { + std::ostringstream os1(std::ios::binary); + os1 << " --" << i->first; + if (i->second.type != VALUETYPE_FLAG) + os1 << _(" "); + + dstream << padStringRight(os1.str(), 24); + + if (i->second.help != NULL) + dstream << i->second.help; + + dstream << std::endl; + } +} + +static void print_version() +{ +#ifdef SERVER + dstream << "minetestserver " << minetest_version_hash << std::endl; +#else + dstream << "Minetest " << minetest_version_hash << std::endl; + dstream << "Using Irrlicht " << IRRLICHT_SDK_VERSION << std::endl; +#endif + dstream << "Build info: " << minetest_build_info << std::endl; +} + +static void list_game_ids() +{ + std::set gameids = getAvailableGameIds(); + for (std::set::const_iterator i = gameids.begin(); + i != gameids.end(); i++) + dstream << (*i) < worldspecs = getAvailableWorlds(); + print_worldspecs(worldspecs, dstream); +} + +static void print_worldspecs(const std::vector &worldspecs, + std::ostream &os) +{ + for (size_t i = 0; i < worldspecs.size(); i++) { + std::string name = worldspecs[i].name; + std::string path = worldspecs[i].path; + if (name.find(" ") != std::string::npos) + name = std::string("'") + name + "'"; + path = std::string("'") + path + "'"; + name = padStringRight(name, 14); + os << " " << name << " " << path << std::endl; + } +} + +static void print_modified_quicktune_values() +{ + bool header_printed = false; + std::vector names = getQuicktuneNames(); + + for (u32 i = 0; i < names.size(); i++) { + QuicktuneValue val = getQuicktuneValue(names[i]); + if (!val.modified) + continue; + if (!header_printed) { + dstream << "Modified quicktune values:" << std::endl; + header_printed = true; + } + dstream << names[i] << " = " << val.getString() << std::endl; + } +} + +static void setup_log_params(const Settings &cmd_args) +{ + // Quiet mode, print errors only + if (cmd_args.getFlag("quiet")) { + log_remove_output(&main_stderr_log_out); + log_add_output_maxlev(&main_stderr_log_out, LMT_ERROR); + } + + // If trace is enabled, enable logging of certain things + if (cmd_args.getFlag("trace")) { + dstream << _("Enabling trace level debug output") << std::endl; + log_trace_level_enabled = true; + dout_con_ptr = &verbosestream; // this is somewhat old crap + socket_enable_debug_output = true; // socket doesn't use log.h + } + + // In certain cases, output info level on stderr + if (cmd_args.getFlag("info") || cmd_args.getFlag("verbose") || + cmd_args.getFlag("trace") || cmd_args.getFlag("speedtests")) + log_add_output(&main_stderr_log_out, LMT_INFO); + + // In certain cases, output verbose level on stderr + if (cmd_args.getFlag("verbose") || cmd_args.getFlag("trace")) + log_add_output(&main_stderr_log_out, LMT_VERBOSE); +} + +static bool create_userdata_path() +{ + bool success; + +#ifdef __ANDROID__ + porting::initAndroid(); + + porting::setExternalStorageDir(porting::jnienv); + if (!fs::PathExists(porting::path_user)) { + success = fs::CreateDir(porting::path_user); + } + porting::copyAssets(); +#else + // Create user data directory + success = fs::CreateDir(porting::path_user); +#endif + + infostream << "path_share = " << porting::path_share << std::endl; + infostream << "path_user = " << porting::path_user << std::endl; + + return success; +} + +static bool init_common(int *log_level, const Settings &cmd_args) +{ + startup_message(); set_default_settings(g_settings); // Initialize sockets sockets_init(); atexit(sockets_cleanup); - /* - Read config file - */ + if (!read_config_file(cmd_args)) + return false; + init_debug_streams(log_level, cmd_args); + + // Initialize random seed + srand(time(0)); + mysrand(time(0)); + + // Initialize HTTP fetcher + httpfetch_init(g_settings->getS32("curl_parallel_limit")); + +#ifdef _MSC_VER + init_gettext((porting::path_share + DIR_DELIM + "locale").c_str(), + g_settings->get("language"), argc, argv); +#else + init_gettext((porting::path_share + DIR_DELIM + "locale").c_str(), + g_settings->get("language")); +#endif + + return true; +} + +static void startup_message() +{ + infostream << PROJECT_NAME << " " << _("with") + << " SER_FMT_VER_HIGHEST_READ=" + << (int)SER_FMT_VER_HIGHEST_READ << ", " + << minetest_build_info << std::endl; +} + +static bool read_config_file(const Settings &cmd_args) +{ // Path of configuration file in use - g_settings_path = ""; + assert(g_settings_path == ""); // Sanity check if (cmd_args.exists("config")) { bool r = g_settings->readConfigFile(cmd_args.get("config").c_str()); - if (r == false) { + if (!r) { errorstream << "Could not read configuration from \"" - << cmd_args.get("config") << "\"" << std::endl; - return 1; + << cmd_args.get("config") << "\"" << std::endl; + return false; } g_settings_path = cmd_args.get("config"); } else { std::vector filenames; - filenames.push_back(porting::path_user + - DIR_DELIM + "minetest.conf"); + filenames.push_back(porting::path_user + DIR_DELIM + "minetest.conf"); // Legacy configuration file location filenames.push_back(porting::path_user + DIR_DELIM + ".." + DIR_DELIM + "minetest.conf"); + #if RUN_IN_PLACE // Try also from a lower level (to aid having the same configuration // for many RUN_IN_PLACE installs) @@ -976,7 +1151,7 @@ int main(int argc, char *argv[]) DIR_DELIM + ".." + DIR_DELIM + ".." + DIR_DELIM + "minetest.conf"); #endif - for(u32 i = 0; i < filenames.size(); i++) { + for (size_t i = 0; i < filenames.size(); i++) { bool r = g_settings->readConfigFile(filenames[i].c_str()); if (r) { g_settings_path = filenames[i]; @@ -989,522 +1164,446 @@ int main(int argc, char *argv[]) g_settings_path = filenames[0]; } - // Initialize debug streams -#define DEBUGFILE "debug.txt" + return true; +} + +static void init_debug_streams(int *log_level, const Settings &cmd_args) +{ #if RUN_IN_PLACE std::string logfile = DEBUGFILE; #else - std::string logfile = porting::path_user+DIR_DELIM+DEBUGFILE; + std::string logfile = porting::path_user + DIR_DELIM + DEBUGFILE; #endif if (cmd_args.exists("logfile")) logfile = cmd_args.get("logfile"); log_remove_output(&main_dstream_no_stderr_log_out); - int loglevel = g_settings->getS32("debug_log_level"); + *log_level = g_settings->getS32("debug_log_level"); - if (loglevel == 0) //no logging + if (*log_level == 0) //no logging logfile = ""; - else if (loglevel > 0 && loglevel <= LMT_NUM_VALUES) - log_add_output_maxlev(&main_dstream_no_stderr_log_out, - (LogMessageLevel)(loglevel - 1)); + if (*log_level < 0) { + dstream << "WARNING: Supplied debug_log_level < 0; Using 0" << std::endl; + *log_level = 0; + } else if (*log_level > LMT_NUM_VALUES) { + dstream << "WARNING: Supplied debug_log_level > " << LMT_NUM_VALUES + << "; Using " << LMT_NUM_VALUES << std::endl; + *log_level = LMT_NUM_VALUES; + } - if (logfile != "") - debugstreams_init(false, logfile.c_str()); - else - debugstreams_init(false, NULL); + log_add_output_maxlev(&main_dstream_no_stderr_log_out, + (LogMessageLevel)(*log_level - 1)); + + debugstreams_init(false, logfile == "" ? NULL : logfile.c_str()); infostream << "logfile = " << logfile << std::endl; - // Initialize random seed - srand(time(0)); - mysrand(time(0)); + atexit(debugstreams_deinit); +} - // Initialize HTTP fetcher - httpfetch_init(g_settings->getS32("curl_parallel_limit")); +static bool game_configure(GameParams *game_params, const Settings &cmd_args) +{ + game_configure_port(game_params, cmd_args); -#ifndef __ANDROID__ - /* - Run unit tests - */ - if ((ENABLE_TESTS && cmd_args.getFlag("disable-unittests") == false) - || cmd_args.getFlag("enable-unittests") == true) { - run_tests(); + if (!game_configure_world(game_params, cmd_args)) { + errorstream << "No world path specified or found." << std::endl; + return false; } -#endif -#ifdef _MSC_VER - init_gettext((porting::path_share + DIR_DELIM + "locale").c_str(), - g_settings->get("language"), argc, argv); -#else - init_gettext((porting::path_share + DIR_DELIM + "locale").c_str(), - g_settings->get("language")); -#endif - /* - Game parameters - */ + game_configure_subgame(game_params, cmd_args); - // Port - u16 port = 30000; + return true; +} + +static void game_configure_port(GameParams *game_params, const Settings &cmd_args) +{ if (cmd_args.exists("port")) - port = cmd_args.getU16("port"); - else if (g_settings->exists("port")) - port = g_settings->getU16("port"); - if (port == 0) - port = 30000; + game_params->socket_port = cmd_args.getU16("port"); + else + game_params->socket_port = g_settings->getU16("port"); - // World directory + if (game_params->socket_port == 0) + game_params->socket_port = DEFAULT_SERVER_PORT; +} + +static bool game_configure_world(GameParams *game_params, const Settings &cmd_args) +{ + if (get_world_from_cmdline(game_params, cmd_args)) + return true; + if (get_world_from_config(game_params, cmd_args)) + return true; + + return auto_select_world(game_params); +} + +static bool get_world_from_cmdline(GameParams *game_params, const Settings &cmd_args) +{ std::string commanded_world = ""; - if (cmd_args.exists("world")) - commanded_world = cmd_args.get("world"); - else if (cmd_args.exists("map-dir")) - commanded_world = cmd_args.get("map-dir"); - else if (cmd_args.exists("nonopt0")) // First nameless argument - commanded_world = cmd_args.get("nonopt0"); - else if (g_settings->exists("map-dir")) - commanded_world = g_settings->get("map-dir"); // World name std::string commanded_worldname = ""; if (cmd_args.exists("worldname")) commanded_worldname = cmd_args.get("worldname"); - // Strip world.mt from commanded_world - { - std::string worldmt = "world.mt"; - if (commanded_world.size() > worldmt.size() && - commanded_world.substr(commanded_world.size() - worldmt.size()) - == worldmt) { - dstream << _("Supplied world.mt file - stripping it off.") << std::endl; - commanded_world = commanded_world.substr(0, - commanded_world.size() - worldmt.size()); - } - } - // If a world name was specified, convert it to a path if (commanded_worldname != "") { // Get information about available worlds std::vector worldspecs = getAvailableWorlds(); bool found = false; - for(u32 i = 0; i < worldspecs.size(); i++) { + for (u32 i = 0; i < worldspecs.size(); i++) { std::string name = worldspecs[i].name; if (name == commanded_worldname) { - if (commanded_world != "") { - dstream << _("--worldname takes precedence over previously " - "selected world.") << std::endl; - } + dstream << _("Using world specified by --worldname on the " + "command line") << std::endl; commanded_world = worldspecs[i].path; found = true; break; } } if (!found) { - dstream << _("World") << " '"<world_path = get_clean_world_path(commanded_world); + return commanded_world != ""; } - // Gamespec + if (cmd_args.exists("world")) + commanded_world = cmd_args.get("world"); + else if (cmd_args.exists("map-dir")) + commanded_world = cmd_args.get("map-dir"); + else if (cmd_args.exists("nonopt0")) // First nameless argument + commanded_world = cmd_args.get("nonopt0"); + + game_params->world_path = get_clean_world_path(commanded_world); + return commanded_world != ""; +} + +static bool get_world_from_config(GameParams *game_params, const Settings &cmd_args) +{ + // World directory + std::string commanded_world = ""; + + if (g_settings->exists("map-dir")) + commanded_world = g_settings->get("map-dir"); + + game_params->world_path = get_clean_world_path(commanded_world); + + return commanded_world != ""; +} + +static bool auto_select_world(GameParams *game_params) +{ + // No world was specified; try to select it automatically + // Get information about available worlds + + verbosestream << _("Determining world path") << std::endl; + + std::vector worldspecs = getAvailableWorlds(); + std::string world_path; + + // If there is only a single world, use it + if (worldspecs.size() == 1) { + world_path = worldspecs[0].path; + dstream <<_("Automatically selecting world at") << " [" + << world_path << "]" << std::endl; + // If there are multiple worlds, list them + } else if (worldspecs.size() > 1 && game_params->is_dedicated_server) { + dstream << _("Multiple worlds are available.") << std::endl; + dstream << _("Please select one using --worldname " + " or --world ") << std::endl; + print_worldspecs(worldspecs, dstream); + return false; + // If there are no worlds, automatically create a new one + } else { + // This is the ultimate default world path + world_path = porting::path_user + DIR_DELIM + "worlds" + + DIR_DELIM + "world"; + infostream << "Creating default world at [" + << world_path << "]" << std::endl; + } + + assert(world_path != ""); + game_params->world_path = world_path; + return true; +} + +static std::string get_clean_world_path(const std::string &path) +{ + const std::string worldmt = "world.mt"; + std::string clean_path; + + if (path.size() > worldmt.size() + && path.substr(path.size() - worldmt.size()) == worldmt) { + dstream << _("Supplied world.mt file - stripping it off.") << std::endl; + clean_path = path.substr(0, path.size() - worldmt.size()); + } else { + clean_path = path; + } + return path; +} + + +static bool game_configure_subgame(GameParams *game_params, const Settings &cmd_args) +{ + bool success; + + success = get_game_from_cmdline(game_params, cmd_args); + if (!success) + success = determine_subgame(game_params); + + return success; +} + +static bool get_game_from_cmdline(GameParams *game_params, const Settings &cmd_args) +{ SubgameSpec commanded_gamespec; + if (cmd_args.exists("gameid")) { std::string gameid = cmd_args.get("gameid"); commanded_gamespec = findSubgame(gameid); if (!commanded_gamespec.isValid()) { errorstream << "Game \"" << gameid << "\" not found" << std::endl; - return 1; + return false; + } + dstream << _("Using game specified by --gameid on the command line") + << std::endl; + game_params->game_spec = commanded_gamespec; + return true; + } + + return false; +} + +static bool determine_subgame(GameParams *game_params) +{ + SubgameSpec gamespec; + + assert(game_params->world_path != ""); // pre-condition + + verbosestream << _("Determining gameid/gamespec") << std::endl; + // If world doesn't exist + if (game_params->world_path != "" + && !getWorldExists(game_params->world_path)) { + // Try to take gamespec from command line + if (game_params->game_spec.isValid()) { + gamespec = game_params->game_spec; + infostream << "Using commanded gameid [" << gamespec.id << "]" << std::endl; + } else { // Otherwise we will be using "minetest" + gamespec = findSubgame(g_settings->get("default_game")); + infostream << "Using default gameid [" << gamespec.id << "]" << std::endl; + } + } else { // World exists + std::string world_gameid = getWorldGameId(game_params->world_path, false); + // If commanded to use a gameid, do so + if (game_params->game_spec.isValid()) { + gamespec = game_params->game_spec; + if (game_params->game_spec.id != world_gameid) { + errorstream << "WARNING: Using commanded gameid [" + << gamespec.id << "]" << " instead of world gameid [" + << world_gameid << "]" << std::endl; + } + } else { + // If world contains an embedded game, use it; + // Otherwise find world from local system. + gamespec = findWorldSubgame(game_params->world_path); + infostream << "Using world gameid [" << gamespec.id << "]" << std::endl; } } + if (!gamespec.isValid()) { + errorstream << "Subgame [" << gamespec.id << "] could not be found." + << std::endl; + return false; + } - /* - Run dedicated server if asked to or no other option - */ -#ifdef SERVER - bool run_dedicated_server = true; -#else - bool run_dedicated_server = cmd_args.getFlag("server"); + game_params->game_spec = gamespec; + return true; +} + + +/***************************************************************************** + * Dedicated server + *****************************************************************************/ +static bool run_dedicated_server(const GameParams &game_params, const Settings &cmd_args) +{ + DSTACK("Dedicated server branch"); + + verbosestream << _("Using world path") << " [" + << game_params.world_path << "]" << std::endl; + verbosestream << _("Using gameid") << " [" + << game_params.game_spec.id << "]" << std::endl; + + // Bind address + std::string bind_str = g_settings->get("bind_address"); + Address bind_addr(0, 0, 0, 0, game_params.socket_port); + + if (g_settings->getBool("ipv6_server")) { + bind_addr.setAddress((IPv6AddressBytes*) NULL); + } + try { + bind_addr.Resolve(bind_str.c_str()); + } catch (ResolveError &e) { + infostream << "Resolving bind address \"" << bind_str + << "\" failed: " << e.what() + << " -- Listening on all addresses." << std::endl; + } + if (bind_addr.isIPv6() && !g_settings->getBool("enable_ipv6")) { + errorstream << "Unable to listen on " + << bind_addr.serializeString() + << L" because IPv6 is disabled" << std::endl; + return false; + } + + // Create server + Server server(game_params.world_path, + game_params.game_spec, false, bind_addr.isIPv6()); + + // Database migration + if (cmd_args.exists("migrate")) + return migrate_database(game_params, cmd_args, &server); + + server.start(bind_addr); + + // Run server + bool &kill = *porting::signal_handler_killstatus(); + dedicated_server_loop(server, kill); + + return true; +} + +static bool migrate_database(const GameParams &game_params, const Settings &cmd_args, + Server *server) +{ + Settings world_mt; + bool success = world_mt.readConfigFile((game_params.world_path + + DIR_DELIM + "world.mt").c_str()); + if (!success) { + errorstream << "Cannot read world.mt" << std::endl; + return false; + } + + if (!world_mt.exists("backend")) { + errorstream << "Please specify your current backend in world.mt file:" + << std::endl << " backend = {sqlite3|leveldb|redis|dummy}" + << std::endl; + return false; + } + + std::string backend = world_mt.get("backend"); + Database *new_db; + std::string migrate_to = cmd_args.get("migrate"); + + if (backend == migrate_to) { + errorstream << "Cannot migrate: new backend is same as the old one" + << std::endl; + return false; + } + + if (migrate_to == "sqlite3") + new_db = new Database_SQLite3(&(ServerMap&)server->getMap(), + game_params.world_path); +#if USE_LEVELDB + else if (migrate_to == "leveldb") + new_db = new Database_LevelDB(&(ServerMap&)server->getMap(), + game_params.world_path); #endif - g_settings->set("server_dedicated", run_dedicated_server ? "true" : "false"); - if (run_dedicated_server) - { - DSTACK("Dedicated server branch"); - // Create time getter if built with Irrlicht +#if USE_REDIS + else if (migrate_to == "redis") + new_db = new Database_Redis(&(ServerMap&)server->getMap(), + game_params.requested_world_path); +#endif + else { + errorstream << "Migration to " << migrate_to << " is not supported" + << std::endl; + return false; + } + + std::list blocks; + ServerMap &old_map = ((ServerMap&)server->getMap()); + old_map.listAllLoadableBlocks(blocks); + int count = 0; + new_db->beginSave(); + for (std::list::iterator i = blocks.begin(); i != blocks.end(); i++) { + MapBlock *block = old_map.loadBlock(*i); + if (!block) { + errorstream << "Failed to load block " << PP(*i) << ", skipping it."; + } else { + old_map.saveBlock(block, new_db); + MapSector *sector = old_map.getSectorNoGenerate(v2s16(i->X, i->Z)); + sector->deleteBlock(block); + } + ++count; + if (count % 500 == 0) + actionstream << "Migrated " << count << " blocks " + << (100.0 * count / blocks.size()) << "% completed" << std::endl; + } + new_db->endSave(); + delete new_db; + + actionstream << "Successfully migrated " << count << " blocks" << std::endl; + world_mt.set("backend", migrate_to); + if (!world_mt.updateConfigFile( + (game_params.world_path+ DIR_DELIM + "world.mt").c_str())) + errorstream << "Failed to update world.mt!" << std::endl; + else + actionstream << "world.mt updated" << std::endl; + + return true; +} + + +/***************************************************************************** + * Client + *****************************************************************************/ #ifndef SERVER - g_timegetter = new SimpleTimeGetter(); -#endif - - // World directory - std::string world_path; - verbosestream << _("Determining world path") << std::endl; - bool is_legacy_world = false; - // If a world was commanded, use it - if (commanded_world != "") { - world_path = commanded_world; - infostream << "Using commanded world path [" << world_path << "]" - << std::endl; - } else { // No world was specified; try to select it automatically - // Get information about available worlds - std::vector worldspecs = getAvailableWorlds(); - // If a world name was specified, select it - if (commanded_worldname != "") { - world_path = ""; - for(u32 i = 0; i < worldspecs.size(); i++) { - std::string name = worldspecs[i].name; - if (name == commanded_worldname) { - world_path = worldspecs[i].path; - break; - } - } - if (world_path == "") { - dstream << _("World") << " '" << commanded_worldname << "' " << _("not " - "available. Available worlds:") << std::endl; - print_worldspecs(worldspecs, dstream); - return 1; - } - } - // If there is only a single world, use it - if (worldspecs.size() == 1) { - world_path = worldspecs[0].path; - dstream <<_("Automatically selecting world at") << " [" - << world_path << "]" << std::endl; - // If there are multiple worlds, list them - } else if (worldspecs.size() > 1) { - dstream << _("Multiple worlds are available.") << std::endl; - dstream << _("Please select one using --worldname " - " or --world ") << std::endl; - print_worldspecs(worldspecs, dstream); - return 1; - // If there are no worlds, automatically create a new one - } else { - // This is the ultimate default world path - world_path = porting::path_user + DIR_DELIM + "worlds" + - DIR_DELIM + "world"; - infostream << "Creating default world at [" - << world_path << "]" << std::endl; - } - } - - if (world_path == "") { - errorstream << "No world path specified or found." << std::endl; - return 1; - } - verbosestream << _("Using world path") << " [" << world_path << "]" << std::endl; - - // We need a gamespec. - SubgameSpec gamespec; - verbosestream << _("Determining gameid/gamespec") << std::endl; - // If world doesn't exist - if (!getWorldExists(world_path)) { - // Try to take gamespec from command line - if (commanded_gamespec.isValid()) { - gamespec = commanded_gamespec; - infostream << "Using commanded gameid [" << gamespec.id << "]" << std::endl; - } else { // Otherwise we will be using "minetest" - gamespec = findSubgame(g_settings->get("default_game")); - infostream << "Using default gameid [" << gamespec.id << "]" << std::endl; - } - } else { // World exists - std::string world_gameid = getWorldGameId(world_path, is_legacy_world); - // If commanded to use a gameid, do so - if (commanded_gamespec.isValid()) { - gamespec = commanded_gamespec; - if (commanded_gamespec.id != world_gameid) { - errorstream << "WARNING: Using commanded gameid [" - << gamespec.id << "]" << " instead of world gameid [" - << world_gameid << "]" << std::endl; - } - } else { - // If world contains an embedded game, use it; - // Otherwise find world from local system. - gamespec = findWorldSubgame(world_path); - infostream << "Using world gameid [" << gamespec.id << "]" << std::endl; - } - } - if (!gamespec.isValid()) { - errorstream << "Subgame [" << gamespec.id << "] could not be found." - << std::endl; - return 1; - } - verbosestream << _("Using gameid") << " [" << gamespec.id<<"]" << std::endl; - - // Bind address - std::string bind_str = g_settings->get("bind_address"); - Address bind_addr(0, 0, 0, 0, port); - - if (g_settings->getBool("ipv6_server")) { - bind_addr.setAddress((IPv6AddressBytes*) NULL); - } - try { - bind_addr.Resolve(bind_str.c_str()); - } catch (ResolveError &e) { - infostream << "Resolving bind address \"" << bind_str - << "\" failed: " << e.what() - << " -- Listening on all addresses." << std::endl; - } - if (bind_addr.isIPv6() && !g_settings->getBool("enable_ipv6")) { - errorstream << "Unable to listen on " - << bind_addr.serializeString() - << L" because IPv6 is disabled" << std::endl; - return 1; - } - - // Create server - Server server(world_path, gamespec, false, bind_addr.isIPv6()); - - // Database migration - if (cmd_args.exists("migrate")) { - std::string migrate_to = cmd_args.get("migrate"); - Settings world_mt; - bool success = world_mt.readConfigFile((world_path + DIR_DELIM - + "world.mt").c_str()); - if (!success) { - errorstream << "Cannot read world.mt" << std::endl; - return 1; - } - if (!world_mt.exists("backend")) { - errorstream << "Please specify your current backend in world.mt file:" - << std::endl << " backend = {sqlite3|leveldb|redis|dummy}" << std::endl; - return 1; - } - std::string backend = world_mt.get("backend"); - Database *new_db; - if (backend == migrate_to) { - errorstream << "Cannot migrate: new backend is same" - <<" as the old one" << std::endl; - return 1; - } - if (migrate_to == "sqlite3") - new_db = new Database_SQLite3(&(ServerMap&)server.getMap(), world_path); - #if USE_LEVELDB - else if (migrate_to == "leveldb") - new_db = new Database_LevelDB(&(ServerMap&)server.getMap(), world_path); - #endif - #if USE_REDIS - else if (migrate_to == "redis") - new_db = new Database_Redis(&(ServerMap&)server.getMap(), world_path); - #endif - else { - errorstream << "Migration to " << migrate_to - << " is not supported" << std::endl; - return 1; - } - - std::list blocks; - ServerMap &old_map = ((ServerMap&)server.getMap()); - old_map.listAllLoadableBlocks(blocks); - int count = 0; - new_db->beginSave(); - for (std::list::iterator i = blocks.begin(); i != blocks.end(); i++) { - MapBlock *block = old_map.loadBlock(*i); - if (!block) { - errorstream << "Failed to load block " << PP(*i) << ", skipping it."; - } else { - old_map.saveBlock(block, new_db); - MapSector *sector = old_map.getSectorNoGenerate(v2s16(i->X, i->Z)); - sector->deleteBlock(block); - } - ++count; - if (count % 500 == 0) - actionstream << "Migrated " << count << " blocks " - << (100.0 * count / blocks.size()) << "% completed" << std::endl; - } - new_db->endSave(); - delete new_db; - - actionstream << "Successfully migrated " << count << " blocks" << std::endl; - world_mt.set("backend", migrate_to); - if (!world_mt.updateConfigFile((world_path + DIR_DELIM + "world.mt").c_str())) - errorstream << "Failed to update world.mt!" << std::endl; - else - actionstream << "world.mt updated" << std::endl; - - return 0; - } - - server.start(bind_addr); - - // Run server - dedicated_server_loop(server, kill); - - return 0; - } - -#ifndef SERVER // Exclude from dedicated server build - - /* - More parameters - */ - - std::string address = g_settings->get("address"); - if (commanded_world != "") - address = ""; - else if (cmd_args.exists("address")) - address = cmd_args.get("address"); - - std::string playername = g_settings->get("name"); - if (cmd_args.exists("name")) - playername = cmd_args.get("name"); - - bool skip_main_menu = cmd_args.getFlag("go"); - - /* - Device initialization - */ - - // Resolution selection - - bool fullscreen = g_settings->getBool("fullscreen"); - u16 screenW = g_settings->getU16("screenW"); - u16 screenH = g_settings->getU16("screenH"); - - // bpp, fsaa, vsync - - bool vsync = g_settings->getBool("vsync"); - u16 bits = g_settings->getU16("fullscreen_bpp"); - u16 fsaa = g_settings->getU16("fsaa"); - - // Determine driver - video::E_DRIVER_TYPE driverType = video::EDT_OPENGL; - static const char* driverids[] = { - "null", - "software", - "burningsvideo", - "direct3d8", - "direct3d9", - "opengl" -#ifdef _IRR_COMPILE_WITH_OGLES1_ - ,"ogles1" -#endif -#ifdef _IRR_COMPILE_WITH_OGLES2_ - ,"ogles2" -#endif - ,"invalid" - }; - - std::string driverstring = g_settings->get("video_driver"); - for (unsigned int i = 0; - i < (sizeof(driverids)/sizeof(driverids[0])); - i++) - { - if (strcasecmp(driverstring.c_str(), driverids[i]) == 0) { - driverType = (video::E_DRIVER_TYPE) i; - break; - } - - if (strcasecmp("invalid", driverids[i]) == 0) { - errorstream << "WARNING: Invalid video_driver specified; defaulting " - << "to opengl" << std::endl; - break; - } - } - - /* - List video modes if requested - */ - MyEventReceiver* receiver = new MyEventReceiver(); - - if (cmd_args.getFlag("videomodes")) { - IrrlichtDevice *nulldevice; - - SIrrlichtCreationParameters params = SIrrlichtCreationParameters(); - params.DriverType = video::EDT_NULL; - params.WindowSize = core::dimension2d(640, 480); - params.Bits = 24; - params.AntiAlias = fsaa; - params.Fullscreen = false; - params.Stencilbuffer = false; - params.Vsync = vsync; - params.EventReceiver = receiver; - params.HighPrecisionFPU = g_settings->getBool("high_precision_fpu"); - - nulldevice = createDeviceEx(params); - - if (nulldevice == 0) - return 1; - - dstream << _("Available video modes (WxHxD):") << std::endl; - - video::IVideoModeList *videomode_list = - nulldevice->getVideoModeList(); - - if (videomode_list == 0) { - nulldevice->drop(); - return 1; - } - - s32 videomode_count = videomode_list->getVideoModeCount(); - core::dimension2d videomode_res; - s32 videomode_depth; - for (s32 i = 0; i < videomode_count; ++i) { - videomode_res = videomode_list->getVideoModeResolution(i); - videomode_depth = videomode_list->getVideoModeDepth(i); - dstream<getDesktopResolution(); - videomode_depth = videomode_list->getDesktopDepth(); - dstream << videomode_res.Width << "x" << videomode_res.Height - << "x" << videomode_depth << std::endl; - - nulldevice->drop(); +ClientLauncher::~ClientLauncher() +{ + if (receiver) delete receiver; - return 0; + + if (input) + delete input; + + if (device) + device->drop(); + +#if USE_FREETYPE + if (use_freetype && font != NULL) + font->drop(); +#endif +} + +bool ClientLauncher::run(GameParams &game_params, const Settings &cmd_args) +{ + init_args(game_params, cmd_args); + + // List video modes if requested + if (list_video_modes) + return print_video_modes(); + + if (!init_engine(game_params.log_level)) { + errorstream << "Could not initialize game engine." << std::endl; + return false; } - /* - Create device and exit if creation failed - */ - SIrrlichtCreationParameters params = SIrrlichtCreationParameters(); - params.DriverType = driverType; - params.WindowSize = core::dimension2d(screenW, screenH); - params.Bits = bits; - params.AntiAlias = fsaa; - params.Fullscreen = fullscreen; - params.Stencilbuffer = false; - params.Vsync = vsync; - params.EventReceiver = receiver; - params.HighPrecisionFPU = g_settings->getBool("high_precision_fpu"); -#ifdef __ANDROID__ - params.PrivateData = porting::app_global; - params.OGLES2ShaderPath = std::string(porting::path_user + DIR_DELIM + - "media" + DIR_DELIM + "Shaders" + DIR_DELIM).c_str(); -#endif - - IrrlichtDevice * device = createDeviceEx(params); - - if (device == 0) { - delete receiver; - return 1; // could not create selected driver. - } - - // Map our log level to irrlicht engine one. - static const irr::ELOG_LEVEL irr_log_level[5] = { - ELL_NONE, - ELL_ERROR, - ELL_WARNING, - ELL_INFORMATION, -#if (IRRLICHT_VERSION_MAJOR == 1 && IRRLICHT_VERSION_MINOR < 8) - ELL_INFORMATION -#else - ELL_DEBUG -#endif - }; - - ILogger* irr_logger = device->getLogger(); - irr_logger->setLogLevel(irr_log_level[loglevel]); - - porting::initIrrlicht(device); late_init_default_settings(g_settings); - /* - Continue initialization - */ + // Speed tests (done after irrlicht is loaded to get timer) + if (cmd_args.getFlag("speedtests")) { + dstream << "Running speed tests" << std::endl; + speed_tests(); + return true; + } - video::IVideoDriver* driver = device->getVideoDriver(); + if (device->getVideoDriver() == NULL) { + errorstream << "Could not initialize video driver." << std::endl; + return false; + } /* This changes the minimum allowed number of vertices in a VBO. @@ -1518,37 +1617,21 @@ int main(int argc, char *argv[]) // Create game callback for menus g_gamecallback = new MainGameCallback(device); - /* - Speed tests (done after irrlicht is loaded to get timer) - */ - if (cmd_args.getFlag("speedtests")) - { - dstream << "Running speed tests" << std::endl; - SpeedTests(); - device->drop(); - return 0; - } - device->setResizable(true); - bool random_input = g_settings->getBool("random_input") - || cmd_args.getFlag("random-input"); - InputHandler *input = NULL; - - if (random_input) { + if (random_input) input = new RandomInputHandler(); - } else { - input = new RealInputHandler(device,receiver); - } + else + input = new RealInputHandler(device, receiver); - scene::ISceneManager* smgr = device->getSceneManager(); + smgr = device->getSceneManager(); guienv = device->getGUIEnvironment(); - gui::IGUISkin* skin = guienv->getSkin(); + skin = guienv->getSkin(); std::string font_path = g_settings->get("font_path"); - gui::IGUIFont *font; - #if USE_FREETYPE - bool use_freetype = g_settings->getBool("freetype"); + +#if USE_FREETYPE + if (use_freetype) { std::string fallback; if (is_yes(gettext("needs_fallback_font"))) @@ -1557,21 +1640,22 @@ int main(int argc, char *argv[]) font_path = g_settings->get(fallback + "font_path"); u32 font_shadow = g_settings->getU16(fallback + "font_shadow"); u32 font_shadow_alpha = g_settings->getU16(fallback + "font_shadow_alpha"); - font = gui::CGUITTFont::createTTFont(guienv, font_path.c_str(), font_size, - true, true, font_shadow, font_shadow_alpha); + font = gui::CGUITTFont::createTTFont(guienv, + font_path.c_str(), font_size, true, true, + font_shadow, font_shadow_alpha); } else { font = guienv->getFont(font_path.c_str()); } - #else +#else font = guienv->getFont(font_path.c_str()); - #endif +#endif if (font) skin->setFont(font); else - errorstream << "WARNING: Font file was not found." - << " Using default font." << std::endl; - // If font was not found, this will get us one - font = skin->getFont(); + errorstream << "WARNING: Font file was not found. Using default font." + << std::endl; + + font = skin->getFont(); // If font was not found, this will get us one assert(font); u32 text_height = font->getDimension(L"Hello, world!").Height; @@ -1589,13 +1673,12 @@ int main(int argc, char *argv[]) skin->setColor(gui::EGDC_FOCUSED_EDITABLE, video::SColor(255, 96, 134, 49)); #endif - // Create the menu clouds if (!g_menucloudsmgr) g_menucloudsmgr = smgr->createNewSceneManager(); if (!g_menuclouds) g_menuclouds = new Clouds(g_menucloudsmgr->getRootSceneNode(), - g_menucloudsmgr, -1, rand(), 100); + g_menucloudsmgr, -1, rand(), 100); g_menuclouds->update(v2f(0, 0), video::SColor(255, 200, 200, 255)); scene::ICameraSceneNode* camera; camera = g_menucloudsmgr->addCameraSceneNode(0, @@ -1608,36 +1691,27 @@ int main(int argc, char *argv[]) ChatBackend chat_backend; - /* - If an error occurs, this is set to something and the - menu-game loop is restarted. It is then displayed before - the menu. - */ + // If an error occurs, this is set to something by menu(). + // It is then displayed before the menu shows on the next call to menu() std::wstring error_message = L""; - // The password entered during the menu screen, - std::string password; - bool first_loop = true; /* Menu-game loop */ - while (device->run() && (kill == false) && - (g_gamecallback->shutdown_requested == false)) + bool retval = true; + bool *kill = porting::signal_handler_killstatus(); + + while (device->run() && !*kill && !g_gamecallback->shutdown_requested) { // Set the window caption - wchar_t* text = wgettext("Main Menu"); + wchar_t *text = wgettext("Main Menu"); device->setWindowCaption((std::wstring(L"Minetest [") + text + L"]").c_str()); delete[] text; - // This is used for catching disconnects - try - { + try { // This is used for catching disconnects - /* - Clear everything from the GUIEnvironment - */ guienv->clear(); /* @@ -1645,223 +1719,46 @@ int main(int argc, char *argv[]) custom gui elements directly on the screen. Otherwise they won't be automatically drawn. */ - guiroot = guienv->addStaticText(L"", - core::rect(0, 0, 10000, 10000)); + guiroot = guienv->addStaticText(L"", core::rect(0, 0, 10000, 10000)); - SubgameSpec gamespec; - WorldSpec worldspec; - bool simple_singleplayer_mode = false; + bool game_has_run = launch_game(&error_message, game_params, cmd_args); - // These are set up based on the menu and other things - std::string current_playername = "inv£lid"; - std::string current_password = ""; - std::string current_address = "does-not-exist"; - int current_port = 0; - - /* - Out-of-game menu loop. - - Loop quits when menu returns proper parameters. - */ - while (kill == false) { - // If skip_main_menu, only go through here once - if (skip_main_menu && !first_loop) { - kill = true; - break; - } - first_loop = false; - - // Cursor can be non-visible when coming from the game - #ifndef ANDROID - device->getCursorControl()->setVisible(true); - #endif - // Some stuff are left to scene manager when coming from the game - // (map at least?) - smgr->clear(); - - // Initialize menu data - MainMenuData menudata; - menudata.address = address; - menudata.name = playername; - menudata.port = itos(port); - menudata.errormessage = wide_to_narrow(error_message); - error_message = L""; - if (cmd_args.exists("password")) - menudata.password = cmd_args.get("password"); - - driver->setTextureCreationFlag(video::ETCF_CREATE_MIP_MAPS, g_settings->getBool("mip_map")); - - menudata.enable_public = g_settings->getBool("server_announce"); - - std::vector worldspecs = getAvailableWorlds(); - - // If a world was commanded, append and select it - if(commanded_world != "") { - worldspec.gameid = getWorldGameId(commanded_world, true); - worldspec.name = _("[--world parameter]"); - if(worldspec.gameid == "") { - worldspec.gameid = g_settings->get("default_game"); - worldspec.name += " [new]"; - } - worldspec.path = commanded_world; - } - - if (skip_main_menu == false) { - video::IVideoDriver* driver = device->getVideoDriver(); - - infostream << "Waiting for other menus" << std::endl; - while (device->run() && kill == false) { - if (noMenuActive()) - break; - driver->beginScene(true, true, - video::SColor(255, 128, 128, 128)); - guienv->drawAll(); - driver->endScene(); - // On some computers framerate doesn't seem to be - // automatically limited - sleep_ms(25); - } - infostream << "Waited for other menus" << std::endl; - - /* show main menu */ - GUIEngine mymenu(device, guiroot, &g_menumgr,smgr,&menudata,kill); - - //once finished you'll never end up here - smgr->clear(); - } - - if (menudata.errormessage != "") { - error_message = narrow_to_wide(menudata.errormessage); - continue; - } - - //update worldspecs (necessary as new world may have been created) - worldspecs = getAvailableWorlds(); - - if (menudata.name == "") - menudata.name = std::string("Guest") + itos(myrand_range(1000,9999)); - else - playername = menudata.name; - - password = translatePassword(playername, narrow_to_wide(menudata.password)); - //infostream<<"Main: password hash: '"<set("name", playername); - - // Break out of menu-game loop to shut down cleanly - if (device->run() == false || kill == true) - break; - - current_playername = playername; - current_password = password; - current_address = address; - current_port = port; - - // If using simple singleplayer mode, override - if (simple_singleplayer_mode) { - current_playername = "singleplayer"; - current_password = ""; - current_address = ""; - current_port = myrand_range(49152, 65535); - } else if (address != "") { - ServerListSpec server; - server["name"] = menudata.servername; - server["address"] = menudata.address; - server["port"] = menudata.port; - server["description"] = menudata.serverdescription; - ServerList::insert(server); - } - - if ((!skip_main_menu) && - (menudata.selected_world >= 0) && - (menudata.selected_world < (int)worldspecs.size())) { - g_settings->set("selected_world_path", - worldspecs[menudata.selected_world].path); - worldspec = worldspecs[menudata.selected_world]; - - } - - infostream <<"Selected world: " << worldspec.name - << " ["<run() == false || kill == true) { - if (g_settings_path != "") { + if (!device->run() || *kill) { + if (g_settings_path != "") g_settings->updateConfigFile(g_settings_path.c_str()); - } break; } if (current_playername.length() > PLAYERNAME_SIZE-1) { error_message = wgettext("Player name too long."); - playername = current_playername.substr(0,PLAYERNAME_SIZE-1); + playername = current_playername.substr(0, PLAYERNAME_SIZE-1); g_settings->set("name", playername); continue; } - /* - Run game - */ + device->getVideoDriver()->setTextureCreationFlag( + video::ETCF_CREATE_MIP_MAPS, g_settings->getBool("mip_map")); + #ifdef HAVE_TOUCHSCREENGUI - receiver->m_touchscreengui = new TouchScreenGUI(device, receiver); - g_touchscreengui = receiver->m_touchscreengui; + receiver->m_touchscreengui = new TouchScreenGUI(device, receiver); + g_touchscreengui = receiver->m_touchscreengui; #endif the_game( - &kill, + kill, random_input, input, device, @@ -1877,21 +1774,21 @@ int main(int argc, char *argv[]) simple_singleplayer_mode ); smgr->clear(); + #ifdef HAVE_TOUCHSCREENGUI - delete g_touchscreengui; - g_touchscreengui = NULL; - receiver->m_touchscreengui = NULL; + delete g_touchscreengui; + g_touchscreengui = NULL; + receiver->m_touchscreengui = NULL; #endif } //try - catch(con::PeerNotFoundException &e) - { + catch (con::PeerNotFoundException &e) { error_message = wgettext("Connection error (timed out?)"); errorstream << wide_to_narrow(error_message) << std::endl; } + #ifdef NDEBUG - catch(std::exception &e) - { + catch (std::exception &e) { std::string narrow_message = "Some exception: \""; narrow_message += e.what(); narrow_message += "\""; @@ -1904,60 +1801,457 @@ int main(int argc, char *argv[]) if (skip_main_menu) { if (error_message != L"") { verbosestream << "error_message = " - << wide_to_narrow(error_message) << std::endl; - retval = 1; + << wide_to_narrow(error_message) << std::endl; + retval = false; } break; } } // Menu-game loop - g_menuclouds->drop(); g_menucloudsmgr->drop(); - delete input; - - /* - In the end, delete the Irrlicht device. - */ - device->drop(); - -#if USE_FREETYPE - if (use_freetype) - font->drop(); -#endif - delete receiver; -#endif // !SERVER - - // Update configuration file - if (g_settings_path != "") - g_settings->updateConfigFile(g_settings_path.c_str()); - - // Print modified quicktune values - { - bool header_printed = false; - std::vector names = getQuicktuneNames(); - for(u32 i = 0; i < names.size(); i++) { - QuicktuneValue val = getQuicktuneValue(names[i]); - if (!val.modified) - continue; - if (!header_printed) { - dstream << "Modified quicktune values:" << std::endl; - header_printed = true; - } - dstream<get("name"); + if (cmd_args.exists("name")) + playername = cmd_args.get("name"); + + skip_main_menu = cmd_args.getFlag("go"); + + list_video_modes = cmd_args.getFlag("videomodes"); + + use_freetype = g_settings->getBool("freetype"); + + random_input = g_settings->getBool("random_input") + || cmd_args.getFlag("random-input"); +} + +bool ClientLauncher::init_engine(int log_level) +{ + receiver = new MyEventReceiver(); + create_engine_device(log_level); + return device != NULL; +} + +bool ClientLauncher::launch_game(std::wstring *error_message, + GameParams &game_params, const Settings &cmd_args) +{ + // Initialize menu data + MainMenuData menudata; + menudata.address = address; + menudata.name = playername; + menudata.port = itos(game_params.socket_port); + menudata.errormessage = wide_to_narrow(*error_message); + + *error_message = L""; + + if (cmd_args.exists("password")) + menudata.password = cmd_args.get("password"); + + menudata.enable_public = g_settings->getBool("server_announce"); + + // If a world was commanded, append and select it + if (game_params.world_path != "") { + worldspec.gameid = getWorldGameId(game_params.world_path, true); + worldspec.name = _("[--world parameter]"); + + if (worldspec.gameid == "") { // Create new + worldspec.gameid = g_settings->get("default_game"); + worldspec.name += " [new]"; + } + worldspec.path = game_params.world_path; + } + + /* Show the GUI menu + */ + if (!skip_main_menu) { + main_menu(&menudata); + + address = menudata.address; + int newport = stoi(menudata.port); + if (newport != 0) + game_params.socket_port = newport; + + simple_singleplayer_mode = menudata.simple_singleplayer_mode; + + std::vector worldspecs = getAvailableWorlds(); + worldspecs = getAvailableWorlds(); + + if (menudata.selected_world >= 0 + && menudata.selected_world < (int)worldspecs.size()) { + g_settings->set("selected_world_path", + worldspecs[menudata.selected_world].path); + worldspec = worldspecs[menudata.selected_world]; + } + } + + if (menudata.errormessage != "") { + /* The calling function will pass this back into this function upon the + * next iteration (if any) causing it to be displayed by the GUI + */ + *error_message = narrow_to_wide(menudata.errormessage); + return false; + } + + if (menudata.name == "") + menudata.name = std::string("Guest") + itos(myrand_range(1000, 9999)); + else + playername = menudata.name; + + password = translatePassword(playername, narrow_to_wide(menudata.password)); + + g_settings->set("name", playername); + + current_playername = playername; + current_password = password; + current_address = address; + current_port = game_params.socket_port; + + // If using simple singleplayer mode, override + if (simple_singleplayer_mode) { + assert(skip_main_menu == false); + current_playername = "singleplayer"; + current_password = ""; + current_address = ""; + current_port = myrand_range(49152, 65535); + } else if (address != "") { + ServerListSpec server; + server["name"] = menudata.servername; + server["address"] = menudata.address; + server["port"] = menudata.port; + server["description"] = menudata.serverdescription; + ServerList::insert(server); + } + + infostream << "Selected world: " << worldspec.name + << " [" << worldspec.path << "]" << std::endl; + + if (current_address == "") { // If local game + if (worldspec.path == "") { + *error_message = wgettext("No world selected and no address " + "provided. Nothing to do."); + errorstream << wide_to_narrow(*error_message) << std::endl; + return false; + } + + if (!fs::PathExists(worldspec.path)) { + *error_message = wgettext("Provided world path doesn't exist: ") + + narrow_to_wide(worldspec.path); + errorstream << wide_to_narrow(*error_message) << std::endl; + return false; + } + + // Load gamespec for required game + gamespec = findWorldSubgame(worldspec.path); + if (!gamespec.isValid() && !game_params.game_spec.isValid()) { + *error_message = wgettext("Could not find or load game \"") + + narrow_to_wide(worldspec.gameid) + L"\""; + errorstream << wide_to_narrow(*error_message) << std::endl; + return false; + } + if (game_params.game_spec.isValid() && + game_params.game_spec.id != worldspec.gameid) { + errorstream << "WARNING: Overriding gamespec from \"" + << worldspec.gameid << "\" to \"" + << game_params.game_spec.id << "\"" << std::endl; + gamespec = game_params.game_spec; + } + + if (!gamespec.isValid()) { + *error_message = wgettext("Invalid gamespec."); + *error_message += L" (world_gameid=" + + narrow_to_wide(worldspec.gameid) + L")"; + errorstream << wide_to_narrow(*error_message) << std::endl; + return false; + } + } + + return true; +} + +void ClientLauncher::main_menu(MainMenuData *menudata) +{ + bool *kill = porting::signal_handler_killstatus(); + video::IVideoDriver *driver = device->getVideoDriver(); + + infostream << "Waiting for other menus" << std::endl; + while (device->run() && *kill == false) { + if (noMenuActive()) + break; + driver->beginScene(true, true, video::SColor(255, 128, 128, 128)); + guienv->drawAll(); + driver->endScene(); + // On some computers framerate doesn't seem to be automatically limited + sleep_ms(25); + } + infostream << "Waited for other menus" << std::endl; + + // Cursor can be non-visible when coming from the game +#ifndef ANDROID + device->getCursorControl()->setVisible(true); +#endif + + /* show main menu */ + GUIEngine mymenu(device, guiroot, &g_menumgr, smgr, menudata, *kill); + + smgr->clear(); /* leave scene manager in a clean state */ +} + +bool ClientLauncher::create_engine_device(int log_level) +{ + static const char *driverids[] = { + "null", + "software", + "burningsvideo", + "direct3d8", + "direct3d9", + "opengl" +#ifdef _IRR_COMPILE_WITH_OGLES1_ + ,"ogles1" +#endif +#ifdef _IRR_COMPILE_WITH_OGLES2_ + ,"ogles2" +#endif + ,"invalid" + }; + + static const irr::ELOG_LEVEL irr_log_level[5] = { + ELL_NONE, + ELL_ERROR, + ELL_WARNING, + ELL_INFORMATION, +#if (IRRLICHT_VERSION_MAJOR == 1 && IRRLICHT_VERSION_MINOR < 8) + ELL_INFORMATION +#else + ELL_DEBUG +#endif + }; + + // Resolution selection + bool fullscreen = g_settings->getBool("fullscreen"); + u16 screenW = g_settings->getU16("screenW"); + u16 screenH = g_settings->getU16("screenH"); + + // bpp, fsaa, vsync + bool vsync = g_settings->getBool("vsync"); + u16 bits = g_settings->getU16("fullscreen_bpp"); + u16 fsaa = g_settings->getU16("fsaa"); + + // Determine driver + video::E_DRIVER_TYPE driverType = video::EDT_OPENGL; + + std::string driverstring = g_settings->get("video_driver"); + for (size_t i = 0; i < sizeof driverids / sizeof driverids[0]; i++) { + if (strcasecmp(driverstring.c_str(), driverids[i]) == 0) { + driverType = (video::E_DRIVER_TYPE) i; + break; + } + + if (strcasecmp("invalid", driverids[i]) == 0) { + errorstream << "WARNING: Invalid video_driver specified;" + << " defaulting to opengl" << std::endl; + break; + } + } + + SIrrlichtCreationParameters params = SIrrlichtCreationParameters(); + params.DriverType = driverType; + params.WindowSize = core::dimension2d(screenW, screenH); + params.Bits = bits; + params.AntiAlias = fsaa; + params.Fullscreen = fullscreen; + params.Stencilbuffer = false; + params.Vsync = vsync; + params.EventReceiver = receiver; + params.HighPrecisionFPU = g_settings->getBool("high_precision_fpu"); +#ifdef __ANDROID__ + params.PrivateData = porting::app_global; + params.OGLES2ShaderPath = std::string(porting::path_user + DIR_DELIM + + "media" + DIR_DELIM + "Shaders" + DIR_DELIM).c_str(); +#endif + + device = createDeviceEx(params); + + if (device) { + // Map our log level to irrlicht engine one. + ILogger* irr_logger = device->getLogger(); + irr_logger->setLogLevel(irr_log_level[log_level]); + + porting::initIrrlicht(device); + } + + return device != NULL; +} + +// Misc functions + +static bool print_video_modes() +{ + IrrlichtDevice *nulldevice; + + bool vsync = g_settings->getBool("vsync"); + u16 fsaa = g_settings->getU16("fsaa"); + MyEventReceiver* receiver = new MyEventReceiver(); + + SIrrlichtCreationParameters params = SIrrlichtCreationParameters(); + params.DriverType = video::EDT_NULL; + params.WindowSize = core::dimension2d(640, 480); + params.Bits = 24; + params.AntiAlias = fsaa; + params.Fullscreen = false; + params.Stencilbuffer = false; + params.Vsync = vsync; + params.EventReceiver = receiver; + params.HighPrecisionFPU = g_settings->getBool("high_precision_fpu"); + + nulldevice = createDeviceEx(params); + + if (nulldevice == NULL) { + delete receiver; + return false; + } + + dstream << _("Available video modes (WxHxD):") << std::endl; + + video::IVideoModeList *videomode_list = nulldevice->getVideoModeList(); + + if (videomode_list != NULL) { + s32 videomode_count = videomode_list->getVideoModeCount(); + core::dimension2d videomode_res; + s32 videomode_depth; + for (s32 i = 0; i < videomode_count; ++i) { + videomode_res = videomode_list->getVideoModeResolution(i); + videomode_depth = videomode_list->getVideoModeDepth(i); + dstream << videomode_res.Width << "x" << videomode_res.Height + << "x" << videomode_depth << std::endl; + } + + dstream << _("Active video mode (WxHxD):") << std::endl; + videomode_res = videomode_list->getDesktopResolution(); + videomode_depth = videomode_list->getDesktopDepth(); + dstream << videomode_res.Width << "x" << videomode_res.Height + << "x" << videomode_depth << std::endl; + + } + + nulldevice->drop(); + delete receiver; + + return videomode_list != NULL; +} + +#endif // !SERVER + +/***************************************************************************** + * Performance tests + *****************************************************************************/ +#ifndef SERVER +static void speed_tests() +{ + // volatile to avoid some potential compiler optimisations + volatile static s16 temp16; + volatile static f32 tempf; + static v3f tempv3f1; + static v3f tempv3f2; + static std::string tempstring; + static std::string tempstring2; + + tempv3f1 = v3f(); + tempv3f2 = v3f(); + tempstring = std::string(); + tempstring2 = std::string(); + + { + infostream << "The following test should take around 20ms." << std::endl; + TimeTaker timer("Testing std::string speed"); + const u32 jj = 10000; + for (u32 j = 0; j < jj; j++) { + tempstring = ""; + tempstring2 = ""; + const u32 ii = 10; + for (u32 i = 0; i < ii; i++) { + tempstring2 += "asd"; + } + for (u32 i = 0; i < ii+1; i++) { + tempstring += "asd"; + if (tempstring == tempstring2) + break; + } + } + } + + infostream << "All of the following tests should take around 100ms each." + << std::endl; + + { + TimeTaker timer("Testing floating-point conversion speed"); + tempf = 0.001; + for (u32 i = 0; i < 4000000; i++) { + temp16 += tempf; + tempf += 0.001; + } + } + + { + TimeTaker timer("Testing floating-point vector speed"); + + tempv3f1 = v3f(1, 2, 3); + tempv3f2 = v3f(4, 5, 6); + for (u32 i = 0; i < 10000000; i++) { + tempf += tempv3f1.dotProduct(tempv3f2); + tempv3f2 += v3f(7, 8, 9); + } + } + + { + TimeTaker timer("Testing std::map speed"); + + std::map map1; + tempf = -324; + const s16 ii = 300; + for (s16 y = 0; y < ii; y++) { + for (s16 x = 0; x < ii; x++) { + map1[v2s16(x, y)] = tempf; + tempf += 1; + } + } + for (s16 y = ii - 1; y >= 0; y--) { + for (s16 x = 0; x < ii; x++) { + tempf = map1[v2s16(x, y)]; + } + } + } + + { + infostream << "Around 5000/ms should do well here." << std::endl; + TimeTaker timer("Testing mutex speed"); + + JMutex m; + u32 n = 0; + u32 i = 0; + do { + n += 10000; + for (; i < n; i++) { + m.Lock(); + m.Unlock(); + } + } + // Do at least 10ms + while(timer.getTimerTime() < 10); + + u32 dtime = timer.stop(); + u32 per_ms = n / dtime; + infostream << "Done. " << dtime << "ms, " << per_ms << "/ms" << std::endl; + } +} +#endif