summaryrefslogtreecommitdiffstats
path: root/common/store.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'common/store.cpp')
-rw-r--r--common/store.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/common/store.cpp b/common/store.cpp
index 6f080b5..2f88c6d 100644
--- a/common/store.cpp
+++ b/common/store.cpp
@@ -158,7 +158,7 @@ KAsync::Job<void> Store::removeDataFromDisk(const QByteArray &identifier)
158 Trace() << "Remove data from disk " << identifier; 158 Trace() << "Remove data from disk " << identifier;
159 auto time = QSharedPointer<QTime>::create(); 159 auto time = QSharedPointer<QTime>::create();
160 time->start(); 160 time->start();
161 auto resourceAccess = QSharedPointer<Sink::ResourceAccess>::create(identifier); 161 auto resourceAccess = ResourceAccessFactory::instance().getAccess(identifier);
162 resourceAccess->open(); 162 resourceAccess->open();
163 return resourceAccess->sendCommand(Sink::Commands::RemoveFromDiskCommand).then<void>([resourceAccess, time]() { 163 return resourceAccess->sendCommand(Sink::Commands::RemoveFromDiskCommand).then<void>([resourceAccess, time]() {
164 Trace() << "Remove from disk complete." << Log::TraceTime(time->elapsed()); 164 Trace() << "Remove from disk complete." << Log::TraceTime(time->elapsed());
@@ -171,7 +171,7 @@ KAsync::Job<void> Store::synchronize(const Sink::Query &query)
171 return KAsync::iterate(query.resources) 171 return KAsync::iterate(query.resources)
172 .template each<void, QByteArray>([query](const QByteArray &resource, KAsync::Future<void> &future) { 172 .template each<void, QByteArray>([query](const QByteArray &resource, KAsync::Future<void> &future) {
173 Trace() << "Synchronizing " << resource; 173 Trace() << "Synchronizing " << resource;
174 auto resourceAccess = QSharedPointer<Sink::ResourceAccess>::create(resource); 174 auto resourceAccess = ResourceAccessFactory::instance().getAccess(resource);
175 resourceAccess->open(); 175 resourceAccess->open();
176 resourceAccess->synchronizeResource(true, false).then<void>([&future, resourceAccess]() { 176 resourceAccess->synchronizeResource(true, false).then<void>([&future, resourceAccess]() {
177 future.setFinished(); 177 future.setFinished();