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/genericresource.cpp | |
parent | 438c74630e5f8c9a46d00b991f5cb8ecd479dafe (diff) | |
download | sink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.tar.gz sink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.zip |
Implement debug stream operators for query.
Diffstat (limited to 'common/genericresource.cpp')
-rw-r--r-- | common/genericresource.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/common/genericresource.cpp b/common/genericresource.cpp index 39bd39e..1fc7744 100644 --- a/common/genericresource.cpp +++ b/common/genericresource.cpp | |||
@@ -399,9 +399,9 @@ void GenericResource::processCommand(int commandId, const QByteArray &data) | |||
399 | } | 399 | } |
400 | } | 400 | } |
401 | 401 | ||
402 | KAsync::Job<void> GenericResource::synchronizeWithSource() | 402 | KAsync::Job<void> GenericResource::synchronizeWithSource(const Sink::QueryBase &query) |
403 | { | 403 | { |
404 | return KAsync::start<void>([this]() { | 404 | return KAsync::start<void>([this, query] { |
405 | 405 | ||
406 | Sink::Notification n; | 406 | Sink::Notification n; |
407 | n.id = "sync"; | 407 | n.id = "sync"; |
@@ -413,7 +413,7 @@ KAsync::Job<void> GenericResource::synchronizeWithSource() | |||
413 | SinkLog() << " Synchronizing"; | 413 | SinkLog() << " Synchronizing"; |
414 | // Changereplay would deadlock otherwise when trying to open the synchronization store | 414 | // Changereplay would deadlock otherwise when trying to open the synchronization store |
415 | enableChangeReplay(false); | 415 | enableChangeReplay(false); |
416 | return mSynchronizer->synchronize() | 416 | return mSynchronizer->synchronize(query) |
417 | .then<void>([this](const KAsync::Error &error) { | 417 | .then<void>([this](const KAsync::Error &error) { |
418 | enableChangeReplay(true); | 418 | enableChangeReplay(true); |
419 | if (!error) { | 419 | if (!error) { |