diff options
Diffstat (limited to 'src/database/database-leveldb.cpp')
-rw-r--r-- | src/database/database-leveldb.cpp | 67 |
1 files changed, 32 insertions, 35 deletions
diff --git a/src/database/database-leveldb.cpp b/src/database/database-leveldb.cpp index 1976ae13d..51830ff35 100644 --- a/src/database/database-leveldb.cpp +++ b/src/database/database-leveldb.cpp @@ -33,20 +33,18 @@ with this program; if not, write to the Free Software Foundation, Inc., #include "leveldb/db.h" - -#define ENSURE_STATUS_OK(s) \ - if (!(s).ok()) { \ - throw DatabaseException(std::string("LevelDB error: ") + \ - (s).ToString()); \ +#define ENSURE_STATUS_OK(s) \ + if (!(s).ok()) { \ + throw DatabaseException( \ + std::string("LevelDB error: ") + (s).ToString()); \ } - Database_LevelDB::Database_LevelDB(const std::string &savedir) { leveldb::Options options; options.create_if_missing = true; - leveldb::Status status = leveldb::DB::Open(options, - savedir + DIR_DELIM + "map.db", &m_database); + leveldb::Status status = leveldb::DB::Open( + options, savedir + DIR_DELIM + "map.db", &m_database); ENSURE_STATUS_OK(status); } @@ -57,11 +55,11 @@ Database_LevelDB::~Database_LevelDB() bool Database_LevelDB::saveBlock(const v3s16 &pos, const std::string &data) { - leveldb::Status status = m_database->Put(leveldb::WriteOptions(), - i64tos(getBlockAsInteger(pos)), data); + leveldb::Status status = m_database->Put( + leveldb::WriteOptions(), i64tos(getBlockAsInteger(pos)), data); if (!status.ok()) { - warningstream << "saveBlock: LevelDB error saving block " - << PP(pos) << ": " << status.ToString() << std::endl; + warningstream << "saveBlock: LevelDB error saving block " << PP(pos) + << ": " << status.ToString() << std::endl; return false; } @@ -71,19 +69,19 @@ bool Database_LevelDB::saveBlock(const v3s16 &pos, const std::string &data) void Database_LevelDB::loadBlock(const v3s16 &pos, std::string *block) { std::string datastr; - leveldb::Status status = m_database->Get(leveldb::ReadOptions(), - i64tos(getBlockAsInteger(pos)), &datastr); + leveldb::Status status = m_database->Get( + leveldb::ReadOptions(), i64tos(getBlockAsInteger(pos)), &datastr); *block = (status.ok()) ? datastr : ""; } bool Database_LevelDB::deleteBlock(const v3s16 &pos) { - leveldb::Status status = m_database->Delete(leveldb::WriteOptions(), - i64tos(getBlockAsInteger(pos))); + leveldb::Status status = m_database->Delete( + leveldb::WriteOptions(), i64tos(getBlockAsInteger(pos))); if (!status.ok()) { - warningstream << "deleteBlock: LevelDB error deleting block " - << PP(pos) << ": " << status.ToString() << std::endl; + warningstream << "deleteBlock: LevelDB error deleting block " << PP(pos) + << ": " << status.ToString() << std::endl; return false; } @@ -92,11 +90,11 @@ bool Database_LevelDB::deleteBlock(const v3s16 &pos) void Database_LevelDB::listAllLoadableBlocks(std::vector<v3s16> &dst) { - leveldb::Iterator* it = m_database->NewIterator(leveldb::ReadOptions()); + leveldb::Iterator *it = m_database->NewIterator(leveldb::ReadOptions()); for (it->SeekToFirst(); it->Valid(); it->Next()) { dst.push_back(getIntegerAsBlock(stoi64(it->key().ToString()))); } - ENSURE_STATUS_OK(it->status()); // Check for any errors found during the scan + ENSURE_STATUS_OK(it->status()); // Check for any errors found during the scan delete it; } @@ -104,8 +102,8 @@ PlayerDatabaseLevelDB::PlayerDatabaseLevelDB(const std::string &savedir) { leveldb::Options options; options.create_if_missing = true; - leveldb::Status status = leveldb::DB::Open(options, - savedir + DIR_DELIM + "players.db", &m_database); + leveldb::Status status = leveldb::DB::Open( + options, savedir + DIR_DELIM + "players.db", &m_database); ENSURE_STATUS_OK(status); } @@ -151,8 +149,8 @@ void PlayerDatabaseLevelDB::savePlayer(RemotePlayer *player) player->inventory.serialize(os); - leveldb::Status status = m_database->Put(leveldb::WriteOptions(), - player->getName(), os.str()); + leveldb::Status status = m_database->Put( + leveldb::WriteOptions(), player->getName(), os.str()); ENSURE_STATUS_OK(status); player->onSuccessfulSave(); } @@ -166,8 +164,8 @@ bool PlayerDatabaseLevelDB::removePlayer(const std::string &name) bool PlayerDatabaseLevelDB::loadPlayer(RemotePlayer *player, PlayerSAO *sao) { std::string raw; - leveldb::Status s = m_database->Get(leveldb::ReadOptions(), - player->getName(), &raw); + leveldb::Status s = + m_database->Get(leveldb::ReadOptions(), player->getName(), &raw); if (!s.ok()) return false; std::istringstream is(raw); @@ -194,7 +192,7 @@ bool PlayerDatabaseLevelDB::loadPlayer(RemotePlayer *player, PlayerSAO *sao) player->inventory.deSerialize(is); } catch (SerializationError &e) { errorstream << "Failed to deserialize player inventory. player_name=" - << player->getName() << " " << e.what() << std::endl; + << player->getName() << " " << e.what() << std::endl; } return true; @@ -202,7 +200,7 @@ bool PlayerDatabaseLevelDB::loadPlayer(RemotePlayer *player, PlayerSAO *sao) void PlayerDatabaseLevelDB::listPlayers(std::vector<std::string> &res) { - leveldb::Iterator* it = m_database->NewIterator(leveldb::ReadOptions()); + leveldb::Iterator *it = m_database->NewIterator(leveldb::ReadOptions()); res.clear(); for (it->SeekToFirst(); it->Valid(); it->Next()) { res.push_back(it->key().ToString()); @@ -214,8 +212,8 @@ AuthDatabaseLevelDB::AuthDatabaseLevelDB(const std::string &savedir) { leveldb::Options options; options.create_if_missing = true; - leveldb::Status status = leveldb::DB::Open(options, - savedir + DIR_DELIM + "auth.db", &m_database); + leveldb::Status status = leveldb::DB::Open( + options, savedir + DIR_DELIM + "auth.db", &m_database); ENSURE_STATUS_OK(status); } @@ -267,16 +265,15 @@ bool AuthDatabaseLevelDB::saveAuth(const AuthEntry &authEntry) os << serializeString(authEntry.password); size_t privilege_count = authEntry.privileges.size(); - FATAL_ERROR_IF(privilege_count > U16_MAX, - "Unsupported number of privileges"); + FATAL_ERROR_IF(privilege_count > U16_MAX, "Unsupported number of privileges"); writeU16(os, privilege_count); for (const std::string &privilege : authEntry.privileges) { os << serializeString(privilege); } writeS64(os, authEntry.last_login); - leveldb::Status s = m_database->Put(leveldb::WriteOptions(), - authEntry.name, os.str()); + leveldb::Status s = m_database->Put( + leveldb::WriteOptions(), authEntry.name, os.str()); return s.ok(); } @@ -293,7 +290,7 @@ bool AuthDatabaseLevelDB::deleteAuth(const std::string &name) void AuthDatabaseLevelDB::listNames(std::vector<std::string> &res) { - leveldb::Iterator* it = m_database->NewIterator(leveldb::ReadOptions()); + leveldb::Iterator *it = m_database->NewIterator(leveldb::ReadOptions()); res.clear(); for (it->SeekToFirst(); it->Valid(); it->Next()) { res.emplace_back(it->key().ToString()); |