diff options
Diffstat (limited to 'common/pipeline.cpp')
-rw-r--r-- | common/pipeline.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp index 976a83f..c6d5297 100644 --- a/common/pipeline.cpp +++ b/common/pipeline.cpp | |||
@@ -305,7 +305,7 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) | |||
305 | 305 | ||
306 | // Apply diff | 306 | // Apply diff |
307 | // FIXME only apply the properties that are available in the buffer | 307 | // FIXME only apply the properties that are available in the buffer |
308 | Trace() << "Applying changed properties: " << diff->availableProperties(); | 308 | Trace() << "Applying changed properties: " << changeset; |
309 | for (const auto &property : changeset) { | 309 | for (const auto &property : changeset) { |
310 | const auto value = diff->getProperty(property); | 310 | const auto value = diff->getProperty(property); |
311 | if (value.isValid()) { | 311 | if (value.isValid()) { |
@@ -320,6 +320,7 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) | |||
320 | } | 320 | } |
321 | } | 321 | } |
322 | 322 | ||
323 | newAdaptor->resetChangedProperties(); | ||
323 | for (auto processor : d->processors[bufferType]) { | 324 | for (auto processor : d->processors[bufferType]) { |
324 | processor->modifiedEntity(key, Storage::maxRevision(d->transaction) + 1, *current, *newAdaptor, d->transaction); | 325 | processor->modifiedEntity(key, Storage::maxRevision(d->transaction) + 1, *current, *newAdaptor, d->transaction); |
325 | } | 326 | } |
@@ -330,7 +331,7 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) | |||
330 | flatbuffers::FlatBufferBuilder metadataFbb; | 331 | flatbuffers::FlatBufferBuilder metadataFbb; |
331 | { | 332 | { |
332 | //We add availableProperties to account for the properties that have been changed by the preprocessors | 333 | //We add availableProperties to account for the properties that have been changed by the preprocessors |
333 | auto modifiedProperties = BufferUtils::toVector(metadataFbb, changeset + newAdaptor->availableProperties()); | 334 | auto modifiedProperties = BufferUtils::toVector(metadataFbb, changeset + newAdaptor->changedProperties()); |
334 | auto metadataBuilder = MetadataBuilder(metadataFbb); | 335 | auto metadataBuilder = MetadataBuilder(metadataFbb); |
335 | metadataBuilder.add_revision(newRevision); | 336 | metadataBuilder.add_revision(newRevision); |
336 | metadataBuilder.add_operation(Operation_Modification); | 337 | metadataBuilder.add_operation(Operation_Modification); |