diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-24 09:57:34 +0100 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-24 09:57:34 +0100 |
| commit | 64d7d7bdd1edb2bcc305ca007784d0708cf7ef3c (patch) | |
| tree | 37069947a889fd5209e2d1e0686c2783c0062f2e /common/pipeline.cpp | |
| parent | 3d35192a7cb2f0321ef54eb721ec21c40758e774 (diff) | |
| download | sink-64d7d7bdd1edb2bcc305ca007784d0708cf7ef3c.tar.gz sink-64d7d7bdd1edb2bcc305ca007784d0708cf7ef3c.zip | |
Deal with not using the implicit internal transaction.
Diffstat (limited to 'common/pipeline.cpp')
| -rw-r--r-- | common/pipeline.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp index d3668bc..1eea631 100644 --- a/common/pipeline.cpp +++ b/common/pipeline.cpp | |||
| @@ -287,7 +287,9 @@ KAsync::Job<qint64> Pipeline::deletedEntity(void const *command, size_t size) | |||
| 287 | 287 | ||
| 288 | void Pipeline::cleanupRevisions(qint64 revision) | 288 | void Pipeline::cleanupRevisions(qint64 revision) |
| 289 | { | 289 | { |
| 290 | d->entityStore.cleanupRevisions(revision); | 290 | //We have to set revisionChanged, otherwise a call to commit might abort |
| 291 | //the transaction when not using the implicit internal transaction | ||
| 292 | d->revisionChanged = d->entityStore.cleanupRevisions(revision); | ||
| 291 | } | 293 | } |
| 292 | 294 | ||
| 293 | 295 | ||