diff options
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); |