diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-01-20 19:07:07 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-01-20 19:07:07 +0100 |
commit | bdb01c2c068df326f5a8328ed1492ab1bea388c5 (patch) | |
tree | 25c2ee1b29bc481b6914c244ed9ca194b1415d16 /tests/messagequeuetest.cpp | |
parent | 17e7ee40c9185c0505883853345fd6024c675b1a (diff) | |
download | sink-bdb01c2c068df326f5a8328ed1492ab1bea388c5.tar.gz sink-bdb01c2c068df326f5a8328ed1492ab1bea388c5.zip |
Renamed Akonadi2 to Sink
(except for documentation).
Diffstat (limited to 'tests/messagequeuetest.cpp')
-rw-r--r-- | tests/messagequeuetest.cpp | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/tests/messagequeuetest.cpp b/tests/messagequeuetest.cpp index 7d406ed..c835b53 100644 --- a/tests/messagequeuetest.cpp +++ b/tests/messagequeuetest.cpp | |||
@@ -17,8 +17,8 @@ class MessageQueueTest : public QObject | |||
17 | private Q_SLOTS: | 17 | private Q_SLOTS: |
18 | void initTestCase() | 18 | void initTestCase() |
19 | { | 19 | { |
20 | Akonadi2::Log::setDebugOutputLevel(Akonadi2::Log::Trace); | 20 | Sink::Log::setDebugOutputLevel(Sink::Log::Trace); |
21 | Akonadi2::Storage store(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue", Akonadi2::Storage::ReadWrite); | 21 | Sink::Storage store(Sink::Store::storageLocation(), "org.kde.dummy.testqueue", Sink::Storage::ReadWrite); |
22 | store.removeFromDisk(); | 22 | store.removeFromDisk(); |
23 | } | 23 | } |
24 | 24 | ||
@@ -28,13 +28,13 @@ private Q_SLOTS: | |||
28 | 28 | ||
29 | void cleanup() | 29 | void cleanup() |
30 | { | 30 | { |
31 | Akonadi2::Storage store(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue", Akonadi2::Storage::ReadWrite); | 31 | Sink::Storage store(Sink::Store::storageLocation(), "org.kde.dummy.testqueue", Sink::Storage::ReadWrite); |
32 | store.removeFromDisk(); | 32 | store.removeFromDisk(); |
33 | } | 33 | } |
34 | 34 | ||
35 | void testEmpty() | 35 | void testEmpty() |
36 | { | 36 | { |
37 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 37 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
38 | QVERIFY(queue.isEmpty()); | 38 | QVERIFY(queue.isEmpty()); |
39 | queue.enqueue("value"); | 39 | queue.enqueue("value"); |
40 | QVERIFY(!queue.isEmpty()); | 40 | QVERIFY(!queue.isEmpty()); |
@@ -42,7 +42,7 @@ private Q_SLOTS: | |||
42 | 42 | ||
43 | void testDequeueEmpty() | 43 | void testDequeueEmpty() |
44 | { | 44 | { |
45 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 45 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
46 | bool gotValue = false; | 46 | bool gotValue = false; |
47 | bool gotError = false; | 47 | bool gotError = false; |
48 | queue.dequeue([&](void *ptr, int size, std::function<void(bool success)> callback) { | 48 | queue.dequeue([&](void *ptr, int size, std::function<void(bool success)> callback) { |
@@ -57,7 +57,7 @@ private Q_SLOTS: | |||
57 | 57 | ||
58 | void testEnqueue() | 58 | void testEnqueue() |
59 | { | 59 | { |
60 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 60 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
61 | QSignalSpy spy(&queue, SIGNAL(messageReady())); | 61 | QSignalSpy spy(&queue, SIGNAL(messageReady())); |
62 | queue.enqueue("value1"); | 62 | queue.enqueue("value1"); |
63 | QCOMPARE(spy.size(), 1); | 63 | QCOMPARE(spy.size(), 1); |
@@ -65,7 +65,7 @@ private Q_SLOTS: | |||
65 | 65 | ||
66 | void testDrained() | 66 | void testDrained() |
67 | { | 67 | { |
68 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 68 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
69 | QSignalSpy spy(&queue, SIGNAL(drained())); | 69 | QSignalSpy spy(&queue, SIGNAL(drained())); |
70 | queue.enqueue("value1"); | 70 | queue.enqueue("value1"); |
71 | 71 | ||
@@ -81,7 +81,7 @@ private Q_SLOTS: | |||
81 | values << "value1"; | 81 | values << "value1"; |
82 | values << "value2"; | 82 | values << "value2"; |
83 | 83 | ||
84 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 84 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
85 | for (const QByteArray &value : values) { | 85 | for (const QByteArray &value : values) { |
86 | queue.enqueue(value); | 86 | queue.enqueue(value); |
87 | } | 87 | } |
@@ -112,7 +112,7 @@ private Q_SLOTS: | |||
112 | values << "value1"; | 112 | values << "value1"; |
113 | values << "value2"; | 113 | values << "value2"; |
114 | 114 | ||
115 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 115 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
116 | for (const QByteArray &value : values) { | 116 | for (const QByteArray &value : values) { |
117 | queue.enqueue(value); | 117 | queue.enqueue(value); |
118 | } | 118 | } |
@@ -151,7 +151,7 @@ private Q_SLOTS: | |||
151 | */ | 151 | */ |
152 | void testNestedEnqueue() | 152 | void testNestedEnqueue() |
153 | { | 153 | { |
154 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 154 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
155 | queue.enqueue("value1"); | 155 | queue.enqueue("value1"); |
156 | 156 | ||
157 | bool gotError = false; | 157 | bool gotError = false; |
@@ -167,7 +167,7 @@ private Q_SLOTS: | |||
167 | 167 | ||
168 | void testBatchDequeue() | 168 | void testBatchDequeue() |
169 | { | 169 | { |
170 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 170 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
171 | queue.enqueue("value1"); | 171 | queue.enqueue("value1"); |
172 | queue.enqueue("value2"); | 172 | queue.enqueue("value2"); |
173 | queue.enqueue("value3"); | 173 | queue.enqueue("value3"); |
@@ -188,7 +188,7 @@ private Q_SLOTS: | |||
188 | 188 | ||
189 | void testBatchEnqueue() | 189 | void testBatchEnqueue() |
190 | { | 190 | { |
191 | MessageQueue queue(Akonadi2::Store::storageLocation(), "org.kde.dummy.testqueue"); | 191 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); |
192 | QSignalSpy spy(&queue, SIGNAL(messageReady())); | 192 | QSignalSpy spy(&queue, SIGNAL(messageReady())); |
193 | queue.startTransaction(); | 193 | queue.startTransaction(); |
194 | queue.enqueue("value1"); | 194 | queue.enqueue("value1"); |