summaryrefslogtreecommitdiffstats
path: root/common/listener.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-12-26 12:29:49 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-12-26 12:29:49 +0100
commit9bab96fcca9dd752c6068ed620cd32adf0f9dae7 (patch)
treedf5094306b2d46f921d0213ab3f3537301042021 /common/listener.cpp
parent2cf098e6e2f28453f4c656fa081d7d6eed179d63 (diff)
downloadsink-9bab96fcca9dd752c6068ed620cd32adf0f9dae7.tar.gz
sink-9bab96fcca9dd752c6068ed620cd32adf0f9dae7.zip
Time sync
Diffstat (limited to 'common/listener.cpp')
-rw-r--r--common/listener.cpp6
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
39Listener::Listener(const QByteArray &resourceInstanceIdentifier, QObject *parent) 40Listener::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;