diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-02-08 21:34:06 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-02-08 21:34:06 +0100 |
commit | 44744e281a56488c7ef257e12ca379ec4ceb2cdd (patch) | |
tree | 5fd45d6c6cf5e68ba2323fac3f498c6afa6f2ddf /common/genericresource.cpp | |
parent | d82f0f6e52b601c3067ca70183458f5ce9b22c22 (diff) | |
download | sink-44744e281a56488c7ef257e12ca379ec4ceb2cdd.tar.gz sink-44744e281a56488c7ef257e12ca379ec4ceb2cdd.zip |
Executed database removal in the resource instead of the client.
The resource doesn't really notify all clients properly about the
removal, but the tests all still pass.
Diffstat (limited to 'common/genericresource.cpp')
-rw-r--r-- | common/genericresource.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/common/genericresource.cpp b/common/genericresource.cpp index 6087896..c097893 100644 --- a/common/genericresource.cpp +++ b/common/genericresource.cpp | |||
@@ -396,12 +396,18 @@ KAsync::Job<void> GenericResource::replay(Sink::Storage &synchronizationStore, c | |||
396 | return KAsync::null<void>(); | 396 | return KAsync::null<void>(); |
397 | } | 397 | } |
398 | 398 | ||
399 | void GenericResource::removeDataFromDisk() | ||
400 | { | ||
401 | removeFromDisk(mResourceInstanceIdentifier); | ||
402 | } | ||
403 | |||
399 | void GenericResource::removeFromDisk(const QByteArray &instanceIdentifier) | 404 | void GenericResource::removeFromDisk(const QByteArray &instanceIdentifier) |
400 | { | 405 | { |
401 | Sink::Storage(Sink::storageLocation(), instanceIdentifier, Sink::Storage::ReadWrite).removeFromDisk(); | 406 | Sink::Storage(Sink::storageLocation(), instanceIdentifier, Sink::Storage::ReadWrite).removeFromDisk(); |
402 | Sink::Storage(Sink::storageLocation(), instanceIdentifier + ".userqueue", Sink::Storage::ReadWrite).removeFromDisk(); | 407 | Sink::Storage(Sink::storageLocation(), instanceIdentifier + ".userqueue", Sink::Storage::ReadWrite).removeFromDisk(); |
403 | Sink::Storage(Sink::storageLocation(), instanceIdentifier + ".synchronizerqueue", Sink::Storage::ReadWrite).removeFromDisk(); | 408 | Sink::Storage(Sink::storageLocation(), instanceIdentifier + ".synchronizerqueue", Sink::Storage::ReadWrite).removeFromDisk(); |
404 | Sink::Storage(Sink::storageLocation(), instanceIdentifier + ".changereplay", Sink::Storage::ReadWrite).removeFromDisk(); | 409 | Sink::Storage(Sink::storageLocation(), instanceIdentifier + ".changereplay", Sink::Storage::ReadWrite).removeFromDisk(); |
410 | Sink::Storage(Sink::storageLocation(), instanceIdentifier + ".synchronization", Sink::Storage::ReadWrite).removeFromDisk(); | ||
405 | } | 411 | } |
406 | 412 | ||
407 | qint64 GenericResource::diskUsage(const QByteArray &instanceIdentifier) | 413 | qint64 GenericResource::diskUsage(const QByteArray &instanceIdentifier) |