diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-10-19 15:28:42 +0200 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-10-21 09:18:49 +0200 |
| commit | ba7c8b890c45d735216888204ec88882ef58c918 (patch) | |
| tree | cb00c9b51e5353ba3726216679c81c0e2fe9ac35 /common/genericresource.cpp | |
| parent | da1c86b80f230c3a2023f97c0048020a12e38de4 (diff) | |
| download | sink-ba7c8b890c45d735216888204ec88882ef58c918.tar.gz sink-ba7c8b890c45d735216888204ec88882ef58c918.zip | |
Ported the pipeline to the entitystore
Diffstat (limited to 'common/genericresource.cpp')
| -rw-r--r-- | common/genericresource.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/common/genericresource.cpp b/common/genericresource.cpp index e0d395a..8f08f3d 100644 --- a/common/genericresource.cpp +++ b/common/genericresource.cpp | |||
| @@ -59,9 +59,9 @@ class CommandProcessor : public QObject | |||
| 59 | public: | 59 | public: |
| 60 | CommandProcessor(Sink::Pipeline *pipeline, QList<MessageQueue *> commandQueues) : QObject(), mPipeline(pipeline), mCommandQueues(commandQueues), mProcessingLock(false) | 60 | CommandProcessor(Sink::Pipeline *pipeline, QList<MessageQueue *> commandQueues) : QObject(), mPipeline(pipeline), mCommandQueues(commandQueues), mProcessingLock(false) |
| 61 | { | 61 | { |
| 62 | mLowerBoundRevision = DataStore::maxRevision(mPipeline->storage().createTransaction(DataStore::ReadOnly, [](const Sink::Storage::DataStore::Error &error) { | 62 | mPipeline->startTransaction(); |
| 63 | SinkWarning() << error.message; | 63 | mLowerBoundRevision = mPipeline->revision(); |
| 64 | })); | 64 | mPipeline->commit(); |
| 65 | 65 | ||
| 66 | for (auto queue : mCommandQueues) { | 66 | for (auto queue : mCommandQueues) { |
| 67 | const bool ret = connect(queue, &MessageQueue::messageReady, this, &CommandProcessor::process); | 67 | const bool ret = connect(queue, &MessageQueue::messageReady, this, &CommandProcessor::process); |