diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-12-22 17:40:19 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-12-22 17:40:19 +0100 |
commit | 501a9c3a441a4fbd5629a15e4056a52b54834baf (patch) | |
tree | 2648c04be009846b868a3c4ffa35f7155f37aac5 /common/storage_lmdb.cpp | |
parent | f08eb59a2c752fdbed54c34809d4d6664a4cd81f (diff) | |
download | sink-501a9c3a441a4fbd5629a15e4056a52b54834baf.tar.gz sink-501a9c3a441a4fbd5629a15e4056a52b54834baf.zip |
Debug output
Diffstat (limited to 'common/storage_lmdb.cpp')
-rw-r--r-- | common/storage_lmdb.cpp | 14 |
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 | } |