diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-12-26 12:29:49 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-12-26 12:29:49 +0100 |
commit | 9bab96fcca9dd752c6068ed620cd32adf0f9dae7 (patch) | |
tree | df5094306b2d46f921d0213ab3f3537301042021 /common/listener.cpp | |
parent | 2cf098e6e2f28453f4c656fa081d7d6eed179d63 (diff) | |
download | sink-9bab96fcca9dd752c6068ed620cd32adf0f9dae7.tar.gz sink-9bab96fcca9dd752c6068ed620cd32adf0f9dae7.zip |
Time sync
Diffstat (limited to 'common/listener.cpp')
-rw-r--r-- | common/listener.cpp | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/common/listener.cpp b/common/listener.cpp index 5468769..1b78f01 100644 --- a/common/listener.cpp +++ b/common/listener.cpp | |||
@@ -35,6 +35,7 @@ | |||
35 | #include <QLocalServer> | 35 | #include <QLocalServer> |
36 | #include <QLocalSocket> | 36 | #include <QLocalSocket> |
37 | #include <QTimer> | 37 | #include <QTimer> |
38 | #include <QTime> | ||
38 | 39 | ||
39 | Listener::Listener(const QByteArray &resourceInstanceIdentifier, QObject *parent) | 40 | Listener::Listener(const QByteArray &resourceInstanceIdentifier, QObject *parent) |
40 | : QObject(parent), | 41 | : QObject(parent), |
@@ -220,6 +221,8 @@ void Listener::processCommand(int commandId, uint messageId, const QByteArray &c | |||
220 | if (Akonadi2::VerifySynchronizeBuffer(verifier)) { | 221 | if (Akonadi2::VerifySynchronizeBuffer(verifier)) { |
221 | auto buffer = Akonadi2::GetSynchronize(commandBuffer.constData()); | 222 | auto buffer = Akonadi2::GetSynchronize(commandBuffer.constData()); |
222 | Log() << QString("\tSynchronize request (id %1) from %2").arg(messageId).arg(client.name); | 223 | Log() << QString("\tSynchronize request (id %1) from %2").arg(messageId).arg(client.name); |
224 | auto timer = QSharedPointer<QTime>::create(); | ||
225 | timer->start(); | ||
223 | auto job = KAsync::null<void>(); | 226 | auto job = KAsync::null<void>(); |
224 | if (buffer->sourceSync()) { | 227 | if (buffer->sourceSync()) { |
225 | job = loadResource()->synchronizeWithSource(); | 228 | job = loadResource()->synchronizeWithSource(); |
@@ -227,7 +230,8 @@ void Listener::processCommand(int commandId, uint messageId, const QByteArray &c | |||
227 | if (buffer->localSync()) { | 230 | if (buffer->localSync()) { |
228 | job = job.then<void>(loadResource()->processAllMessages()); | 231 | job = job.then<void>(loadResource()->processAllMessages()); |
229 | } | 232 | } |
230 | job.then<void>([callback]() { | 233 | job.then<void>([callback, timer]() { |
234 | Trace() << "Sync took " << timer->elapsed(); | ||
231 | callback(); | 235 | callback(); |
232 | }).exec(); | 236 | }).exec(); |
233 | return; | 237 | return; |