]> git.lizzy.rs Git - dragonfireclient.git/blobdiff - src/main.cpp
Merge branch 'master' of https://github.com/minetest/minetest
[dragonfireclient.git] / src / main.cpp
index f7238176b1e858905cedd0cdc036e140ea217470..ebd1f740ecf1fdf8bbdc242e836224e226982fd8 100644 (file)
@@ -20,6 +20,7 @@ with this program; if not, write to the Free Software Foundation, Inc.,
 #include "irrlichttypes.h" // must be included before anything irrlicht, see comment in the file
 #include "irrlicht.h" // createDevice
 #include "irrlichttypes_extrabloated.h"
+#include "benchmark/benchmark.h"
 #include "chat_interface.h"
 #include "debug.h"
 #include "unittest/test.h"
@@ -38,6 +39,7 @@ with this program; if not, write to the Free Software Foundation, Inc.,
 #include "player.h"
 #include "porting.h"
 #include "network/socket.h"
+#include "mapblock.h"
 #if USE_CURSES
        #include "terminal_chat_console.h"
 #endif
@@ -60,11 +62,16 @@ extern "C" {
 #endif
 }
 
-#if !defined(SERVER) && \
-       (IRRLICHT_VERSION_MAJOR == 1) && \
-       (IRRLICHT_VERSION_MINOR == 8) && \
-       (IRRLICHT_VERSION_REVISION == 2)
-       #error "Irrlicht 1.8.2 is known to be broken - please update Irrlicht to version >= 1.8.3"
+#if !defined(__cpp_rtti) || !defined(__cpp_exceptions)
+#error Minetest cannot be built without exceptions or RTTI
+#endif
+
+#if defined(__MINGW32__) && !defined(__MINGW64__) && !defined(__clang__) && \
+       (__GNUC__ < 11 || (__GNUC__ == 11 && __GNUC_MINOR__ < 1))
+// see e.g. https://github.com/minetest/minetest/issues/10137
+#warning ==================================
+#warning 32-bit MinGW gcc before 11.1 has known issues with crashes on thread exit, you should upgrade.
+#warning ==================================
 #endif
 
 #define DEBUGFILE "debug.txt"
@@ -91,6 +98,7 @@ static void list_worlds(bool print_name, bool print_path);
 static bool setup_log_params(const Settings &cmd_args);
 static bool create_userdata_path();
 static bool init_common(const Settings &cmd_args, int argc, char *argv[]);
+static void uninit_common();
 static void startup_message();
 static bool read_config_file(const Settings &cmd_args);
 static void init_log_streams(const Settings &cmd_args);
@@ -110,6 +118,7 @@ static bool determine_subgame(GameParams *game_params);
 
 static bool run_dedicated_server(const GameParams &game_params, const Settings &cmd_args);
 static bool migrate_map_database(const GameParams &game_params, const Settings &cmd_args);
+static bool recompress_map_database(const GameParams &game_params, const Settings &cmd_args, const Address &addr);
 
 /**********************************************************************/
 
@@ -201,9 +210,22 @@ int main(int argc, char *argv[])
                errorstream << "Unittest support is not enabled in this binary. "
                        << "If you want to enable it, compile project with BUILD_UNITTESTS=1 flag."
                        << std::endl;
+               return 1;
 #endif
        }
+
+       // Run benchmarks
+       if (cmd_args.getFlag("run-benchmarks")) {
+#if BUILD_BENCHMARKS
+               return run_benchmarks();
+#else
+               errorstream << "Benchmark support is not enabled in this binary. "
+                       << "If you want to enable it, compile project with BUILD_BENCHMARKS=1 flag."
+                       << std::endl;
+               return 1;
 #endif
+       }
+#endif // __ANDROID__
 
        GameStartData game_params;
 #ifdef SERVER
@@ -225,8 +247,7 @@ int main(int argc, char *argv[])
                return run_dedicated_server(game_params, cmd_args) ? 0 : 1;
 
 #ifndef SERVER
-       ClientLauncher launcher;
-       retval = launcher.run(game_params, cmd_args) ? 0 : 1;
+       retval = ClientLauncher().run(game_params, cmd_args) ? 0 : 1;
 #else
        retval = 0;
 #endif
@@ -237,9 +258,6 @@ int main(int argc, char *argv[])
 
        print_modified_quicktune_values();
 
-       // Stop httpfetch thread (if started)
-       httpfetch_cleanup();
-
        END_DEBUG_EXCEPTION_HANDLER
 
        return retval;
@@ -272,6 +290,8 @@ static void set_allowed_options(OptionList *allowed_options)
                        _("Set network port (UDP)"))));
        allowed_options->insert(std::make_pair("run-unittests", ValueSpec(VALUETYPE_FLAG,
                        _("Run the unit tests and exit"))));
+       allowed_options->insert(std::make_pair("run-benchmarks", ValueSpec(VALUETYPE_FLAG,
+                       _("Run the benchmarks and exit"))));
        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,
@@ -302,11 +322,13 @@ static void set_allowed_options(OptionList *allowed_options)
                _("Migrate from current players backend to another (Only works when using minetestserver or with --server)"))));
        allowed_options->insert(std::make_pair("migrate-auth", ValueSpec(VALUETYPE_STRING,
                _("Migrate from current auth backend to another (Only works when using minetestserver or with --server)"))));
+       allowed_options->insert(std::make_pair("migrate-mod-storage", ValueSpec(VALUETYPE_STRING,
+               _("Migrate from current mod storage backend to another (Only works when using minetestserver or with --server)"))));
        allowed_options->insert(std::make_pair("terminal", ValueSpec(VALUETYPE_FLAG,
                        _("Feature an interactive terminal (Only works when using minetestserver or with --server)"))));
+       allowed_options->insert(std::make_pair("recompress", ValueSpec(VALUETYPE_FLAG,
+                       _("Recompress the blocks of the given map database."))));
 #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,
@@ -446,14 +468,6 @@ static bool setup_log_params(const Settings &cmd_args)
                }
        }
 
-       // If trace is enabled, enable logging of certain things
-       if (cmd_args.getFlag("trace")) {
-               dstream << _("Enabling trace level debug output") << std::endl;
-               g_logger.setTraceEnabled(true);
-               dout_con_ptr = &verbosestream; // This is somewhat old
-               socket_enable_debug_output = true; // Sockets 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"))
@@ -463,6 +477,12 @@ static bool setup_log_params(const Settings &cmd_args)
        if (cmd_args.getFlag("verbose") || cmd_args.getFlag("trace"))
                g_logger.addOutput(&stderr_output, LL_VERBOSE);
 
+       if (cmd_args.getFlag("trace")) {
+               dstream << _("Enabling trace level debug output") << std::endl;
+               g_logger.addOutput(&stderr_output, LL_TRACE);
+               socket_enable_debug_output = true;
+       }
+
        return true;
 }
 
@@ -487,11 +507,15 @@ static bool create_userdata_path()
 static bool init_common(const Settings &cmd_args, int argc, char *argv[])
 {
        startup_message();
-       set_default_settings(g_settings);
+       set_default_settings();
 
-       // Initialize sockets
        sockets_init();
-       atexit(sockets_cleanup);
+
+       // Initialize g_settings
+       Settings::createLayer(SL_GLOBAL);
+
+       // Set cleanup callback(s) to run at process exit
+       atexit(uninit_common);
 
        if (!read_config_file(cmd_args))
                return false;
@@ -511,6 +535,17 @@ static bool init_common(const Settings &cmd_args, int argc, char *argv[])
        return true;
 }
 
+static void uninit_common()
+{
+       httpfetch_cleanup();
+
+       sockets_cleanup();
+
+       // It'd actually be okay to leak these but we want to please valgrind...
+       for (int i = 0; i < (int)SL_TOTAL_COUNT; i++)
+               delete Settings::getLayer((SettingsLayer)i);
+}
+
 static void startup_message()
 {
        infostream << PROJECT_NAME << " " << _("with")
@@ -577,7 +612,7 @@ static void init_log_streams(const Settings &cmd_args)
                warningstream << "Deprecated use of debug_log_level with an "
                        "integer value; please update your configuration." << std::endl;
                static const char *lev_name[] =
-                       {"", "error", "action", "info", "verbose"};
+                       {"", "error", "action", "info", "verbose", "trace"};
                int lev_i = atoi(conf_loglev.c_str());
                if (lev_i < 0 || lev_i >= (int)ARRLEN(lev_name)) {
                        warningstream << "Supplied invalid debug_log_level!"
@@ -864,7 +899,7 @@ static bool run_dedicated_server(const GameParams &game_params, const Settings &
                return false;
        }
 
-       // Database migration
+       // Database migration/compression
        if (cmd_args.exists("migrate"))
                return migrate_map_database(game_params, cmd_args);
 
@@ -874,6 +909,12 @@ static bool run_dedicated_server(const GameParams &game_params, const Settings &
        if (cmd_args.exists("migrate-auth"))
                return ServerEnvironment::migrateAuthDatabase(game_params, cmd_args);
 
+       if (cmd_args.exists("migrate-mod-storage"))
+               return Server::migrateModStorageDatabase(game_params, cmd_args);
+
+       if (cmd_args.getFlag("recompress"))
+               return recompress_map_database(game_params, cmd_args, bind_addr);
+
        if (cmd_args.exists("terminal")) {
 #if USE_CURSES
                bool name_ok = true;
@@ -1023,3 +1064,67 @@ static bool migrate_map_database(const GameParams &game_params, const Settings &
 
        return true;
 }
+
+static bool recompress_map_database(const GameParams &game_params, const Settings &cmd_args, const Address &addr)
+{
+       Settings world_mt;
+       const std::string world_mt_path = game_params.world_path + DIR_DELIM + "world.mt";
+
+       if (!world_mt.readConfigFile(world_mt_path.c_str())) {
+               errorstream << "Cannot read world.mt at " << world_mt_path << std::endl;
+               return false;
+       }
+       const std::string &backend = world_mt.get("backend");
+       Server server(game_params.world_path, game_params.game_spec, false, addr, false);
+       MapDatabase *db = ServerMap::createDatabase(backend, game_params.world_path, world_mt);
+
+       u32 count = 0;
+       u64 last_update_time = 0;
+       bool &kill = *porting::signal_handler_killstatus();
+       const u8 serialize_as_ver = SER_FMT_VER_HIGHEST_WRITE;
+
+       // This is ok because the server doesn't actually run
+       std::vector<v3s16> blocks;
+       db->listAllLoadableBlocks(blocks);
+       db->beginSave();
+       std::istringstream iss(std::ios_base::binary);
+       std::ostringstream oss(std::ios_base::binary);
+       for (auto it = blocks.begin(); it != blocks.end(); ++it) {
+               if (kill) return false;
+
+               std::string data;
+               db->loadBlock(*it, &data);
+               if (data.empty()) {
+                       errorstream << "Failed to load block " << PP(*it) << std::endl;
+                       return false;
+               }
+
+               iss.str(data);
+               iss.clear();
+
+               MapBlock mb(nullptr, v3s16(0,0,0), &server);
+               u8 ver = readU8(iss);
+               mb.deSerialize(iss, ver, true);
+
+               oss.str("");
+               oss.clear();
+               writeU8(oss, serialize_as_ver);
+               mb.serialize(oss, serialize_as_ver, true, -1);
+
+               db->saveBlock(*it, oss.str());
+
+               count++;
+               if (count % 0xFF == 0 && porting::getTimeS() - last_update_time >= 1) {
+                       std::cerr << " Recompressed " << count << " blocks, "
+                               << (100.0f * count / blocks.size()) << "% completed.\r";
+                       db->endSave();
+                       db->beginSave();
+                       last_update_time = porting::getTimeS();
+               }
+       }
+       std::cerr << std::endl;
+       db->endSave();
+
+       actionstream << "Done, " << count << " blocks were recompressed." << std::endl;
+       return true;
+}