diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-07 21:48:44 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-07 21:48:44 +0100 |
commit | 89b6f63bab839ab0504cd3067f0389afe4dc47e3 (patch) | |
tree | 62c527983d63827bb722010ea8c59d5af0e5a879 /common/synchronizer.h | |
parent | 438c74630e5f8c9a46d00b991f5cb8ecd479dafe (diff) | |
download | sink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.tar.gz sink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.zip |
Implement debug stream operators for query.
Diffstat (limited to 'common/synchronizer.h')
-rw-r--r-- | common/synchronizer.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/common/synchronizer.h b/common/synchronizer.h index 12bb587..c03c425 100644 --- a/common/synchronizer.h +++ b/common/synchronizer.h | |||
@@ -41,7 +41,7 @@ public: | |||
41 | virtual ~Synchronizer(); | 41 | virtual ~Synchronizer(); |
42 | 42 | ||
43 | void setup(const std::function<void(int commandId, const QByteArray &data)> &enqueueCommandCallback, MessageQueue &messageQueue); | 43 | void setup(const std::function<void(int commandId, const QByteArray &data)> &enqueueCommandCallback, MessageQueue &messageQueue); |
44 | KAsync::Job<void> synchronize(); | 44 | KAsync::Job<void> synchronize(const Sink::QueryBase &query); |
45 | 45 | ||
46 | //Read only access to main storage | 46 | //Read only access to main storage |
47 | Storage::EntityStore &store(); | 47 | Storage::EntityStore &store(); |
@@ -91,7 +91,7 @@ protected: | |||
91 | // template <typename DomainType> | 91 | // template <typename DomainType> |
92 | // void remove(const DomainType &entity); | 92 | // void remove(const DomainType &entity); |
93 | 93 | ||
94 | virtual KAsync::Job<void> synchronizeWithSource() = 0; | 94 | virtual KAsync::Job<void> synchronizeWithSource(const Sink::QueryBase &query) = 0; |
95 | 95 | ||
96 | private: | 96 | private: |
97 | void modifyIfChanged(Storage::EntityStore &store, const QByteArray &bufferType, const QByteArray &sinkId, const Sink::ApplicationDomain::ApplicationDomainType &entity); | 97 | void modifyIfChanged(Storage::EntityStore &store, const QByteArray &bufferType, const QByteArray &sinkId, const Sink::ApplicationDomain::ApplicationDomainType &entity); |