Ported the pipeline to the entitystore

1 files changed, 1 insertions, 29 deletions

diff --git a/tests/pipelinebenchmark.cpp b/tests/pipelinebenchmark.cpp
index 16806c7..2e614ef 100644
--- a/tests/pipelinebenchmark.cpp
+++ b/tests/pipelinebenchmark.cpp
@@ -32,7 +32,6 @@
 #include <common/store.h>
 #include <common/pipeline.h>
 #include <common/index.h>
-#include <common/indexupdater.h>
 #include <common/adaptorfactoryregistry.h>
 
 #include "hawd/dataset.h"
@@ -45,27 +44,6 @@
 #include "createentity_generated.h"
 #include "getrssusage.h"
 
-// class IndexUpdater : public Sink::Preprocessor {
-// public:
-//     void newEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &newEntity, Sink::Storage::DataStore::Transaction &transaction) Q_DECL_OVERRIDE
-//     {
-//         for (int i = 0; i < 10; i++) {
-//             Index ridIndex(QString("index.index%1").arg(i).toLatin1(), transaction);
-//             ridIndex.add("foo", uid);
-//         }
-//     }
-//
-//     void modifiedEntity(const QByteArray &key, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &oldEntity, const Sink::ApplicationDomain::BufferAdaptor &newEntity,
-//     Sink::Storage::DataStore::Transaction &transaction) Q_DECL_OVERRIDE
-//     {
-//     }
-//
-//     void deletedEntity(const QByteArray &key, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &oldEntity, Sink::Storage::DataStore::Transaction &transaction) Q_DECL_OVERRIDE
-//     {
-//     }
-// };
-//
-
 /**
  * Benchmark pipeline processing speed.
  *
@@ -133,15 +111,9 @@ private slots:
         resourceIdentifier = "sink.test.instance1";
     }
 
-    void testWithoutIndex()
-    {
-        populateDatabase(10000, QVector<Sink::Preprocessor *>());
-    }
-
     void testWithIndex()
     {
-        auto indexer = QSharedPointer<DefaultIndexUpdater<Sink::ApplicationDomain::Mail>>::create();
-        populateDatabase(10000, QVector<Sink::Preprocessor *>() << indexer.data());
+        populateDatabase(10000, QVector<Sink::Preprocessor *>());
     }
 };