Avoid missing revision updates while a query is running.

Instead we have to remember that something has changed and rerun an
incremental query.

1 files changed, 8 insertions, 1 deletions

diff --git a/common/queryrunner.h b/common/queryrunner.h
index 35093e2..e449570 100644
--- a/common/queryrunner.h
+++ b/common/queryrunner.h
@@ -77,7 +77,7 @@ private:
  * QueryRunner has to keep ResourceAccess alive in order to keep getting updates.
  */
 template <typename DomainType>
-class QueryRunner : public QueryRunnerBase
+class SINK_EXPORT QueryRunner : public QueryRunnerBase
 {
 public:
     QueryRunner(const Sink::Query &query, const Sink::ResourceContext &context, const QByteArray &bufferType, const Sink::Log::Context &logCtx);
@@ -91,6 +91,11 @@ public:
 
     typename Sink::ResultEmitter<typename DomainType::Ptr>::Ptr emitter();
 
+    /**
+     * For testing only.
+     */
+    void delayNextQuery();
+
 private:
     void fetch(const Sink::Query &query, const QByteArray &bufferType);
     KAsync::Job<void> incrementalFetch(const Sink::Query &query, const QByteArray &bufferType);
@@ -106,4 +111,6 @@ private:
     bool mInitialQueryComplete = false;
     bool mQueryInProgress = false;
     bool mRequestFetchMore = false;
+    bool mDelayNextQuery = false;
+    bool mRevisionChangedMeanwhile = false;
 };