summaryrefslogtreecommitdiffstats
path: root/tests/messagequeuetest.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-01-20 19:07:07 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-01-20 19:07:07 +0100
commitbdb01c2c068df326f5a8328ed1492ab1bea388c5 (patch)
tree25c2ee1b29bc481b6914c244ed9ca194b1415d16 /tests/messagequeuetest.cpp
parent17e7ee40c9185c0505883853345fd6024c675b1a (diff)
downloadsink-bdb01c2c068df326f5a8328ed1492ab1bea388c5.tar.gz
sink-bdb01c2c068df326f5a8328ed1492ab1bea388c5.zip
Renamed Akonadi2 to Sink
(except for documentation).
Diffstat (limited to 'tests/messagequeuetest.cpp')
-rw-r--r--tests/messagequeuetest.cpp24
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
17private Q_SLOTS: 17private 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");