diff options
Diffstat (limited to 'common')
-rw-r--r-- | common/genericresource.cpp | 11 | ||||
-rw-r--r-- | common/genericresource.h | 1 |
2 files changed, 5 insertions, 7 deletions
diff --git a/common/genericresource.cpp b/common/genericresource.cpp index 4250a02..5e6764a 100644 --- a/common/genericresource.cpp +++ b/common/genericresource.cpp | |||
@@ -327,12 +327,11 @@ int GenericResource::error() const | |||
327 | 327 | ||
328 | void GenericResource::enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data) | 328 | void GenericResource::enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data) |
329 | { | 329 | { |
330 | //TODO get rid of m_fbb member variable | 330 | flatbuffers::FlatBufferBuilder fbb; |
331 | m_fbb.Clear(); | 331 | auto commandData = Akonadi2::EntityBuffer::appendAsVector(fbb, data.constData(), data.size()); |
332 | auto commandData = Akonadi2::EntityBuffer::appendAsVector(m_fbb, data.constData(), data.size()); | 332 | auto buffer = Akonadi2::CreateQueuedCommand(fbb, commandId, commandData); |
333 | auto buffer = Akonadi2::CreateQueuedCommand(m_fbb, commandId, commandData); | 333 | Akonadi2::FinishQueuedCommandBuffer(fbb, buffer); |
334 | Akonadi2::FinishQueuedCommandBuffer(m_fbb, buffer); | 334 | mq.enqueue(fbb.GetBufferPointer(), fbb.GetSize()); |
335 | mq.enqueue(m_fbb.GetBufferPointer(), m_fbb.GetSize()); | ||
336 | } | 335 | } |
337 | 336 | ||
338 | void GenericResource::processCommand(int commandId, const QByteArray &data) | 337 | void GenericResource::processCommand(int commandId, const QByteArray &data) |
diff --git a/common/genericresource.h b/common/genericresource.h index 82c8a49..1aa4206 100644 --- a/common/genericresource.h +++ b/common/genericresource.h | |||
@@ -60,7 +60,6 @@ protected: | |||
60 | virtual KAsync::Job<void> replay(const QByteArray &type, const QByteArray &key, const QByteArray &value); | 60 | virtual KAsync::Job<void> replay(const QByteArray &type, const QByteArray &key, const QByteArray &value); |
61 | void onProcessorError(int errorCode, const QString &errorMessage); | 61 | void onProcessorError(int errorCode, const QString &errorMessage); |
62 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); | 62 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); |
63 | flatbuffers::FlatBufferBuilder m_fbb; | ||
64 | MessageQueue mUserQueue; | 63 | MessageQueue mUserQueue; |
65 | MessageQueue mSynchronizerQueue; | 64 | MessageQueue mSynchronizerQueue; |
66 | QByteArray mResourceInstanceIdentifier; | 65 | QByteArray mResourceInstanceIdentifier; |