diff options
Diffstat (limited to 'examples')
-rw-r--r-- | examples/dummyresource/resourcefactory.cpp | 5 | ||||
-rw-r--r-- | examples/maildirresource/maildirresource.cpp | 6 |
2 files changed, 11 insertions, 0 deletions
diff --git a/examples/dummyresource/resourcefactory.cpp b/examples/dummyresource/resourcefactory.cpp index 36866ec..48858da 100644 --- a/examples/dummyresource/resourcefactory.cpp +++ b/examples/dummyresource/resourcefactory.cpp | |||
@@ -95,12 +95,17 @@ Sink::ApplicationDomain::Folder::Ptr DummyResource::createFolder(const QByteArra | |||
95 | 95 | ||
96 | void DummyResource::synchronize(const QByteArray &bufferType, const QMap<QString, QMap<QString, QVariant> > &data, Sink::Storage::Transaction &transaction, Sink::Storage::Transaction &synchronizationTransaction, DomainTypeAdaptorFactoryInterface &adaptorFactory, std::function<Sink::ApplicationDomain::ApplicationDomainType::Ptr(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &)> createEntity) | 96 | void DummyResource::synchronize(const QByteArray &bufferType, const QMap<QString, QMap<QString, QVariant> > &data, Sink::Storage::Transaction &transaction, Sink::Storage::Transaction &synchronizationTransaction, DomainTypeAdaptorFactoryInterface &adaptorFactory, std::function<Sink::ApplicationDomain::ApplicationDomainType::Ptr(const QByteArray &ridBuffer, const QMap<QString, QVariant> &data, Sink::Storage::Transaction &)> createEntity) |
97 | { | 97 | { |
98 | auto time = QSharedPointer<QTime>::create(); | ||
99 | time->start(); | ||
98 | //TODO find items to remove | 100 | //TODO find items to remove |
101 | int count = 0; | ||
99 | for (auto it = data.constBegin(); it != data.constEnd(); it++) { | 102 | for (auto it = data.constBegin(); it != data.constEnd(); it++) { |
103 | count++; | ||
100 | const auto remoteId = it.key().toUtf8(); | 104 | const auto remoteId = it.key().toUtf8(); |
101 | auto entity = createEntity(remoteId, it.value(), synchronizationTransaction); | 105 | auto entity = createEntity(remoteId, it.value(), synchronizationTransaction); |
102 | createOrModify(transaction, synchronizationTransaction, adaptorFactory, bufferType, remoteId, *entity); | 106 | createOrModify(transaction, synchronizationTransaction, adaptorFactory, bufferType, remoteId, *entity); |
103 | } | 107 | } |
108 | Trace() << "Sync of " << count << " entities of type " << bufferType << " done." << Sink::Log::TraceTime(time->elapsed()); | ||
104 | } | 109 | } |
105 | 110 | ||
106 | KAsync::Job<void> DummyResource::synchronizeWithSource(Sink::Storage &mainStore, Sink::Storage &synchronizationStore) | 111 | KAsync::Job<void> DummyResource::synchronizeWithSource(Sink::Storage &mainStore, Sink::Storage &synchronizationStore) |
diff --git a/examples/maildirresource/maildirresource.cpp b/examples/maildirresource/maildirresource.cpp index d5cc24b..6fd70a0 100644 --- a/examples/maildirresource/maildirresource.cpp +++ b/examples/maildirresource/maildirresource.cpp | |||
@@ -135,6 +135,8 @@ void MaildirResource::synchronizeFolders(Sink::Storage::Transaction &transaction | |||
135 | void MaildirResource::synchronizeMails(Sink::Storage::Transaction &transaction, Sink::Storage::Transaction &synchronizationTransaction, const QString &path) | 135 | void MaildirResource::synchronizeMails(Sink::Storage::Transaction &transaction, Sink::Storage::Transaction &synchronizationTransaction, const QString &path) |
136 | { | 136 | { |
137 | Trace() << "Synchronizing mails" << path; | 137 | Trace() << "Synchronizing mails" << path; |
138 | auto time = QSharedPointer<QTime>::create(); | ||
139 | time->start(); | ||
138 | const QByteArray bufferType = ENTITY_TYPE_MAIL; | 140 | const QByteArray bufferType = ENTITY_TYPE_MAIL; |
139 | 141 | ||
140 | KPIM::Maildir maildir(path, true); | 142 | KPIM::Maildir maildir(path, true); |
@@ -165,7 +167,9 @@ void MaildirResource::synchronizeMails(Sink::Storage::Transaction &transaction, | |||
165 | } | 167 | } |
166 | ); | 168 | ); |
167 | 169 | ||
170 | int count = 0; | ||
168 | while (entryIterator->hasNext()) { | 171 | while (entryIterator->hasNext()) { |
172 | count++; | ||
169 | const QString filePath = QDir::fromNativeSeparators(entryIterator->next()); | 173 | const QString filePath = QDir::fromNativeSeparators(entryIterator->next()); |
170 | const QString fileName = entryIterator->fileName(); | 174 | const QString fileName = entryIterator->fileName(); |
171 | const auto remoteId = filePath.toUtf8(); | 175 | const auto remoteId = filePath.toUtf8(); |
@@ -192,6 +196,8 @@ void MaildirResource::synchronizeMails(Sink::Storage::Transaction &transaction, | |||
192 | 196 | ||
193 | createOrModify(transaction, synchronizationTransaction, *mMailAdaptorFactory, bufferType, remoteId, mail); | 197 | createOrModify(transaction, synchronizationTransaction, *mMailAdaptorFactory, bufferType, remoteId, mail); |
194 | } | 198 | } |
199 | Trace() << "Synchronized " << count << " mails in " << listingPath << Sink::Log::TraceTime(time->elapsed()); | ||
200 | |||
195 | } | 201 | } |
196 | 202 | ||
197 | KAsync::Job<void> MaildirResource::synchronizeWithSource(Sink::Storage &mainStore, Sink::Storage &synchronizationStore) | 203 | KAsync::Job<void> MaildirResource::synchronizeWithSource(Sink::Storage &mainStore, Sink::Storage &synchronizationStore) |