diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-10-28 16:39:16 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-10-28 16:39:16 +0100 |
commit | 129333371d28c06d85f75ca579ce17798e615e84 (patch) | |
tree | 2ae01db9d26f6f72a74fa77e6937e03304e81a2c /tests/genericresourcetest.cpp | |
parent | 20f049b65c4bd8c3d0c16bbf398641675648a93f (diff) | |
download | sink-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.cpp | 4 |
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 | ||