summaryrefslogtreecommitdiffstats
path: root/tests/genericresourcetest.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-10-28 16:39:16 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-10-28 16:39:16 +0100
commit129333371d28c06d85f75ca579ce17798e615e84 (patch)
tree2ae01db9d26f6f72a74fa77e6937e03304e81a2c /tests/genericresourcetest.cpp
parent20f049b65c4bd8c3d0c16bbf398641675648a93f (diff)
downloadsink-129333371d28c06d85f75ca579ce17798e615e84.tar.gz
sink-129333371d28c06d85f75ca579ce17798e615e84.zip
Made pipeline preprocessing synchronous.
Instead of having the asynchronous preprocessor concept with different pipelines for new/modify/delete we have a single pipeline with synchronous preprocessors that act upon new/modify/delete. This keeps the code simpler due to lack of asynchronity and keeps the new/modify/delete operations together (which at least for the indexing makes a lot of sense). Not supporting asynchronity is ok because the tasks done in preprocessing are not cpu intensive (if they were we had a problem since they are directly involved in the round-trip time), and the main cost comes from i/o, meaning we don't gain much by doing multithreading. Costly tasks (such as full-text indexing) should rather be implemented as post-processing, since that doesn't increase the round-trip time directly, and eventually consistent is typically good enough for that.
Diffstat (limited to 'tests/genericresourcetest.cpp')
-rw-r--r--tests/genericresourcetest.cpp4
1 files changed, 1 insertions, 3 deletions
diff --git a/tests/genericresourcetest.cpp b/tests/genericresourcetest.cpp
index 6dd4108..141a5f8 100644
--- a/tests/genericresourcetest.cpp
+++ b/tests/genericresourcetest.cpp
@@ -32,9 +32,7 @@ private Q_SLOTS:
32 32
33 void init() 33 void init()
34 { 34 {
35 removeFromDisk("org.kde.test.instance1"); 35 Akonadi2::GenericResource::removeFromDisk("org.kde.test.instance1");
36 removeFromDisk("org.kde.test.instance1.userqueue");
37 removeFromDisk("org.kde.test.instance1.synchronizerqueue");
38 Akonadi2::Log::setDebugOutputLevel(Akonadi2::Log::Trace); 36 Akonadi2::Log::setDebugOutputLevel(Akonadi2::Log::Trace);
39 } 37 }
40 38