summaryrefslogtreecommitdiffstats
path: root/common/storage_lmdb.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-12-22 17:40:19 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-12-22 17:40:19 +0100
commit501a9c3a441a4fbd5629a15e4056a52b54834baf (patch)
tree2648c04be009846b868a3c4ffa35f7155f37aac5 /common/storage_lmdb.cpp
parentf08eb59a2c752fdbed54c34809d4d6664a4cd81f (diff)
downloadsink-501a9c3a441a4fbd5629a15e4056a52b54834baf.tar.gz
sink-501a9c3a441a4fbd5629a15e4056a52b54834baf.zip
Debug output
Diffstat (limited to 'common/storage_lmdb.cpp')
-rw-r--r--common/storage_lmdb.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/common/storage_lmdb.cpp b/common/storage_lmdb.cpp
index b9b86aa..79f32ba 100644
--- a/common/storage_lmdb.cpp
+++ b/common/storage_lmdb.cpp
@@ -125,7 +125,7 @@ bool Storage::NamedDatabase::write(const QByteArray &sKey, const QByteArray &sVa
125 const size_t valueSize = sValue.size(); 125 const size_t valueSize = sValue.size();
126 126
127 if (!keyPtr || keySize == 0) { 127 if (!keyPtr || keySize == 0) {
128 Error error(d->name.toLatin1(), ErrorCodes::GenericError, "Tried to write empty key."); 128 Error error(d->name.toLatin1() + d->db, ErrorCodes::GenericError, "Tried to write empty key.");
129 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error); 129 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error);
130 return false; 130 return false;
131 } 131 }
@@ -139,7 +139,7 @@ bool Storage::NamedDatabase::write(const QByteArray &sKey, const QByteArray &sVa
139 rc = mdb_put(d->transaction, d->dbi, &key, &data, 0); 139 rc = mdb_put(d->transaction, d->dbi, &key, &data, 0);
140 140
141 if (rc) { 141 if (rc) {
142 Error error(d->name.toLatin1(), ErrorCodes::GenericError, "mdb_put: " + QByteArray(mdb_strerror(rc))); 142 Error error(d->name.toLatin1() + d->db, ErrorCodes::GenericError, "mdb_put: " + QByteArray(mdb_strerror(rc)));
143 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error); 143 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error);
144 } 144 }
145 145
@@ -156,7 +156,7 @@ void Storage::NamedDatabase::remove(const QByteArray &k, const QByteArray &value
156 const std::function<void(const Storage::Error &error)> &errorHandler) 156 const std::function<void(const Storage::Error &error)> &errorHandler)
157{ 157{
158 if (!d || !d->transaction) { 158 if (!d || !d->transaction) {
159 Error error(d->name.toLatin1(), ErrorCodes::GenericError, "Not open"); 159 Error error(d->name.toLatin1() + d->db, ErrorCodes::GenericError, "Not open");
160 if (d) { 160 if (d) {
161 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error); 161 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error);
162 } 162 }
@@ -177,7 +177,7 @@ void Storage::NamedDatabase::remove(const QByteArray &k, const QByteArray &value
177 } 177 }
178 178
179 if (rc) { 179 if (rc) {
180 Error error(d->name.toLatin1(), ErrorCodes::GenericError, QString("Error on mdb_del: %1 %2").arg(rc).arg(mdb_strerror(rc)).toLatin1()); 180 Error error(d->name.toLatin1() + d->db, ErrorCodes::GenericError, QString("Error on mdb_del: %1 %2").arg(rc).arg(mdb_strerror(rc)).toLatin1());
181 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error); 181 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error);
182 } 182 }
183} 183}
@@ -202,7 +202,7 @@ int Storage::NamedDatabase::scan(const QByteArray &k,
202 202
203 rc = mdb_cursor_open(d->transaction, d->dbi, &cursor); 203 rc = mdb_cursor_open(d->transaction, d->dbi, &cursor);
204 if (rc) { 204 if (rc) {
205 Error error(d->name.toLatin1(), getErrorCode(rc), QByteArray("Error during mdb_cursor open: ") + QByteArray(mdb_strerror(rc))); 205 Error error(d->name.toLatin1() + d->db, getErrorCode(rc), QByteArray("Error during mdb_cursor open: ") + QByteArray(mdb_strerror(rc)));
206 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error); 206 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error);
207 return 0; 207 return 0;
208 } 208 }
@@ -247,7 +247,7 @@ int Storage::NamedDatabase::scan(const QByteArray &k,
247 mdb_cursor_close(cursor); 247 mdb_cursor_close(cursor);
248 248
249 if (rc) { 249 if (rc) {
250 Error error(d->name.toLatin1(), getErrorCode(rc), QByteArray("Key: ") + k + " : " + QByteArray(mdb_strerror(rc))); 250 Error error(d->name.toLatin1() + d->db, getErrorCode(rc), QByteArray("Key: ") + k + " : " + QByteArray(mdb_strerror(rc)));
251 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error); 251 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error);
252 } 252 }
253 253
@@ -273,7 +273,7 @@ void Storage::NamedDatabase::findLatest(const QByteArray &k,
273 273
274 rc = mdb_cursor_open(d->transaction, d->dbi, &cursor); 274 rc = mdb_cursor_open(d->transaction, d->dbi, &cursor);
275 if (rc) { 275 if (rc) {
276 Error error(d->name.toLatin1(), getErrorCode(rc), QByteArray("Error during mdb_cursor open: ") + QByteArray(mdb_strerror(rc))); 276 Error error(d->name.toLatin1() + d->db, getErrorCode(rc), QByteArray("Error during mdb_cursor open: ") + QByteArray(mdb_strerror(rc)));
277 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error); 277 errorHandler ? errorHandler(error) : d->defaultErrorHandler(error);
278 return; 278 return;
279 } 279 }