diff options
| author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-10-07 15:40:17 +0200 |
|---|---|---|
| committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-10-07 15:40:17 +0200 |
| commit | f0fa3392133e15d68245d88397d5c43023b84b43 (patch) | |
| tree | 8d690ed8ce2df4aac5cd8263f778ea97c7a52bca /common/messagequeue.cpp | |
| parent | 8499c2d29b082f35ac2eb55f7633e0d4103cefe5 (diff) | |
| download | sink-f0fa3392133e15d68245d88397d5c43023b84b43.tar.gz sink-f0fa3392133e15d68245d88397d5c43023b84b43.zip | |
Detect when we try to operate on transactions that point to a
non-existing env.
...which happens if we remove the env while transactions are open.
Diffstat (limited to 'common/messagequeue.cpp')
| -rw-r--r-- | common/messagequeue.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/common/messagequeue.cpp b/common/messagequeue.cpp index 54aaf8c..e050bcd 100644 --- a/common/messagequeue.cpp +++ b/common/messagequeue.cpp | |||
| @@ -11,6 +11,9 @@ MessageQueue::MessageQueue(const QString &storageRoot, const QString &name) : mS | |||
| 11 | 11 | ||
| 12 | MessageQueue::~MessageQueue() | 12 | MessageQueue::~MessageQueue() |
| 13 | { | 13 | { |
| 14 | if (mWriteTransaction) { | ||
| 15 | mWriteTransaction.abort(); | ||
| 16 | } | ||
| 14 | } | 17 | } |
| 15 | 18 | ||
| 16 | void MessageQueue::enqueue(void const *msg, size_t size) | 19 | void MessageQueue::enqueue(void const *msg, size_t size) |