8 files changed, 24 insertions, 12 deletions

diff --git a/common/domainadaptor.h b/common/domainadaptor.h
index 4943cc0..e881b9a 100644
--- a/common/domainadaptor.h
+++ b/common/domainadaptor.h
@@ -173,13 +173,13 @@ public:
     {
         flatbuffers::FlatBufferBuilder localFbb;
         if (mLocalWriteMapper) {
-            Trace() << "Creating local buffer part";
+            // Trace() << "Creating local buffer part";
             createBufferPartBuffer<LocalBuffer, LocalBuilder>(domainObject, localFbb, *mLocalWriteMapper);
         }
 
         flatbuffers::FlatBufferBuilder resFbb;
         if (mResourceWriteMapper) {
-            Trace() << "Creating resouce buffer part";
+            // Trace() << "Creating resouce buffer part";
             createBufferPartBuffer<ResourceBuffer, ResourceBuilder>(domainObject, resFbb, *mResourceWriteMapper);
         }
 
diff --git a/common/facade.h b/common/facade.h
index 0ddc205..13734f0 100644
--- a/common/facade.h
+++ b/common/facade.h
@@ -271,7 +271,7 @@ public:
         }
 
         //We have to capture the runner to keep it alive
-        return synchronizeResource(query.syncOnDemand, query.processAll).template then<void>([runner](KAsync::Future<void> &future) {
+        return synchronizeResource(query).template then<void>([runner](KAsync::Future<void> &future) {
             runner->run().then<void>([&future]() {
                 future.setFinished();
             }).exec();
@@ -281,19 +281,18 @@ public:
         });
     }
 
-protected:
-    KAsync::Job<void> synchronizeResource(bool sync, bool processAll)
+private:
+    KAsync::Job<void> synchronizeResource(const Akonadi2::Query &query)
     {
         //TODO check if a sync is necessary
         //TODO Only sync what was requested
         //TODO timeout
-        if (sync || processAll) {
-            return mResourceAccess->synchronizeResource(sync, processAll);
+        if (query.syncOnDemand || query.processAll) {
+            return mResourceAccess->synchronizeResource(query.syncOnDemand, query.processAll);
         }
         return KAsync::null<void>();
     }
 
-private:
     virtual KAsync::Job<qint64> load(const Akonadi2::Query &query, const QSharedPointer<Akonadi2::ResultProvider<typename DomainType::Ptr> > &resultProvider, qint64 oldRevision)
     {
         return KAsync::start<qint64>([=]() -> qint64 {
diff --git a/common/genericresource.cpp b/common/genericresource.cpp
index 8ae20ed..dcae43d 100644
--- a/common/genericresource.cpp
+++ b/common/genericresource.cpp
@@ -26,7 +26,7 @@ public:
 
     typedef std::function<KAsync::Job<void>(const QByteArray &type, const QByteArray &key, const QByteArray &value)> ReplayFunction;
 
-    ChangeReplay(const QString &resourceName, const ReplayFunction replayFunction)
+    ChangeReplay(const QString &resourceName, const ReplayFunction &replayFunction)
         : mStorage(storageLocation(), resourceName, Storage::ReadOnly),
         mChangeReplayStore(storageLocation(), resourceName + ".changereplay", Storage::ReadWrite),
         mReplayFunction(replayFunction)
@@ -224,6 +224,7 @@ private slots:
     KAsync::Job<void> processPipeline()
     {
         mPipeline->startTransaction();
+        Trace() << "Cleaning up from " << mPipeline->cleanedUpRevision() + 1 << " to " << mLowerBoundRevision;
         for (qint64 revision = mPipeline->cleanedUpRevision() + 1; revision <= mLowerBoundRevision; revision++) {
             mPipeline->cleanupRevision(revision);
         }
diff --git a/common/log.cpp b/common/log.cpp
index 25102dd..c33c700 100644
--- a/common/log.cpp
+++ b/common/log.cpp
@@ -187,7 +187,7 @@ QDebug Akonadi2::Log::debugStream(DebugLevel debugLevel, int line, const char* f
     }
     if (showLocation) {
         output += QString(" %3").arg(function);
-        /*debug << file << ":" << line */
+        output += QString("%1:%2").arg(file).arg(line);
     }
     output += ":";
 
diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index 9816129..15d2401 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -518,7 +518,6 @@ void PipelineState::step()
 
 void PipelineState::processingCompleted(Preprocessor *filter)
 {
-    //TODO record processing progress
     if (d->pipeline && filter == d->filterIt.peekPrevious()) {
         d->idle = true;
         d->pipeline->pipelineStepped(*this);
diff --git a/common/pipeline.h b/common/pipeline.h
index 837c18a..c8d9ddc 100644
--- a/common/pipeline.h
+++ b/common/pipeline.h
@@ -164,7 +164,7 @@ public:
         });
     }
 
-    QString id() const
+    QString id() const Q_DECL_OVERRIDE
     {
         return mId;
     }
diff --git a/common/resource.h b/common/resource.h
index 33805ca..4ed21b5 100644
--- a/common/resource.h
+++ b/common/resource.h
@@ -37,8 +37,20 @@ public:
     virtual ~Resource();
 
     virtual void processCommand(int commandId, const QByteArray &data);
+
+    /**
+     * Execute synchronization with the source.
+     */
     virtual KAsync::Job<void> synchronizeWithSource();
+
+    /**
+     * Process all internal messages, thus ensuring the store is up to date and no pending modifications are left.
+     */
     virtual KAsync::Job<void> processAllMessages();
+
+    /**
+     * Set the lowest revision that is still referenced by external clients.
+     */
     virtual void setLowerBoundRevision(qint64 revision);
 
 Q_SIGNALS:
diff --git a/examples/dummyresource/resourcefactory.cpp b/examples/dummyresource/resourcefactory.cpp
index 0e4c3af..8e6bd42 100644
--- a/examples/dummyresource/resourcefactory.cpp
+++ b/examples/dummyresource/resourcefactory.cpp
@@ -154,6 +154,7 @@ void DummyResource::synchronize(const QString &bufferType, const QMap<QString, Q
 
 KAsync::Job<void> DummyResource::synchronizeWithSource()
 {
+    Log() << " Synchronizing";
     return KAsync::start<void>([this](KAsync::Future<void> &f) {
         auto transaction = Akonadi2::Storage(Akonadi2::storageLocation(), mResourceInstanceIdentifier, Akonadi2::Storage::ReadOnly).createTransaction(Akonadi2::Storage::ReadOnly);