summaryrefslogtreecommitdiffstats
path: root/common/storage_lmdb.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/storage_lmdb.cpp')
-rw-r--r--common/storage_lmdb.cpp28
1 files changed, 9 insertions, 19 deletions
diff --git a/common/storage_lmdb.cpp b/common/storage_lmdb.cpp
index 6afa1a8..6f2142f 100644
--- a/common/storage_lmdb.cpp
+++ b/common/storage_lmdb.cpp
@@ -382,8 +382,7 @@ DataStore::NamedDatabase::~NamedDatabase()
382bool DataStore::NamedDatabase::write(const size_t key, const QByteArray &value, 382bool DataStore::NamedDatabase::write(const size_t key, const QByteArray &value,
383 const std::function<void(const DataStore::Error &error)> &errorHandler) 383 const std::function<void(const DataStore::Error &error)> &errorHandler)
384{ 384{
385 auto baKey = sizeTToByteArray(key); 385 return write(sizeTToByteArray(key), value, errorHandler);
386 return write(baKey, value, errorHandler);
387} 386}
388 387
389bool DataStore::NamedDatabase::write(const QByteArray &sKey, const QByteArray &sValue, const std::function<void(const DataStore::Error &error)> &errorHandler) 388bool DataStore::NamedDatabase::write(const QByteArray &sKey, const QByteArray &sValue, const std::function<void(const DataStore::Error &error)> &errorHandler)
@@ -425,8 +424,7 @@ bool DataStore::NamedDatabase::write(const QByteArray &sKey, const QByteArray &s
425void DataStore::NamedDatabase::remove( 424void DataStore::NamedDatabase::remove(
426 const size_t key, const std::function<void(const DataStore::Error &error)> &errorHandler) 425 const size_t key, const std::function<void(const DataStore::Error &error)> &errorHandler)
427{ 426{
428 auto baKey = sizeTToByteArray(key); 427 return remove(sizeTToByteArray(key), errorHandler);
429 return remove(baKey, errorHandler);
430} 428}
431 429
432void DataStore::NamedDatabase::remove(const QByteArray &k, const std::function<void(const DataStore::Error &error)> &errorHandler) 430void DataStore::NamedDatabase::remove(const QByteArray &k, const std::function<void(const DataStore::Error &error)> &errorHandler)
@@ -437,8 +435,7 @@ void DataStore::NamedDatabase::remove(const QByteArray &k, const std::function<v
437void DataStore::NamedDatabase::remove(const size_t key, const QByteArray &value, 435void DataStore::NamedDatabase::remove(const size_t key, const QByteArray &value,
438 const std::function<void(const DataStore::Error &error)> &errorHandler) 436 const std::function<void(const DataStore::Error &error)> &errorHandler)
439{ 437{
440 auto baKey = sizeTToByteArray(key); 438 return remove(sizeTToByteArray(key), value, errorHandler);
441 return remove(baKey, value, errorHandler);
442} 439}
443 440
444void DataStore::NamedDatabase::remove(const QByteArray &k, const QByteArray &value, const std::function<void(const DataStore::Error &error)> &errorHandler) 441void DataStore::NamedDatabase::remove(const QByteArray &k, const QByteArray &value, const std::function<void(const DataStore::Error &error)> &errorHandler)
@@ -478,11 +475,9 @@ int DataStore::NamedDatabase::scan(const size_t key,
478 const std::function<bool(size_t key, const QByteArray &value)> &resultHandler, 475 const std::function<bool(size_t key, const QByteArray &value)> &resultHandler,
479 const std::function<void(const DataStore::Error &error)> &errorHandler, bool skipInternalKeys) const 476 const std::function<void(const DataStore::Error &error)> &errorHandler, bool skipInternalKeys) const
480{ 477{
481 auto baKey = sizeTToByteArray(key); 478 return scan(sizeTToByteArray(key),
482 return scan(baKey,
483 [&resultHandler](const QByteArray &key, const QByteArray &value) { 479 [&resultHandler](const QByteArray &key, const QByteArray &value) {
484 size_t integerKey = byteArrayToSizeT(value); 480 return resultHandler(byteArrayToSizeT(value), value);
485 return resultHandler(integerKey, value);
486 }, 481 },
487 errorHandler, /* findSubstringKeys = */ false, skipInternalKeys); 482 errorHandler, /* findSubstringKeys = */ false, skipInternalKeys);
488} 483}
@@ -578,11 +573,9 @@ void DataStore::NamedDatabase::findLatest(size_t key,
578 const std::function<void(size_t key, const QByteArray &value)> &resultHandler, 573 const std::function<void(size_t key, const QByteArray &value)> &resultHandler,
579 const std::function<void(const DataStore::Error &error)> &errorHandler) const 574 const std::function<void(const DataStore::Error &error)> &errorHandler) const
580{ 575{
581 auto baKey = sizeTToByteArray(key); 576 return findLatest(sizeTToByteArray(key),
582 return findLatest(baKey,
583 [&resultHandler](const QByteArray &key, const QByteArray &value) { 577 [&resultHandler](const QByteArray &key, const QByteArray &value) {
584 size_t integerKey = byteArrayToSizeT(value); 578 resultHandler(byteArrayToSizeT(value), value);
585 resultHandler(integerKey, value);
586 }, 579 },
587 errorHandler); 580 errorHandler);
588} 581}
@@ -664,12 +657,9 @@ int DataStore::NamedDatabase::findAllInRange(const size_t lowerBound, const size
664 const std::function<void(size_t key, const QByteArray &value)> &resultHandler, 657 const std::function<void(size_t key, const QByteArray &value)> &resultHandler,
665 const std::function<void(const DataStore::Error &error)> &errorHandler) const 658 const std::function<void(const DataStore::Error &error)> &errorHandler) const
666{ 659{
667 auto baLowerBound = sizeTToByteArray(lowerBound); 660 return findAllInRange(sizeTToByteArray(lowerBound), sizeTToByteArray(upperBound),
668 auto baUpperBound = sizeTToByteArray(upperBound);
669 return findAllInRange(baLowerBound, baUpperBound,
670 [&resultHandler](const QByteArray &key, const QByteArray &value) { 661 [&resultHandler](const QByteArray &key, const QByteArray &value) {
671 size_t integerKey = byteArrayToSizeT(value); 662 resultHandler(byteArrayToSizeT(value), value);
672 resultHandler(integerKey, value);
673 }, 663 },
674 errorHandler); 664 errorHandler);
675} 665}