summaryrefslogtreecommitdiffstats
path: root/common/pipeline.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-04-02 17:16:09 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-04-02 17:16:09 +0200
commit64a3e2d9ba3fe79dee53d86a4469f760eea8fcf9 (patch)
treeb93f4760015e320e8c7151ae920b031c1207382b /common/pipeline.cpp
parent94729eef71570e0b792a9afb95eeab7fd1eec56b (diff)
downloadsink-64a3e2d9ba3fe79dee53d86a4469f760eea8fcf9.tar.gz
sink-64a3e2d9ba3fe79dee53d86a4469f760eea8fcf9.zip
Cleanup and debug messages.
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r--common/pipeline.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index f321cf5..ed40699 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -30,6 +30,7 @@
30#include "createentity_generated.h" 30#include "createentity_generated.h"
31#include "entitybuffer.h" 31#include "entitybuffer.h"
32#include "async/src/async.h" 32#include "async/src/async.h"
33#include "log.h"
33 34
34namespace Akonadi2 35namespace Akonadi2
35{ 36{
@@ -95,7 +96,7 @@ void Pipeline::null()
95 96
96Async::Job<void> Pipeline::newEntity(void const *command, size_t size) 97Async::Job<void> Pipeline::newEntity(void const *command, size_t size)
97{ 98{
98 qDebug() << "Pipeline: New Entity"; 99 Log() << "Pipeline: New Entity";
99 100
100 //TODO toRFC4122 would probably be more efficient, but results in non-printable keys. 101 //TODO toRFC4122 would probably be more efficient, but results in non-printable keys.
101 const auto key = QUuid::createUuid().toString().toUtf8(); 102 const auto key = QUuid::createUuid().toString().toUtf8();
@@ -136,7 +137,7 @@ Async::Job<void> Pipeline::newEntity(void const *command, size_t size)
136 137
137 storage().write(key.data(), key.size(), fbb.GetBufferPointer(), fbb.GetSize()); 138 storage().write(key.data(), key.size(), fbb.GetBufferPointer(), fbb.GetSize());
138 storage().setMaxRevision(newRevision); 139 storage().setMaxRevision(newRevision);
139 qDebug() << "Pipeline: wrote entity: "<< newRevision; 140 Log() << "Pipeline: wrote entity: "<< newRevision;
140 141
141 return Async::start<void>([this, key, entityType](Async::Future<void> &future) { 142 return Async::start<void>([this, key, entityType](Async::Future<void> &future) {
142 PipelineState state(this, NewPipeline, key, d->newPipeline[entityType], [&future]() { 143 PipelineState state(this, NewPipeline, key, d->newPipeline[entityType], [&future]() {