summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2017-04-12 15:05:25 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2017-04-12 15:05:25 +0200
commita648c97bbc9470c29cfc9700fc30a083c7752ffc (patch)
treebfa244c90a38eacfec4ec6e15e189fa2c0b9f8a6
parent465427226f4c0050abb8d19b1c0413670d5d589a (diff)
downloadsink-a648c97bbc9470c29cfc9700fc30a083c7752ffc.tar.gz
sink-a648c97bbc9470c29cfc9700fc30a083c7752ffc.zip
cleanup
-rw-r--r--common/pipeline.cpp10
-rw-r--r--common/pipeline.h2
-rw-r--r--examples/mailtransportresource/mailtransportresource.cpp2
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
415Preprocessor::Result Preprocessor::processModification(Type type, const ApplicationDomain::ApplicationDomainType &current, ApplicationDomain::ApplicationDomainType &diff) 415Preprocessor::Result Preprocessor::process(Type type, const ApplicationDomain::ApplicationDomainType &current, 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 &current, ApplicationDomain::ApplicationDomainType &diff); 101 virtual Result process(Type type, const ApplicationDomain::ApplicationDomainType &current, 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 &current, ApplicationDomain::ApplicationDomainType &diff) Q_DECL_OVERRIDE 69 virtual Result process(Type type, const ApplicationDomain::ApplicationDomainType &current, 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;