diff options
-rw-r--r-- | common/changereplay.cpp | 2 | ||||
-rw-r--r-- | common/listener.cpp | 2 | ||||
-rw-r--r-- | examples/davresource/davresource.cpp | 1 |
3 files changed, 1 insertions, 4 deletions
diff --git a/common/changereplay.cpp b/common/changereplay.cpp index 6b4540e..7895b66 100644 --- a/common/changereplay.cpp +++ b/common/changereplay.cpp | |||
@@ -33,7 +33,6 @@ ChangeReplay::ChangeReplay(const ResourceContext &resourceContext, const Sink::L | |||
33 | : mStorage(storageLocation(), resourceContext.instanceId(), DataStore::ReadOnly), mChangeReplayStore(storageLocation(), resourceContext.instanceId() + ".changereplay", DataStore::ReadWrite), mReplayInProgress(false), mLogCtx{ctx.subContext("changereplay")}, | 33 | : mStorage(storageLocation(), resourceContext.instanceId(), DataStore::ReadOnly), mChangeReplayStore(storageLocation(), resourceContext.instanceId() + ".changereplay", DataStore::ReadWrite), mReplayInProgress(false), mLogCtx{ctx.subContext("changereplay")}, |
34 | mGuard{new QObject} | 34 | mGuard{new QObject} |
35 | { | 35 | { |
36 | SinkTraceCtx(mLogCtx) << "Created change replay: " << resourceContext.instanceId(); | ||
37 | } | 36 | } |
38 | 37 | ||
39 | qint64 ChangeReplay::getLastReplayedRevision() | 38 | qint64 ChangeReplay::getLastReplayedRevision() |
@@ -55,7 +54,6 @@ bool ChangeReplay::allChangesReplayed() | |||
55 | SinkWarningCtx(mLogCtx) << error.message; | 54 | SinkWarningCtx(mLogCtx) << error.message; |
56 | })); | 55 | })); |
57 | const qint64 lastReplayedRevision = getLastReplayedRevision(); | 56 | const qint64 lastReplayedRevision = getLastReplayedRevision(); |
58 | SinkTraceCtx(mLogCtx) << "Checking if all replayed. Top revision:" << topRevision << "Last replayed:" << lastReplayedRevision; | ||
59 | return (lastReplayedRevision >= topRevision); | 57 | return (lastReplayedRevision >= topRevision); |
60 | } | 58 | } |
61 | 59 | ||
diff --git a/common/listener.cpp b/common/listener.cpp index 96806ad..2f5bd47 100644 --- a/common/listener.cpp +++ b/common/listener.cpp | |||
@@ -67,7 +67,7 @@ Listener::Listener(const QByteArray &resourceInstanceIdentifier, const QByteArra | |||
67 | m_checkConnectionsTimer->setInterval(1000); | 67 | m_checkConnectionsTimer->setInterval(1000); |
68 | connect(m_checkConnectionsTimer.get(), &QTimer::timeout, [this]() { | 68 | connect(m_checkConnectionsTimer.get(), &QTimer::timeout, [this]() { |
69 | if (m_connections.isEmpty()) { | 69 | if (m_connections.isEmpty()) { |
70 | SinkLog() << QString("No connections, shutting down."); | 70 | SinkTrace() << QString("No connections, shutting down."); |
71 | quit(); | 71 | quit(); |
72 | } | 72 | } |
73 | }); | 73 | }); |
diff --git a/examples/davresource/davresource.cpp b/examples/davresource/davresource.cpp index d7254b4..50471ed 100644 --- a/examples/davresource/davresource.cpp +++ b/examples/davresource/davresource.cpp | |||
@@ -140,7 +140,6 @@ public: | |||
140 | if (error) { | 140 | if (error) { |
141 | SinkWarningCtx(mLogCtx) << "Failed to synchronize addressbooks." << collectionsFetchJob->errorString(); | 141 | SinkWarningCtx(mLogCtx) << "Failed to synchronize addressbooks." << collectionsFetchJob->errorString(); |
142 | } else { | 142 | } else { |
143 | SinkWarningCtx(mLogCtx) << "Fetched addressbooks." << collectionsFetchJob->errorString(); | ||
144 | synchronizeAddressbooks(collectionsFetchJob ->collections()); | 143 | synchronizeAddressbooks(collectionsFetchJob ->collections()); |
145 | } | 144 | } |
146 | }); | 145 | }); |