diff options
author | Minijackson <minijackson@riseup.net> | 2018-08-21 14:00:21 +0200 |
---|---|---|
committer | Minijackson <minijackson@riseup.net> | 2018-08-21 14:04:56 +0200 |
commit | 191730c624aae5fa7831fe900b98624b2ac1f1d7 (patch) | |
tree | 2f6d43e732a3f4343b970635ca751081d735a1c9 /common/storage_lmdb.cpp | |
parent | d320030c53cf9fd4338ca3f6da00a9b876c13397 (diff) | |
download | sink-191730c624aae5fa7831fe900b98624b2ac1f1d7.tar.gz sink-191730c624aae5fa7831fe900b98624b2ac1f1d7.zip |
resultHandler take size_t as argument for involved storage functions
Diffstat (limited to 'common/storage_lmdb.cpp')
-rw-r--r-- | common/storage_lmdb.cpp | 23 |
1 files changed, 21 insertions, 2 deletions
diff --git a/common/storage_lmdb.cpp b/common/storage_lmdb.cpp index 981d4ef..6afa1a8 100644 --- a/common/storage_lmdb.cpp +++ b/common/storage_lmdb.cpp | |||
@@ -573,6 +573,20 @@ int DataStore::NamedDatabase::scan(const QByteArray &k, const std::function<bool | |||
573 | return numberOfRetrievedValues; | 573 | return numberOfRetrievedValues; |
574 | } | 574 | } |
575 | 575 | ||
576 | |||
577 | void DataStore::NamedDatabase::findLatest(size_t key, | ||
578 | const std::function<void(size_t key, const QByteArray &value)> &resultHandler, | ||
579 | const std::function<void(const DataStore::Error &error)> &errorHandler) const | ||
580 | { | ||
581 | auto baKey = sizeTToByteArray(key); | ||
582 | return findLatest(baKey, | ||
583 | [&resultHandler](const QByteArray &key, const QByteArray &value) { | ||
584 | size_t integerKey = byteArrayToSizeT(value); | ||
585 | resultHandler(integerKey, value); | ||
586 | }, | ||
587 | errorHandler); | ||
588 | } | ||
589 | |||
576 | void DataStore::NamedDatabase::findLatest(const QByteArray &k, const std::function<void(const QByteArray &key, const QByteArray &value)> &resultHandler, | 590 | void DataStore::NamedDatabase::findLatest(const QByteArray &k, const std::function<void(const QByteArray &key, const QByteArray &value)> &resultHandler, |
577 | const std::function<void(const DataStore::Error &error)> &errorHandler) const | 591 | const std::function<void(const DataStore::Error &error)> &errorHandler) const |
578 | { | 592 | { |
@@ -647,12 +661,17 @@ void DataStore::NamedDatabase::findLatest(const QByteArray &k, const std::functi | |||
647 | } | 661 | } |
648 | 662 | ||
649 | int DataStore::NamedDatabase::findAllInRange(const size_t lowerBound, const size_t upperBound, | 663 | int DataStore::NamedDatabase::findAllInRange(const size_t lowerBound, const size_t upperBound, |
650 | const std::function<void(const QByteArray &key, const QByteArray &value)> &resultHandler, | 664 | const std::function<void(size_t key, const QByteArray &value)> &resultHandler, |
651 | const std::function<void(const DataStore::Error &error)> &errorHandler) const | 665 | const std::function<void(const DataStore::Error &error)> &errorHandler) const |
652 | { | 666 | { |
653 | auto baLowerBound = sizeTToByteArray(lowerBound); | 667 | auto baLowerBound = sizeTToByteArray(lowerBound); |
654 | auto baUpperBound = sizeTToByteArray(upperBound); | 668 | auto baUpperBound = sizeTToByteArray(upperBound); |
655 | return findAllInRange(baLowerBound, baUpperBound, resultHandler, errorHandler); | 669 | return findAllInRange(baLowerBound, baUpperBound, |
670 | [&resultHandler](const QByteArray &key, const QByteArray &value) { | ||
671 | size_t integerKey = byteArrayToSizeT(value); | ||
672 | resultHandler(integerKey, value); | ||
673 | }, | ||
674 | errorHandler); | ||
656 | } | 675 | } |
657 | 676 | ||
658 | int DataStore::NamedDatabase::findAllInRange(const QByteArray &lowerBound, const QByteArray &upperBound, | 677 | int DataStore::NamedDatabase::findAllInRange(const QByteArray &lowerBound, const QByteArray &upperBound, |