diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-22 14:27:37 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-22 14:27:37 +0100 |
commit | c799105ca6b4107fa19de9845247f1f3322ea6ef (patch) | |
tree | 9a9da831861b5094936f8b62431fb5e20ce759f5 /tests | |
parent | c6af4d6ed59235d8fec52aeddfcd9a65607139ff (diff) | |
download | sink-c799105ca6b4107fa19de9845247f1f3322ea6ef.tar.gz sink-c799105ca6b4107fa19de9845247f1f3322ea6ef.zip |
Ensure we always process the full queue and that flushing works.
Diffstat (limited to 'tests')
-rw-r--r-- | tests/pipelinetest.cpp | 4 |
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); |