Fixed sync, detect errors during sync, wait until sync items are processed until signalling completion.

1 files changed, 3 insertions, 0 deletions

diff --git a/dummyresource/resourcefactory.h b/dummyresource/resourcefactory.h
index 6043fb6..767eba1 100644
--- a/dummyresource/resourcefactory.h
+++ b/dummyresource/resourcefactory.h
@@ -37,13 +37,16 @@ public:
     Async::Job<void> synchronizeWithSource(Akonadi2::Pipeline *pipeline);
     void processCommand(int commandId, const QByteArray &data, uint size, Akonadi2::Pipeline *pipeline);
     void configurePipeline(Akonadi2::Pipeline *pipeline);
+    int error() const;
 
 private:
+    void onProcessorError(int errorCode, const QString &errorMessage);
     void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data);
     flatbuffers::FlatBufferBuilder m_fbb;
     MessageQueue mUserQueue;
     MessageQueue mSynchronizerQueue;
     Processor *mProcessor;
+    int mError;
 };
 
 class DummyResourceFactory : public Akonadi2::ResourceFactory