diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-02-16 17:43:22 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-02-16 17:43:22 +0100 |
commit | 529dd17eec62a9702b8837f8f1976dfbf28fdd82 (patch) | |
tree | 3fe5581a76b83cd9c4360b67e7dd99ceb8c0eaab /common/pipeline.cpp | |
parent | 8acaae496f9e816c4c1b1126fc6409b6fafe6500 (diff) | |
download | sink-529dd17eec62a9702b8837f8f1976dfbf28fdd82.tar.gz sink-529dd17eec62a9702b8837f8f1976dfbf28fdd82.zip |
Prepared sort indexes
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r-- | common/pipeline.cpp | 1 |
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); |