Skip to content

Commit

Permalink
fix: compilation and crash with async save
Browse files Browse the repository at this point in the history
  • Loading branch information
dudantas committed Nov 9, 2024
1 parent 8b03cf5 commit d4344ad
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 13 deletions.
2 changes: 1 addition & 1 deletion src/creatures/players/components/player_storage.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -126,7 +126,7 @@ bool PlayerStorage::save() {
return true;
};

auto insertModifiedStorageKeys = [playerGUID, playerName, modifiedKeys, storageMap]() mutable {
auto insertModifiedStorageKeys = [this, playerGUID, playerName, modifiedKeys, storageMap]() mutable {
getReservedRange();
if (!modifiedKeys.empty()) {
DBInsert storageQuery("INSERT INTO `player_storage` (`player_id`, `key`, `value`) VALUES ");
Expand Down
26 changes: 14 additions & 12 deletions src/game/scheduling/save_manager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
#include "io/iologindata.hpp"
#include "kv/kv.hpp"
#include "lib/di/container.hpp"
#include "game/scheduling/task.hpp"
#include "game/scheduling/dispatcher.hpp"

SaveManager::SaveManager(ThreadPool &threadPool, KVStore &kvStore, Logger &logger, Game &game) :
threadPool(threadPool), kv(kvStore), logger(logger), game(game) {
Expand All @@ -34,18 +34,19 @@ void SaveManager::saveAll() {
Benchmark bm_saveAll;
logger.info("Saving server...");

Benchmark bm_players;
const auto async = g_configManager().getBoolean(TOGGLE_SAVE_ASYNC);

Benchmark bm_players;

const auto &players = std::vector<std::pair<uint32_t, std::shared_ptr<Player>>>(game.getPlayers().begin(), game.getPlayers().end());
logger.info("Saving {} players... (Async: {})", players.size(), async ? "Enabled" : "Disabled");

threadPool.submit_loop(static_cast<int>(0), static_cast<int>(players.size()), [this, &players](const int i) {
const auto &player = players[i].second;
player->loginPosition = player->getPosition();
doSavePlayer(player);
})
.wait();
g_dispatcher().asyncWait(players.size(), [this, &players](size_t i) {
if(const auto& player = players[i].second) {
player->loginPosition = player->getPosition();
doSavePlayer(player);
}
});

double duration_players = bm_players.duration();
if (duration_players > 1000.0) {
Expand All @@ -56,10 +57,11 @@ void SaveManager::saveAll() {

Benchmark bm_guilds;
const auto &guilds = std::vector<std::pair<uint32_t, std::shared_ptr<Guild>>>(game.getGuilds().begin(), game.getGuilds().end());
threadPool.submit_loop(static_cast<int>(0), static_cast<int>(guilds.size()), [this, &guilds](const int i) {
saveGuild(guilds[i].second);
})
.wait();
g_dispatcher().asyncWait(guilds.size(), [this, &guilds](size_t i) {
if (const auto& guild = guilds[i].second) {
saveGuild(guild);
}
});

double duration_guilds = bm_guilds.duration();
if (duration_guilds > 1000.0) {
Expand Down

0 comments on commit d4344ad

Please sign in to comment.