summaryrefslogtreecommitdiffstats
path: root/common/pipeline.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r--common/pipeline.cpp1
1 files changed, 1 insertions, 0 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index 93d8236..35e582b 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -209,6 +209,7 @@ KAsync::Job<qint64> Pipeline::newEntity(void const *command, size_t size)
209 Log() << "Pipeline: wrote entity: " << key << newRevision << bufferType; 209 Log() << "Pipeline: wrote entity: " << key << newRevision << bufferType;
210 Storage::mainDatabase(d->transaction, bufferType).scan(Storage::assembleKey(key, newRevision), [this, bufferType, newRevision, adaptorFactory, key](const QByteArray &, const QByteArray &value) -> bool { 210 Storage::mainDatabase(d->transaction, bufferType).scan(Storage::assembleKey(key, newRevision), [this, bufferType, newRevision, adaptorFactory, key](const QByteArray &, const QByteArray &value) -> bool {
211 auto entity = GetEntity(value); 211 auto entity = GetEntity(value);
212 Q_ASSERT(entity->resource() || entity->local());
212 auto adaptor = adaptorFactory->createAdaptor(*entity); 213 auto adaptor = adaptorFactory->createAdaptor(*entity);
213 for (auto processor : d->processors[bufferType]) { 214 for (auto processor : d->processors[bufferType]) {
214 processor->newEntity(key, newRevision, *adaptor, d->transaction); 215 processor->newEntity(key, newRevision, *adaptor, d->transaction);