diff options
Diffstat (limited to 'dummyresource')
-rw-r--r-- | dummyresource/domainadaptor.cpp | 14 | ||||
-rw-r--r-- | dummyresource/resourcefactory.cpp | 7 |
2 files changed, 11 insertions, 10 deletions
diff --git a/dummyresource/domainadaptor.cpp b/dummyresource/domainadaptor.cpp index d902052..2182f9a 100644 --- a/dummyresource/domainadaptor.cpp +++ b/dummyresource/domainadaptor.cpp | |||
@@ -100,13 +100,13 @@ QSharedPointer<Akonadi2::Domain::BufferAdaptor> DummyEventAdaptorFactory::create | |||
100 | } | 100 | } |
101 | } | 101 | } |
102 | 102 | ||
103 | Akonadi2::Metadata const *metadataBuffer = 0; | 103 | // Akonadi2::Metadata const *metadataBuffer = 0; |
104 | if (auto metadataData = entity.metadata()) { | 104 | // if (auto metadataData = entity.metadata()) { |
105 | flatbuffers::Verifier verifyer(metadataData->Data(), metadataData->size()); | 105 | // flatbuffers::Verifier verifyer(metadataData->Data(), metadataData->size()); |
106 | if (Akonadi2::VerifyMetadataBuffer(verifyer)) { | 106 | // if (Akonadi2::VerifyMetadataBuffer(verifyer)) { |
107 | metadataBuffer = Akonadi2::GetMetadata(metadataData->Data()); | 107 | // metadataBuffer = Akonadi2::GetMetadata(metadataData->Data()); |
108 | } | 108 | // } |
109 | } | 109 | // } |
110 | 110 | ||
111 | Akonadi2::Domain::Buffer::Event const *localBuffer = 0; | 111 | Akonadi2::Domain::Buffer::Event const *localBuffer = 0; |
112 | if (auto localData = entity.local()) { | 112 | if (auto localData = entity.local()) { |
diff --git a/dummyresource/resourcefactory.cpp b/dummyresource/resourcefactory.cpp index 10c8eaf..9d702a8 100644 --- a/dummyresource/resourcefactory.cpp +++ b/dummyresource/resourcefactory.cpp | |||
@@ -170,7 +170,7 @@ private slots: | |||
170 | 170 | ||
171 | flatbuffers::Verifier verifyer(reinterpret_cast<const uint8_t *>(ptr), size); | 171 | flatbuffers::Verifier verifyer(reinterpret_cast<const uint8_t *>(ptr), size); |
172 | if (!Akonadi2::VerifyQueuedCommandBuffer(verifyer)) { | 172 | if (!Akonadi2::VerifyQueuedCommandBuffer(verifyer)) { |
173 | qWarning() << "invalid buffer"; | 173 | Warning() << "invalid buffer"; |
174 | callback(false); | 174 | callback(false); |
175 | return; | 175 | return; |
176 | } | 176 | } |
@@ -185,13 +185,13 @@ private slots: | |||
185 | callback(true); | 185 | callback(true); |
186 | }, | 186 | }, |
187 | [callback](int errorCode, QString errorMessage) { | 187 | [callback](int errorCode, QString errorMessage) { |
188 | Warning() << errorMessage; | 188 | Warning() << "Error while processing queue command: " << errorMessage; |
189 | callback(false); | 189 | callback(false); |
190 | } | 190 | } |
191 | ).exec(); | 191 | ).exec(); |
192 | }, | 192 | }, |
193 | [&future](const MessageQueue::Error &error) { | 193 | [&future](const MessageQueue::Error &error) { |
194 | Warning() << error.message; | 194 | Warning() << "Error while getting message from messagequeue: " << error.message; |
195 | future.setValue(false); | 195 | future.setValue(false); |
196 | future.setFinished(); | 196 | future.setFinished(); |
197 | } | 197 | } |
@@ -209,6 +209,7 @@ private slots: | |||
209 | [it, this](Async::Future<void> &future) { | 209 | [it, this](Async::Future<void> &future) { |
210 | auto queue = it->next(); | 210 | auto queue = it->next(); |
211 | processQueue(queue).then<void>([&future]() { | 211 | processQueue(queue).then<void>([&future]() { |
212 | Trace() << "Queue processed"; | ||
212 | future.setFinished(); | 213 | future.setFinished(); |
213 | }).exec(); | 214 | }).exec(); |
214 | } | 215 | } |