diff options
-rw-r--r-- | common/pipeline.cpp | 10 | ||||
-rw-r--r-- | common/pipeline.h | 2 | ||||
-rw-r--r-- | examples/mailtransportresource/mailtransportresource.cpp | 2 |
3 files changed, 7 insertions, 7 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp index 78eb29b..f5cf995 100644 --- a/common/pipeline.cpp +++ b/common/pipeline.cpp | |||
@@ -270,7 +270,7 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) | |||
270 | 270 | ||
271 | foreach (const auto &processor, d->processors[bufferType]) { | 271 | foreach (const auto &processor, d->processors[bufferType]) { |
272 | bool exitLoop = false; | 272 | bool exitLoop = false; |
273 | const auto result = processor->processModification(Preprocessor::Modification, current, newEntity); | 273 | const auto result = processor->process(Preprocessor::Modification, current, newEntity); |
274 | switch (result.action) { | 274 | switch (result.action) { |
275 | case Preprocessor::MoveToResource: | 275 | case Preprocessor::MoveToResource: |
276 | isMove = true; | 276 | isMove = true; |
@@ -412,18 +412,18 @@ void Preprocessor::deletedEntity(const ApplicationDomain::ApplicationDomainType | |||
412 | 412 | ||
413 | } | 413 | } |
414 | 414 | ||
415 | Preprocessor::Result Preprocessor::processModification(Type type, const ApplicationDomain::ApplicationDomainType ¤t, ApplicationDomain::ApplicationDomainType &diff) | 415 | Preprocessor::Result Preprocessor::process(Type type, const ApplicationDomain::ApplicationDomainType ¤t, ApplicationDomain::ApplicationDomainType &diff) |
416 | { | 416 | { |
417 | switch(type) { | 417 | switch(type) { |
418 | case Creation: | 418 | case Creation: |
419 | newEntity(diff); | 419 | newEntity(diff); |
420 | return {NoAction}; | 420 | break; |
421 | case Modification: | 421 | case Modification: |
422 | modifiedEntity(current, diff); | 422 | modifiedEntity(current, diff); |
423 | return {NoAction}; | 423 | break; |
424 | case Deletion: | 424 | case Deletion: |
425 | deletedEntity(current); | 425 | deletedEntity(current); |
426 | return {NoAction}; | 426 | break; |
427 | default: | 427 | default: |
428 | break; | 428 | break; |
429 | } | 429 | } |
diff --git a/common/pipeline.h b/common/pipeline.h index 11d52fd..684100e 100644 --- a/common/pipeline.h +++ b/common/pipeline.h | |||
@@ -98,7 +98,7 @@ public: | |||
98 | virtual void newEntity(ApplicationDomain::ApplicationDomainType &newEntity); | 98 | virtual void newEntity(ApplicationDomain::ApplicationDomainType &newEntity); |
99 | virtual void modifiedEntity(const ApplicationDomain::ApplicationDomainType &oldEntity, ApplicationDomain::ApplicationDomainType &newEntity); | 99 | virtual void modifiedEntity(const ApplicationDomain::ApplicationDomainType &oldEntity, ApplicationDomain::ApplicationDomainType &newEntity); |
100 | virtual void deletedEntity(const ApplicationDomain::ApplicationDomainType &oldEntity); | 100 | virtual void deletedEntity(const ApplicationDomain::ApplicationDomainType &oldEntity); |
101 | virtual Result processModification(Type type, const ApplicationDomain::ApplicationDomainType ¤t, ApplicationDomain::ApplicationDomainType &diff); | 101 | virtual Result process(Type type, const ApplicationDomain::ApplicationDomainType ¤t, ApplicationDomain::ApplicationDomainType &diff); |
102 | virtual void finalizeBatch(); | 102 | virtual void finalizeBatch(); |
103 | 103 | ||
104 | void setup(const QByteArray &resourceType, const QByteArray &resourceInstanceIdentifier, Pipeline *, Storage::EntityStore *entityStore); | 104 | void setup(const QByteArray &resourceType, const QByteArray &resourceInstanceIdentifier, Pipeline *, Storage::EntityStore *entityStore); |
diff --git a/examples/mailtransportresource/mailtransportresource.cpp b/examples/mailtransportresource/mailtransportresource.cpp index 8a4ef92..c73219f 100644 --- a/examples/mailtransportresource/mailtransportresource.cpp +++ b/examples/mailtransportresource/mailtransportresource.cpp | |||
@@ -66,7 +66,7 @@ public: | |||
66 | return targetResource.identifier(); | 66 | return targetResource.identifier(); |
67 | } | 67 | } |
68 | 68 | ||
69 | virtual Result processModification(Type type, const ApplicationDomain::ApplicationDomainType ¤t, ApplicationDomain::ApplicationDomainType &diff) Q_DECL_OVERRIDE | 69 | virtual Result process(Type type, const ApplicationDomain::ApplicationDomainType ¤t, ApplicationDomain::ApplicationDomainType &diff) Q_DECL_OVERRIDE |
70 | { | 70 | { |
71 | if (type == Preprocessor::Modification) { | 71 | if (type == Preprocessor::Modification) { |
72 | using namespace Sink::ApplicationDomain; | 72 | using namespace Sink::ApplicationDomain; |