diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-09-26 11:58:38 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-09-26 11:58:38 +0200 |
commit | be8dba1827ec54ec11d9a3ef143db9ad7f7f38df (patch) | |
tree | 4c441927d9e1851126143e5f8170d48fa87df17b /common/datastorequery.h | |
parent | 52ad48c8bd755a2fde249296d6017853538f478f (diff) | |
download | sink-be8dba1827ec54ec11d9a3ef143db9ad7f7f38df.tar.gz sink-be8dba1827ec54ec11d9a3ef143db9ad7f7f38df.zip |
The threading reduction is working.
Diffstat (limited to 'common/datastorequery.h')
-rw-r--r-- | common/datastorequery.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/common/datastorequery.h b/common/datastorequery.h index c9f6a3a..ea61780 100644 --- a/common/datastorequery.h +++ b/common/datastorequery.h | |||
@@ -44,6 +44,7 @@ protected: | |||
44 | typedef std::function<void(const QByteArray &uid, const Sink::EntityBuffer &entityBuffer)> BufferCallback; | 44 | typedef std::function<void(const QByteArray &uid, const Sink::EntityBuffer &entityBuffer)> BufferCallback; |
45 | 45 | ||
46 | virtual QVariant getProperty(const Sink::Entity &entity, const QByteArray &property); | 46 | virtual QVariant getProperty(const Sink::Entity &entity, const QByteArray &property); |
47 | QVector<QByteArray> indexLookup(const QByteArray &property, const QVariant &value); | ||
47 | 48 | ||
48 | virtual void readEntity(const QByteArray &key, const BufferCallback &resultCallback); | 49 | virtual void readEntity(const QByteArray &key, const BufferCallback &resultCallback); |
49 | 50 | ||
@@ -100,6 +101,12 @@ public: | |||
100 | return mDatastore->getProperty(entity, property); | 101 | return mDatastore->getProperty(entity, property); |
101 | } | 102 | } |
102 | 103 | ||
104 | QVector<QByteArray> indexLookup(const QByteArray &property, const QVariant &value) | ||
105 | { | ||
106 | Q_ASSERT(mDatastore); | ||
107 | return mDatastore->indexLookup(property, value); | ||
108 | } | ||
109 | |||
103 | virtual void skip() { mSource->skip(); }; | 110 | virtual void skip() { mSource->skip(); }; |
104 | 111 | ||
105 | //Returns true for as long as a result is available | 112 | //Returns true for as long as a result is available |