summaryrefslogtreecommitdiffstats
path: root/common/datastorequery.h
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-09-26 11:58:38 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-09-26 11:58:38 +0200
commitbe8dba1827ec54ec11d9a3ef143db9ad7f7f38df (patch)
tree4c441927d9e1851126143e5f8170d48fa87df17b /common/datastorequery.h
parent52ad48c8bd755a2fde249296d6017853538f478f (diff)
downloadsink-be8dba1827ec54ec11d9a3ef143db9ad7f7f38df.tar.gz
sink-be8dba1827ec54ec11d9a3ef143db9ad7f7f38df.zip
The threading reduction is working.
Diffstat (limited to 'common/datastorequery.h')
-rw-r--r--common/datastorequery.h7
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