Got transactions to work.

With an ugly hack, we'll need to solve this in the messagequeue
properly.

1 files changed, 14 insertions, 5 deletions

diff --git a/common/genericresource.cpp b/common/genericresource.cpp
index 943f7d2..e2b0122 100644
--- a/common/genericresource.cpp
+++ b/common/genericresource.cpp
@@ -195,12 +195,13 @@ void GenericResource::processCommand(int commandId, const QByteArray &data)
     mUserQueue.startTransaction();
     enqueueCommand(mUserQueue, commandId, data);
     modifications++;
-    // if (modifications >= 100) {
+    if (modifications >= 100) {
         mUserQueue.commit();
-    //     modifications = 0;
-    // } else {
-    //     mCommitQueueTimer.start();
-    // }
+        modifications = 0;
+        mCommitQueueTimer.stop();
+    } else {
+        mCommitQueueTimer.start();
+    }
 }
 
 static void waitForDrained(KAsync::Future<void> &f, MessageQueue &queue)
@@ -220,6 +221,14 @@ KAsync::Job<void> GenericResource::processAllMessages()
     //TODO: report errors while processing sync?
     //TODO JOBAPI: A helper that waits for n events and then continues?
     return KAsync::start<void>([this](KAsync::Future<void> &f) {
+        if (mCommitQueueTimer.isActive()) {
+            QObject::connect(&mCommitQueueTimer, &QTimer::timeout, [&f]() {
+                f.setFinished();
+            });
+        } else {
+            f.setFinished();
+        }
+    }).then<void>([this](KAsync::Future<void> &f) {
         waitForDrained(f, mSynchronizerQueue);
     }).then<void>([this](KAsync::Future<void> &f) {
         waitForDrained(f, mUserQueue);