summaryrefslogtreecommitdiffstats
path: root/synchronizer
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-01-18 10:51:34 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-01-18 10:51:34 +0100
commit47b4442c585a25b2e4b857f2d9e3ab371d942c19 (patch)
tree4167c6cb75e3ee8072452585f1b433fb637e3389 /synchronizer
parentaef2ebc45a30d3c3b15b630648e8b37a551ce1ef (diff)
downloadsink-47b4442c585a25b2e4b857f2d9e3ab371d942c19.tar.gz
sink-47b4442c585a25b2e4b857f2d9e3ab371d942c19.zip
Use jobs to track progress of write commands.
Diffstat (limited to 'synchronizer')
-rw-r--r--synchronizer/listener.cpp5
1 files changed, 4 insertions, 1 deletions
diff --git a/synchronizer/listener.cpp b/synchronizer/listener.cpp
index dc0d9dd..a84623d 100644
--- a/synchronizer/listener.cpp
+++ b/synchronizer/listener.cpp
@@ -209,7 +209,10 @@ void Listener::processCommand(int commandId, uint messageId, Client &client, uin
209 case Akonadi2::Commands::ModifyEntityCommand: 209 case Akonadi2::Commands::ModifyEntityCommand:
210 case Akonadi2::Commands::CreateEntityCommand: 210 case Akonadi2::Commands::CreateEntityCommand:
211 log(QString("\tCommand id %1 of type %2 from %3").arg(messageId).arg(commandId).arg(client.name)); 211 log(QString("\tCommand id %1 of type %2 from %3").arg(messageId).arg(commandId).arg(client.name));
212 m_resource->processCommand(commandId, client.commandBuffer, size, m_pipeline); 212 loadResource();
213 if (m_resource) {
214 m_resource->processCommand(commandId, client.commandBuffer, size, m_pipeline);
215 }
213 break; 216 break;
214 default: 217 default:
215 if (commandId > Akonadi2::Commands::CustomCommand) { 218 if (commandId > Akonadi2::Commands::CustomCommand) {