summaryrefslogtreecommitdiffstats
path: root/common/messagequeue.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-08-16 12:47:22 +0200
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-08-18 18:48:06 +0200
commit239d2fe9fc349497344833a439d202e7ecd262e8 (patch)
treeac81459bbe29a0aa77bd01e1a660b54564e7b6f9 /common/messagequeue.cpp
parent726a49431909dbd8bdc6efdb8a36ddf4214a7328 (diff)
downloadsink-239d2fe9fc349497344833a439d202e7ecd262e8.tar.gz
sink-239d2fe9fc349497344833a439d202e7ecd262e8.zip
Use the QByteArray implementation as main implementation
Diffstat (limited to 'common/messagequeue.cpp')
-rw-r--r--common/messagequeue.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/common/messagequeue.cpp b/common/messagequeue.cpp
index 3b5ca2b..2a046d1 100644
--- a/common/messagequeue.cpp
+++ b/common/messagequeue.cpp
@@ -44,20 +44,20 @@ MessageQueue::MessageQueue(const QString &storageRoot, const QString &name)
44 44
45void MessageQueue::enqueue(void const *msg, size_t size) 45void MessageQueue::enqueue(void const *msg, size_t size)
46{ 46{
47 enqueue(QByteArray::fromRawData(static_cast<const char*>(msg), size));
48}
49
50void MessageQueue::enqueue(const QByteArray &value)
51{
47 auto transaction = std::move(mStorage.createTransaction(Akonadi2::Storage::ReadWrite)); 52 auto transaction = std::move(mStorage.createTransaction(Akonadi2::Storage::ReadWrite));
48 const qint64 revision = Akonadi2::Storage::maxRevision(transaction) + 1; 53 const qint64 revision = Akonadi2::Storage::maxRevision(transaction) + 1;
49 const QByteArray key = QString("%1").arg(revision).toUtf8(); 54 const QByteArray key = QString("%1").arg(revision).toUtf8();
50 transaction.write(key, QByteArray::fromRawData(static_cast<const char*>(msg), size)); 55 transaction.write(key, value);
51 Akonadi2::Storage::setMaxRevision(transaction, revision); 56 Akonadi2::Storage::setMaxRevision(transaction, revision);
52 transaction.commit(); 57 transaction.commit();
53 emit messageReady(); 58 emit messageReady();
54} 59}
55 60
56void MessageQueue::enqueue(const QByteArray &value)
57{
58 enqueue(value.data(), value.size());
59}
60
61void MessageQueue::dequeue(const std::function<void(void *ptr, int size, std::function<void(bool success)>)> &resultHandler, 61void MessageQueue::dequeue(const std::function<void(void *ptr, int size, std::function<void(bool success)>)> &resultHandler,
62 const std::function<void(const Error &error)> &errorHandler) 62 const std::function<void(const Error &error)> &errorHandler)
63{ 63{