diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-01-18 10:51:34 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-01-18 10:51:34 +0100 |
commit | 47b4442c585a25b2e4b857f2d9e3ab371d942c19 (patch) | |
tree | 4167c6cb75e3ee8072452585f1b433fb637e3389 /synchronizer | |
parent | aef2ebc45a30d3c3b15b630648e8b37a551ce1ef (diff) | |
download | sink-47b4442c585a25b2e4b857f2d9e3ab371d942c19.tar.gz sink-47b4442c585a25b2e4b857f2d9e3ab371d942c19.zip |
Use jobs to track progress of write commands.
Diffstat (limited to 'synchronizer')
-rw-r--r-- | synchronizer/listener.cpp | 5 |
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) { |