diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-07-11 11:55:29 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-07-11 11:55:29 +0200 |
commit | 3a3118e768e1447dc7524328e84b8d7faef81fe1 (patch) | |
tree | af5582170ed6164fffc9365f34b17bf449c0db40 /tests/messagequeuetest.cpp | |
parent | f9379318d801df204cc50385c5eca1f28e91755e (diff) | |
parent | ce2fd2666f084eebe443598f6f3740a02913091e (diff) | |
download | sink-3a3118e768e1447dc7524328e84b8d7faef81fe1.tar.gz sink-3a3118e768e1447dc7524328e84b8d7faef81fe1.zip |
Merge branch 'feature/notifications' into develop
Diffstat (limited to 'tests/messagequeuetest.cpp')
-rw-r--r-- | tests/messagequeuetest.cpp | 29 |
1 files changed, 16 insertions, 13 deletions
diff --git a/tests/messagequeuetest.cpp b/tests/messagequeuetest.cpp index 484ff86..e79bba2 100644 --- a/tests/messagequeuetest.cpp +++ b/tests/messagequeuetest.cpp | |||
@@ -7,6 +7,9 @@ | |||
7 | #include "storage.h" | 7 | #include "storage.h" |
8 | #include "messagequeue.h" | 8 | #include "messagequeue.h" |
9 | #include "log.h" | 9 | #include "log.h" |
10 | #include "test.h" | ||
11 | |||
12 | SINK_DEBUG_AREA("messagequeuetest") | ||
10 | 13 | ||
11 | /** | 14 | /** |
12 | * Test of the messagequeue implementation. | 15 | * Test of the messagequeue implementation. |
@@ -17,8 +20,8 @@ class MessageQueueTest : public QObject | |||
17 | private slots: | 20 | private slots: |
18 | void initTestCase() | 21 | void initTestCase() |
19 | { | 22 | { |
20 | Sink::Log::setDebugOutputLevel(Sink::Log::Trace); | 23 | Sink::Test::initTest(); |
21 | Sink::Storage store(Sink::Store::storageLocation(), "org.kde.dummy.testqueue", Sink::Storage::ReadWrite); | 24 | Sink::Storage store(Sink::Store::storageLocation(), "sink.dummy.testqueue", Sink::Storage::ReadWrite); |
22 | store.removeFromDisk(); | 25 | store.removeFromDisk(); |
23 | } | 26 | } |
24 | 27 | ||
@@ -28,13 +31,13 @@ private slots: | |||
28 | 31 | ||
29 | void cleanup() | 32 | void cleanup() |
30 | { | 33 | { |
31 | Sink::Storage store(Sink::Store::storageLocation(), "org.kde.dummy.testqueue", Sink::Storage::ReadWrite); | 34 | Sink::Storage store(Sink::Store::storageLocation(), "sink.dummy.testqueue", Sink::Storage::ReadWrite); |
32 | store.removeFromDisk(); | 35 | store.removeFromDisk(); |
33 | } | 36 | } |
34 | 37 | ||
35 | void testEmpty() | 38 | void testEmpty() |
36 | { | 39 | { |
37 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 40 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
38 | QVERIFY(queue.isEmpty()); | 41 | QVERIFY(queue.isEmpty()); |
39 | queue.enqueue("value"); | 42 | queue.enqueue("value"); |
40 | QVERIFY(!queue.isEmpty()); | 43 | QVERIFY(!queue.isEmpty()); |
@@ -42,7 +45,7 @@ private slots: | |||
42 | 45 | ||
43 | void testDequeueEmpty() | 46 | void testDequeueEmpty() |
44 | { | 47 | { |
45 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 48 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
46 | bool gotValue = false; | 49 | bool gotValue = false; |
47 | bool gotError = false; | 50 | bool gotError = false; |
48 | queue.dequeue([&](void *ptr, int size, std::function<void(bool success)> callback) { gotValue = true; }, [&](const MessageQueue::Error &error) { gotError = true; }); | 51 | queue.dequeue([&](void *ptr, int size, std::function<void(bool success)> callback) { gotValue = true; }, [&](const MessageQueue::Error &error) { gotError = true; }); |
@@ -52,7 +55,7 @@ private slots: | |||
52 | 55 | ||
53 | void testEnqueue() | 56 | void testEnqueue() |
54 | { | 57 | { |
55 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 58 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
56 | QSignalSpy spy(&queue, SIGNAL(messageReady())); | 59 | QSignalSpy spy(&queue, SIGNAL(messageReady())); |
57 | queue.enqueue("value1"); | 60 | queue.enqueue("value1"); |
58 | QCOMPARE(spy.size(), 1); | 61 | QCOMPARE(spy.size(), 1); |
@@ -60,7 +63,7 @@ private slots: | |||
60 | 63 | ||
61 | void testDrained() | 64 | void testDrained() |
62 | { | 65 | { |
63 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 66 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
64 | QSignalSpy spy(&queue, SIGNAL(drained())); | 67 | QSignalSpy spy(&queue, SIGNAL(drained())); |
65 | queue.enqueue("value1"); | 68 | queue.enqueue("value1"); |
66 | 69 | ||
@@ -74,13 +77,13 @@ private slots: | |||
74 | values << "value1"; | 77 | values << "value1"; |
75 | values << "value2"; | 78 | values << "value2"; |
76 | 79 | ||
77 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 80 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
78 | for (const QByteArray &value : values) { | 81 | for (const QByteArray &value : values) { |
79 | queue.enqueue(value); | 82 | queue.enqueue(value); |
80 | } | 83 | } |
81 | 84 | ||
82 | while (!queue.isEmpty()) { | 85 | while (!queue.isEmpty()) { |
83 | Log() << "start"; | 86 | SinkLog() << "start"; |
84 | const auto expected = values.dequeue(); | 87 | const auto expected = values.dequeue(); |
85 | bool gotValue = false; | 88 | bool gotValue = false; |
86 | bool gotError = false; | 89 | bool gotError = false; |
@@ -104,7 +107,7 @@ private slots: | |||
104 | values << "value1"; | 107 | values << "value1"; |
105 | values << "value2"; | 108 | values << "value2"; |
106 | 109 | ||
107 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 110 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
108 | for (const QByteArray &value : values) { | 111 | for (const QByteArray &value : values) { |
109 | queue.enqueue(value); | 112 | queue.enqueue(value); |
110 | } | 113 | } |
@@ -142,7 +145,7 @@ private slots: | |||
142 | */ | 145 | */ |
143 | void testNestedEnqueue() | 146 | void testNestedEnqueue() |
144 | { | 147 | { |
145 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 148 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
146 | queue.enqueue("value1"); | 149 | queue.enqueue("value1"); |
147 | 150 | ||
148 | bool gotError = false; | 151 | bool gotError = false; |
@@ -157,7 +160,7 @@ private slots: | |||
157 | 160 | ||
158 | void testBatchDequeue() | 161 | void testBatchDequeue() |
159 | { | 162 | { |
160 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 163 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
161 | queue.enqueue("value1"); | 164 | queue.enqueue("value1"); |
162 | queue.enqueue("value2"); | 165 | queue.enqueue("value2"); |
163 | queue.enqueue("value3"); | 166 | queue.enqueue("value3"); |
@@ -178,7 +181,7 @@ private slots: | |||
178 | 181 | ||
179 | void testBatchEnqueue() | 182 | void testBatchEnqueue() |
180 | { | 183 | { |
181 | MessageQueue queue(Sink::Store::storageLocation(), "org.kde.dummy.testqueue"); | 184 | MessageQueue queue(Sink::Store::storageLocation(), "sink.dummy.testqueue"); |
182 | QSignalSpy spy(&queue, SIGNAL(messageReady())); | 185 | QSignalSpy spy(&queue, SIGNAL(messageReady())); |
183 | queue.startTransaction(); | 186 | queue.startTransaction(); |
184 | queue.enqueue("value1"); | 187 | queue.enqueue("value1"); |