Wait for the resource shutdown during removeFromDisk

Otherwise we risk failing jobs if they are sent to the old resource.

1 files changed, 15 insertions, 1 deletions

diff --git a/common/store.cpp b/common/store.cpp
index d7b277d..848afae 100644
--- a/common/store.cpp
+++ b/common/store.cpp
@@ -191,7 +191,21 @@ KAsync::Job<void> Store::removeDataFromDisk(const QByteArray &identifier)
     auto resourceAccess = ResourceAccessFactory::instance().getAccess(identifier, ResourceConfig::getResourceType(identifier));
     resourceAccess->open();
     return resourceAccess->sendCommand(Sink::Commands::RemoveFromDiskCommand)
-        .then<void>([resourceAccess, time]() { SinkTrace() << "Remove from disk complete." << Log::TraceTime(time->elapsed()); });
+        .then<void>([resourceAccess](KAsync::Future<void> &future) {
+            if (resourceAccess->isReady()) {
+                //Wait for the resource shutdown
+                QObject::connect(resourceAccess.data(), &ResourceAccess::ready, [&future](bool ready) {
+                    if (!ready) {
+                        future.setFinished();
+                    }
+                });
+            } else {
+                future.setFinished();
+            }
+        })
+        .then<void>([resourceAccess, time]() {
+            SinkTrace() << "Remove from disk complete." << Log::TraceTime(time->elapsed()); 
+        });
 }
 
 KAsync::Job<void> Store::synchronize(const Sink::Query &query)