summaryrefslogtreecommitdiffstats
path: root/common/genericresource.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-07 21:48:44 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-07 21:48:44 +0100
commit89b6f63bab839ab0504cd3067f0389afe4dc47e3 (patch)
tree62c527983d63827bb722010ea8c59d5af0e5a879 /common/genericresource.cpp
parent438c74630e5f8c9a46d00b991f5cb8ecd479dafe (diff)
downloadsink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.tar.gz
sink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.zip
Implement debug stream operators for query.
Diffstat (limited to 'common/genericresource.cpp')
-rw-r--r--common/genericresource.cpp6
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
402KAsync::Job<void> GenericResource::synchronizeWithSource() 402KAsync::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) {