Actually avoid superfluous readEntity calls.

We still read all values, but just reported the ones before the limit.
With this we query 1000 out of 50k values in 63ms.

1 files changed, 27 insertions, 25 deletions

diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp
index 4fab68d..1ef076e 100644
--- a/common/queryrunner.cpp
+++ b/common/queryrunner.cpp
@@ -180,34 +180,36 @@ QueryWorker<DomainType>::~QueryWorker()
 template<class DomainType>
 void QueryWorker<DomainType>::replaySet(ResultSet &resultSet, Sink::ResultProviderInterface<typename DomainType::Ptr> &resultProvider, const QList<QByteArray> &properties, int offset, int batchSize)
 {
-    int counter = 0;
+    Trace() << "Skipping over " << offset << " results";
     resultSet.skip(offset);
-    while (resultSet.next([this, &resultProvider, &counter, &properties, batchSize](const Sink::ApplicationDomain::ApplicationDomainType::Ptr &value, Sink::Operation operation) -> bool {
-        //FIXME allow maildir resource to set the mimeMessage property
-        auto valueCopy = Sink::ApplicationDomain::ApplicationDomainType::getInMemoryRepresentation<DomainType>(*value, properties).template staticCast<DomainType>();
-        if (mResultTransformation) {
-            mResultTransformation(*valueCopy);
-        }
-        if (batchSize && counter >= batchSize) {
-            return false;
-        }
-        counter++;
-        switch (operation) {
-        case Sink::Operation_Creation:
-            // Trace() << "Got creation";
-            resultProvider.add(valueCopy);
-            break;
-        case Sink::Operation_Modification:
-            // Trace() << "Got modification";
-            resultProvider.modify(valueCopy);
-            break;
-        case Sink::Operation_Removal:
-            // Trace() << "Got removal";
-            resultProvider.remove(valueCopy);
+    int counter;
+    for (counter = 0; !batchSize || (counter < batchSize); counter++) {
+        const bool ret = resultSet.next([this, &resultProvider, &counter, &properties, batchSize](const Sink::ApplicationDomain::ApplicationDomainType::Ptr &value, Sink::Operation operation) -> bool {
+            //FIXME allow maildir resource to set the mimeMessage property
+            auto valueCopy = Sink::ApplicationDomain::ApplicationDomainType::getInMemoryRepresentation<DomainType>(*value, properties).template staticCast<DomainType>();
+            if (mResultTransformation) {
+                mResultTransformation(*valueCopy);
+            }
+            switch (operation) {
+            case Sink::Operation_Creation:
+                // Trace() << "Got creation";
+                resultProvider.add(valueCopy);
+                break;
+            case Sink::Operation_Modification:
+                // Trace() << "Got modification";
+                resultProvider.modify(valueCopy);
+                break;
+            case Sink::Operation_Removal:
+                // Trace() << "Got removal";
+                resultProvider.remove(valueCopy);
+                break;
+            }
+            return true;
+        });
+        if (!ret) {
             break;
         }
-        return true;
-    })){};
+    };
     Trace() << "Replayed " << counter << " results." << "Limit " << batchSize;
 }