summaryrefslogtreecommitdiffstats
path: root/tests/pipelinetest.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-22 14:27:37 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-22 14:27:37 +0100
commitc799105ca6b4107fa19de9845247f1f3322ea6ef (patch)
tree9a9da831861b5094936f8b62431fb5e20ce759f5 /tests/pipelinetest.cpp
parentc6af4d6ed59235d8fec52aeddfcd9a65607139ff (diff)
downloadsink-c799105ca6b4107fa19de9845247f1f3322ea6ef.tar.gz
sink-c799105ca6b4107fa19de9845247f1f3322ea6ef.zip
Ensure we always process the full queue and that flushing works.
Diffstat (limited to 'tests/pipelinetest.cpp')
-rw-r--r--tests/pipelinetest.cpp4
1 files changed, 0 insertions, 4 deletions
diff --git a/tests/pipelinetest.cpp b/tests/pipelinetest.cpp
index 5c294bb..e68aa53 100644
--- a/tests/pipelinetest.cpp
+++ b/tests/pipelinetest.cpp
@@ -271,9 +271,7 @@ private slots:
271 QCOMPARE(getKeys(instanceIdentifier(), "event.main").size(), 2); 271 QCOMPARE(getKeys(instanceIdentifier(), "event.main").size(), 2);
272 272
273 // Cleanup old revisions 273 // Cleanup old revisions
274 pipeline.startTransaction();
275 pipeline.cleanupRevisions(2); 274 pipeline.cleanupRevisions(2);
276 pipeline.commit();
277 275
278 // And now only the latest revision is left 276 // And now only the latest revision is left
279 QCOMPARE(getKeys(instanceIdentifier(), "event.main").size(), 1); 277 QCOMPARE(getKeys(instanceIdentifier(), "event.main").size(), 1);
@@ -349,9 +347,7 @@ private slots:
349 QCOMPARE(getKeys(instanceIdentifier(), "event.main").size(), 2); 347 QCOMPARE(getKeys(instanceIdentifier(), "event.main").size(), 2);
350 348
351 // Cleanup old revisions 349 // Cleanup old revisions
352 pipeline.startTransaction();
353 pipeline.cleanupRevisions(2); 350 pipeline.cleanupRevisions(2);
354 pipeline.commit();
355 351
356 // And all revisions are gone 352 // And all revisions are gone
357 QCOMPARE(getKeys(instanceIdentifier(), "event.main").size(), 0); 353 QCOMPARE(getKeys(instanceIdentifier(), "event.main").size(), 0);