diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-10-28 16:46:10 +0100 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-10-28 16:46:10 +0100 |
| commit | 81859328bf30c2aeecdf3ee48e5939e0496552fd (patch) | |
| tree | 7df79566e26c8ec3f8d6380076d0edbf0b9cfd60 | |
| parent | 129333371d28c06d85f75ca579ce17798e615e84 (diff) | |
| download | sink-81859328bf30c2aeecdf3ee48e5939e0496552fd.tar.gz sink-81859328bf30c2aeecdf3ee48e5939e0496552fd.zip | |
Reuse the existing transaction
| -rw-r--r-- | common/pipeline.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/pipeline.cpp b/common/pipeline.cpp index de63288..ae4cc3d 100644 --- a/common/pipeline.cpp +++ b/common/pipeline.cpp | |||
| @@ -233,7 +233,7 @@ KAsync::Job<qint64> Pipeline::modifiedEntity(void const *command, size_t size) | |||
| 233 | auto diff = adaptorFactory->createAdaptor(*diffEntity); | 233 | auto diff = adaptorFactory->createAdaptor(*diffEntity); |
| 234 | 234 | ||
| 235 | QSharedPointer<Akonadi2::ApplicationDomain::BufferAdaptor> current; | 235 | QSharedPointer<Akonadi2::ApplicationDomain::BufferAdaptor> current; |
| 236 | storage().createTransaction(Akonadi2::Storage::ReadOnly).openDatabase(bufferType + ".main").scan(Akonadi2::Storage::assembleKey(key, baseRevision), [¤t, adaptorFactory](const QByteArray &key, const QByteArray &data) -> bool { | 236 | d->transaction.openDatabase(bufferType + ".main").scan(Akonadi2::Storage::assembleKey(key, baseRevision), [¤t, adaptorFactory](const QByteArray &key, const QByteArray &data) -> bool { |
| 237 | Akonadi2::EntityBuffer buffer(const_cast<const char *>(data.data()), data.size()); | 237 | Akonadi2::EntityBuffer buffer(const_cast<const char *>(data.data()), data.size()); |
| 238 | if (!buffer.isValid()) { | 238 | if (!buffer.isValid()) { |
| 239 | Warning() << "Read invalid buffer from disk"; | 239 | Warning() << "Read invalid buffer from disk"; |