summaryrefslogtreecommitdiffstats
path: root/common/pipeline.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-02-16 17:43:22 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-02-16 17:43:22 +0100
commit529dd17eec62a9702b8837f8f1976dfbf28fdd82 (patch)
tree3fe5581a76b83cd9c4360b67e7dd99ceb8c0eaab /common/pipeline.cpp
parent8acaae496f9e816c4c1b1126fc6409b6fafe6500 (diff)
downloadsink-529dd17eec62a9702b8837f8f1976dfbf28fdd82.tar.gz
sink-529dd17eec62a9702b8837f8f1976dfbf28fdd82.zip
Prepared sort indexes
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);