aboutsummaryrefslogtreecommitdiff
path: root/src/database/database-leveldb.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/database/database-leveldb.cpp')
-rw-r--r--src/database/database-leveldb.cpp67
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());