summaryrefslogtreecommitdiffstats
path: root/dummyresource
diff options
context:
space:
mode:
Diffstat (limited to 'dummyresource')
-rw-r--r--dummyresource/domainadaptor.cpp14
-rw-r--r--dummyresource/resourcefactory.cpp7
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 }