diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-07-20 09:46:37 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-09-15 16:14:19 +0200 |
commit | 9a22126970a0e560e05ece5e8cdf7bb0ec5bc7eb (patch) | |
tree | c0cd06ae71233d42a3aa989de000f63013ee20ff /common/pipeline.cpp | |
parent | 993a9eadb30c55bbb764a1fc123c5dfbb502b1f1 (diff) | |
download | sink-9a22126970a0e560e05ece5e8cdf7bb0ec5bc7eb.tar.gz sink-9a22126970a0e560e05ece5e8cdf7bb0ec5bc7eb.zip |
Debug output
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r-- | common/pipeline.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp index 000d2b2..1d45340 100644 --- a/common/pipeline.cpp +++ b/common/pipeline.cpp | |||
@@ -189,7 +189,7 @@ KAsync::Job<qint64> Pipeline::newEntity(void const *command, size_t size) | |||
189 | if (key.isEmpty()) { | 189 | if (key.isEmpty()) { |
190 | key = Sink::Storage::generateUid(); | 190 | key = Sink::Storage::generateUid(); |
191 | } | 191 | } |
192 | SinkLog() << "New Entity. Type: " << bufferType << "uid: "<< key << " replayToSource: " << replayToSource; | 192 | SinkTrace() << "New Entity. Type: " << bufferType << "uid: "<< key << " replayToSource: " << replayToSource; |
193 | Q_ASSERT(!key.isEmpty()); | 193 | Q_ASSERT(!key.isEmpty()); |
194 | 194 | ||
195 | { | 195 | { |
@@ -259,7 +259,7 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) | |||
259 | const bool replayToSource = modifyEntity->replayToSource(); | 259 | const bool replayToSource = modifyEntity->replayToSource(); |
260 | const QByteArray bufferType = QByteArray(reinterpret_cast<char const *>(modifyEntity->domainType()->Data()), modifyEntity->domainType()->size()); | 260 | const QByteArray bufferType = QByteArray(reinterpret_cast<char const *>(modifyEntity->domainType()->Data()), modifyEntity->domainType()->size()); |
261 | const QByteArray key = QByteArray(reinterpret_cast<char const *>(modifyEntity->entityId()->Data()), modifyEntity->entityId()->size()); | 261 | const QByteArray key = QByteArray(reinterpret_cast<char const *>(modifyEntity->entityId()->Data()), modifyEntity->entityId()->size()); |
262 | SinkLog() << "Modified Entity. Type: " << bufferType << "uid: "<< key << " replayToSource: " << replayToSource; | 262 | SinkTrace() << "Modified Entity. Type: " << bufferType << "uid: "<< key << " replayToSource: " << replayToSource; |
263 | if (bufferType.isEmpty() || key.isEmpty()) { | 263 | if (bufferType.isEmpty() || key.isEmpty()) { |
264 | SinkWarning() << "entity type or key " << bufferType << key; | 264 | SinkWarning() << "entity type or key " << bufferType << key; |
265 | return KAsync::error<qint64>(0); | 265 | return KAsync::error<qint64>(0); |
@@ -365,7 +365,7 @@ KAsync::Job<qint64> Pipeline::deletedEntity(void const *command, size_t size) | |||
365 | const bool replayToSource = deleteEntity->replayToSource(); | 365 | const bool replayToSource = deleteEntity->replayToSource(); |
366 | const QByteArray bufferType = QByteArray(reinterpret_cast<char const *>(deleteEntity->domainType()->Data()), deleteEntity->domainType()->size()); | 366 | const QByteArray bufferType = QByteArray(reinterpret_cast<char const *>(deleteEntity->domainType()->Data()), deleteEntity->domainType()->size()); |
367 | const QByteArray key = QByteArray(reinterpret_cast<char const *>(deleteEntity->entityId()->Data()), deleteEntity->entityId()->size()); | 367 | const QByteArray key = QByteArray(reinterpret_cast<char const *>(deleteEntity->entityId()->Data()), deleteEntity->entityId()->size()); |
368 | SinkLog() << "Deleted Entity. Type: " << bufferType << "uid: "<< key << " replayToSource: " << replayToSource; | 368 | SinkTrace() << "Deleted Entity. Type: " << bufferType << "uid: "<< key << " replayToSource: " << replayToSource; |
369 | 369 | ||
370 | bool found = false; | 370 | bool found = false; |
371 | bool alreadyRemoved = false; | 371 | bool alreadyRemoved = false; |