diff options
-rw-r--r-- | common/storage_lmdb.cpp | 28 |
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() | |||
382 | bool DataStore::NamedDatabase::write(const size_t key, const QByteArray &value, | 382 | bool 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 | ||
389 | bool DataStore::NamedDatabase::write(const QByteArray &sKey, const QByteArray &sValue, const std::function<void(const DataStore::Error &error)> &errorHandler) | 388 | bool 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 | |||
425 | void DataStore::NamedDatabase::remove( | 424 | void 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 | ||
432 | void DataStore::NamedDatabase::remove(const QByteArray &k, const std::function<void(const DataStore::Error &error)> &errorHandler) | 430 | void 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 | |||
437 | void DataStore::NamedDatabase::remove(const size_t key, const QByteArray &value, | 435 | void 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 | ||
444 | void DataStore::NamedDatabase::remove(const QByteArray &k, const QByteArray &value, const std::function<void(const DataStore::Error &error)> &errorHandler) | 441 | void 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 | } |