diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-08-11 23:51:09 +0200 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-08-11 23:51:09 +0200 |
| commit | 65817a81d040285fb654e865053d87a1c1d33792 (patch) | |
| tree | 572a28b2cf29287af1dfa4f22bc26ecb99d870cb /common/messagequeue.cpp | |
| parent | a5a61963afa3f14fae644c7512597b650c930d91 (diff) | |
| download | sink-65817a81d040285fb654e865053d87a1c1d33792.tar.gz sink-65817a81d040285fb654e865053d87a1c1d33792.zip | |
Messagequeue fixup
Diffstat (limited to 'common/messagequeue.cpp')
| -rw-r--r-- | common/messagequeue.cpp | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/common/messagequeue.cpp b/common/messagequeue.cpp index ecc4d1a..d2e285a 100644 --- a/common/messagequeue.cpp +++ b/common/messagequeue.cpp | |||
| @@ -46,7 +46,6 @@ void MessageQueue::dequeue(const std::function<void(void *ptr, int size, std::fu | |||
| 46 | ErrorMsg() << "Error while removing value" << error.message << keyCopy; | 46 | ErrorMsg() << "Error while removing value" << error.message << keyCopy; |
| 47 | //Don't call the errorhandler in here, we already called the result handler | 47 | //Don't call the errorhandler in here, we already called the result handler |
| 48 | }); | 48 | }); |
| 49 | mTransaction.commit(); | ||
| 50 | if (isEmpty()) { | 49 | if (isEmpty()) { |
| 51 | emit this->drained(); | 50 | emit this->drained(); |
| 52 | } | 51 | } |