diff options
Diffstat (limited to 'common/store.cpp')
-rw-r--r-- | common/store.cpp | 4 |
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(); |