summary refs log tree commit diff
path: root/src/Cache.cc
diff options
context:
space:
mode:
authorKonstantinos Sideris <sideris.konstantin@gmail.com>2017-10-03 21:16:31 +0300
committerKonstantinos Sideris <sideris.konstantin@gmail.com>2017-10-03 21:16:31 +0300
commit88349eae90cc842427392ababb7903a242f17a94 (patch)
tree658d044218fa3d926b68621727e6dc1e7669529d /src/Cache.cc
parentFix unicode handling of replaceEmoji (#84) (diff)
downloadnheko-88349eae90cc842427392ababb7903a242f17a94.tar.xz
Recover from corrupted cache data
Make Cache constructor exception free

fixes #74
Diffstat (limited to 'src/Cache.cc')
-rw-r--r--src/Cache.cc21
1 files changed, 16 insertions, 5 deletions
diff --git a/src/Cache.cc b/src/Cache.cc

index 5ed77086..c96ec37d 100644 --- a/src/Cache.cc +++ b/src/Cache.cc
@@ -37,10 +37,21 @@ Cache::Cache(const QString &userId) , isMounted_{ false } , userId_{ userId } { +} + +void +Cache::setup() +{ + qDebug() << "Setting up cache"; + auto statePath = QString("%1/%2/state") .arg(QStandardPaths::writableLocation(QStandardPaths::CacheLocation)) .arg(QString::fromUtf8(userId_.toUtf8().toHex())); + cacheDirectory_ = QString("%1/%2") + .arg(QStandardPaths::writableLocation(QStandardPaths::CacheLocation)) + .arg(QString::fromUtf8(userId_.toUtf8().toHex())); + bool isInitial = !QFile::exists(statePath); env_ = lmdb::env::create(); @@ -48,7 +59,7 @@ Cache::Cache(const QString &userId) env_.set_max_dbs(1024UL); if (isInitial) { - qDebug() << "[cache] First time initializing LMDB"; + qDebug() << "First time initializing LMDB"; if (!QDir().mkpath(statePath)) { throw std::runtime_error( @@ -83,10 +94,7 @@ Cache::Cache(const QString &userId) txn.commit(); - isMounted_ = true; - cacheDirectory_ = QString("%1/%2") - .arg(QStandardPaths::writableLocation(QStandardPaths::CacheLocation)) - .arg(QString::fromUtf8(userId_.toUtf8().toHex())); + isMounted_ = true; } void @@ -156,6 +164,9 @@ Cache::insertRoomState(lmdb::txn &txn, const QString &roomid, const RoomState &s void Cache::removeRoom(const QString &roomid) { + if (!isMounted_) + return; + auto txn = lmdb::txn::begin(env_, nullptr, 0); lmdb::dbi_del(txn, roomDb_, lmdb::val(roomid.toUtf8(), roomid.toUtf8().size()), nullptr);