Commit 1ab2cce9 authored by Laurent Montel's avatar Laurent Montel 😁
Browse files

run git clang-format

parent 6b598b36
......@@ -11,7 +11,8 @@
#include <AkonadiCore/Item>
#include <QStringList>
namespace Akonadi {
namespace Akonadi
{
class Collection;
}
......
......@@ -9,29 +9,29 @@
#include "agent.h"
#include "contactindexer.h"
#include "emailindexer.h"
#include "akonotesindexer.h"
#include "calendarindexer.h"
#include "indexeradaptor.h"
#include "collectionupdatejob.h"
#include "contactindexer.h"
#include "emailindexer.h"
#include "indexeradaptor.h"
#include "priority.h"
#include <ChangeRecorder>
#include <AkonadiCore/AttributeFactory>
#include <AkonadiCore/CollectionFetchScope>
#include <AkonadiCore/ItemFetchScope>
#include <AkonadiCore/EntityDisplayAttribute>
#include <AkonadiCore/IndexPolicyAttribute>
#include <AkonadiCore/AttributeFactory>
#include <AkonadiCore/ItemFetchScope>
#include <ChangeRecorder>
#include <AgentManager>
#include <ServerManager>
#include "akonadi_indexer_agent_debug.h"
#include <KConfig>
#include <KConfigGroup>
#include <KLocalizedString>
#include "akonadi_indexer_agent_debug.h"
#define INDEXING_AGENT_VERSION 5
......@@ -69,12 +69,10 @@ AkonadiIndexingAgent::AkonadiIndexingAgent(const QString &id)
} else {
setOnline(true);
}
connect(this, &Akonadi::AgentBase::abortRequested,
this, &AkonadiIndexingAgent::onAbortRequested);
connect(this, &Akonadi::AgentBase::onlineChanged,
this, &AkonadiIndexingAgent::onOnlineChanged);
connect(this, &Akonadi::AgentBase::abortRequested, this, &AkonadiIndexingAgent::onAbortRequested);
connect(this, &Akonadi::AgentBase::onlineChanged, this, &AkonadiIndexingAgent::onOnlineChanged);
connect(&m_scheduler, SIGNAL(status(int,QString)), this, SIGNAL(status(int,QString)));
connect(&m_scheduler, SIGNAL(status(int, QString)), this, SIGNAL(status(int, QString)));
connect(&m_scheduler, &Scheduler::percent, this, &Akonadi::AgentBase::percent);
connect(&m_scheduler, &Scheduler::collectionIndexingFinished, this, &AkonadiIndexingAgent::collectionIndexingFinished);
......@@ -197,7 +195,9 @@ void AkonadiIndexingAgent::itemsRemoved(const Akonadi::Item::List &items)
m_index.scheduleCommit();
}
void AkonadiIndexingAgent::itemsMoved(const Akonadi::Item::List &items, const Akonadi::Collection &sourceCollection, const Akonadi::Collection &destinationCollection)
void AkonadiIndexingAgent::itemsMoved(const Akonadi::Item::List &items,
const Akonadi::Collection &sourceCollection,
const Akonadi::Collection &destinationCollection)
{
const bool indexSource = shouldIndex(sourceCollection);
const bool indexDest = shouldIndex(destinationCollection);
......@@ -255,7 +255,7 @@ void AkonadiIndexingAgent::collectionChanged(const Akonadi::Collection &collecti
}
if (changes.contains("ENTITYDISPLAY")) {
//If the name changed we have to reindex all subcollections
// If the name changed we have to reindex all subcollections
auto *job = new CollectionUpdateJob(m_index, collection, this);
job->start();
} else {
......@@ -273,7 +273,9 @@ void AkonadiIndexingAgent::collectionRemoved(const Akonadi::Collection &collecti
m_index.scheduleCommit();
}
void AkonadiIndexingAgent::collectionMoved(const Akonadi::Collection &collection, const Akonadi::Collection &collectionSource, const Akonadi::Collection &collectionDestination)
void AkonadiIndexingAgent::collectionMoved(const Akonadi::Collection &collection,
const Akonadi::Collection &collectionSource,
const Akonadi::Collection &collectionDestination)
{
Q_UNUSED(collectionSource)
Q_UNUSED(collectionDestination)
......@@ -313,7 +315,7 @@ void AkonadiIndexingAgent::onOnlineChanged(bool online)
// Index items that might have changed while we were offline
if (online) {
//We only reindex if this is not a regular start
// We only reindex if this is not a regular start
KConfigGroup cfg = config()->group("General");
bool aborted = cfg.readEntry("aborted", false);
if (!aborted) {
......@@ -337,9 +339,7 @@ void AkonadiIndexingAgent::onOnlineChanged(bool online)
bool AkonadiIndexingAgent::shouldIndex(const Akonadi::Collection &col) const
{
return !col.isVirtual()
&& (!col.hasAttribute<Akonadi::IndexPolicyAttribute>()
|| col.attribute<Akonadi::IndexPolicyAttribute>()->indexingEnabled());
return !col.isVirtual() && (!col.hasAttribute<Akonadi::IndexPolicyAttribute>() || col.attribute<Akonadi::IndexPolicyAttribute>()->indexingEnabled());
}
bool AkonadiIndexingAgent::shouldIndex(const Akonadi::Item &item) const
......
......@@ -13,9 +13,9 @@
#include <agentbase.h>
#include <collection.h>
#include <QList>
#include "scheduler.h"
#include "index.h"
#include "scheduler.h"
#include <QList>
class AkonadiIndexingAgent : public Akonadi::AgentBase, public Akonadi::AgentBase::ObserverV3
{
......@@ -40,7 +40,9 @@ public:
void collectionAdded(const Akonadi::Collection &collection, const Akonadi::Collection &parent) override;
void collectionChanged(const Akonadi::Collection &collection, const QSet<QByteArray> &changedAttributes) override;
void collectionRemoved(const Akonadi::Collection &collection) override;
void collectionMoved(const Akonadi::Collection &collection, const Akonadi::Collection &collectionSource, const Akonadi::Collection &collectionDestination) override;
void collectionMoved(const Akonadi::Collection &collection,
const Akonadi::Collection &collectionSource,
const Akonadi::Collection &collectionDestination) override;
// Remove the entire db
void cleanup() override;
......
......@@ -13,9 +13,9 @@
#include "abstractindexer.h"
#include <KMime/Message>
#include <Collection>
#include <Item>
#include <KMime/Message>
class AkonotesIndexer : public AbstractIndexer
{
......@@ -35,6 +35,7 @@ public:
void remove(const Akonadi::Item &item) override;
void remove(const Akonadi::Collection &collection) override;
void move(Akonadi::Item::Id itemId, Akonadi::Collection::Id from, Akonadi::Collection::Id to) override;
private:
void processPart(KMime::Content *content, KMime::Content *mainContent);
void process(const KMime::Message::Ptr &msg);
......
......@@ -7,17 +7,17 @@
*/
#include <collectionindexingjob.h>
#include <QTest>
#include <AkonadiCore/Collection>
#include <AkonadiCore/ServerManager>
#include <AkonadiCore/CollectionFetchJob>
#include <AkonadiCore/ServerManager>
#include <AkonadiCore/qtest_akonadi.h>
#include <QTest>
class TestIndex : public Index
{
public:
using Index::move; // So we don't trigger -Woverloaded-virtual
using Index::index; // So we don't trigger -Woverloaded-virtual
using Index::move; // So we don't trigger -Woverloaded-virtual
QList<Akonadi::Item::Id> itemsIndexed;
QList<Akonadi::Item::Id> alreadyIndexed;
QList<Akonadi::Item::Id> itemsRemoved;
......@@ -31,9 +31,9 @@ public:
return true;
}
void findIndexed(QSet< Akonadi::Item::Id> &indexed, Akonadi::Collection::Id) override
void findIndexed(QSet<Akonadi::Item::Id> &indexed, Akonadi::Collection::Id) override
{
indexed = QSet< Akonadi::Item::Id>(alreadyIndexed.begin(), alreadyIndexed.end());
indexed = QSet<Akonadi::Item::Id>(alreadyIndexed.begin(), alreadyIndexed.end());
}
void index(const Akonadi::Item &item) override
......
......@@ -6,16 +6,16 @@
*
*/
#include <QTest>
#include <AkonadiCore/Collection>
#include <KContacts/Addressee>
#include <QDir>
#include <QTest>
#include <query.h>
#include <index.h>
#include <../lib/collectionquery.h>
#include <../lib/resultiterator.h>
#include <QDebug>
#include <index.h>
#include <query.h>
Q_DECLARE_METATYPE(QSet<qint64>)
Q_DECLARE_METATYPE(QList<qint64>)
......@@ -32,7 +32,7 @@ private:
QDir dir(dirName);
if (dir.exists(dirName)) {
const QFileInfoList infoDirs = dir.entryInfoList(QDir::NoDotAndDotDot | QDir::System | QDir::Hidden | QDir::AllDirs | QDir::Files, QDir::DirsFirst);
const QFileInfoList infoDirs = dir.entryInfoList(QDir::NoDotAndDotDot | QDir::System | QDir::Hidden | QDir::AllDirs | QDir::Files, QDir::DirsFirst);
for (const QFileInfo &info : infoDirs) {
if (info.isDir()) {
result = removeDir(info.absoluteFilePath());
......@@ -82,7 +82,7 @@ private Q_SLOTS:
Akonadi::Search::PIM::ResultIterator it = query.exec();
QList<qint64> results;
while (it.next()) {
//qDebug() << "result " << it.id();
// qDebug() << "result " << it.id();
results << it.id();
}
QCOMPARE(results.size(), 1);
......@@ -107,7 +107,7 @@ private Q_SLOTS:
Akonadi::Search::PIM::ResultIterator it = query.exec();
QList<qint64> results;
while (it.next()) {
//qDebug() << "result " << it.id();
// qDebug() << "result " << it.id();
results << it.id();
}
std::sort(results.begin(), results.end());
......@@ -122,7 +122,7 @@ private Q_SLOTS:
Akonadi::Search::PIM::ResultIterator it = query.exec();
QList<qint64> results;
while (it.next()) {
//qDebug() << "result " << it.id();
// qDebug() << "result " << it.id();
results << it.id();
}
std::sort(results.begin(), results.end());
......@@ -135,7 +135,7 @@ private Q_SLOTS:
{
QList<qint64> results;
while (it.next()) {
//qDebug() << "result " << it.id();
// qDebug() << "result " << it.id();
results << it.id();
}
return results;
......@@ -164,7 +164,7 @@ private Q_SLOTS:
col3.setParentCollection(col2);
index.change(col3);
//Old name gone
// Old name gone
{
Akonadi::Search::PIM::CollectionQuery query;
query.setDatabaseDir(dbPrefix + QLatin1String("/collections/"));
......@@ -172,7 +172,7 @@ private Q_SLOTS:
QList<qint64> results = getResults(query.exec());
QCOMPARE(results.size(), 0);
}
//New name
// New name
{
Akonadi::Search::PIM::CollectionQuery query;
query.setDatabaseDir(dbPrefix + QLatin1String("/collections/"));
......@@ -181,7 +181,7 @@ private Q_SLOTS:
QCOMPARE(results.size(), 1);
QCOMPARE(results.at(0), col1.id());
}
//Old path gone
// Old path gone
{
Akonadi::Search::PIM::CollectionQuery query;
query.setDatabaseDir(dbPrefix + QLatin1String("/collections/"));
......@@ -189,7 +189,7 @@ private Q_SLOTS:
QList<qint64> results = getResults(query.exec());
QCOMPARE(results.size(), 0);
}
//New paths
// New paths
{
Akonadi::Search::PIM::CollectionQuery query;
query.setDatabaseDir(dbPrefix + QLatin1String("/collections/"));
......
......@@ -6,15 +6,15 @@
*
*/
#include <QTest>
#include <AkonadiCore/Collection>
#include <KContacts/Addressee>
#include <QDir>
#include <QTest>
#include "emailindexer.h"
#include "contactindexer.h"
#include <../search/email/emailsearchstore.h>
#include "emailindexer.h"
#include <../search/contact/contactsearchstore.h>
#include <../search/email/emailsearchstore.h>
#include <query.h>
Q_DECLARE_METATYPE(QSet<qint64>)
......@@ -35,7 +35,7 @@ private:
QDir dir(dirName);
if (dir.exists(dirName)) {
const QFileInfoList infoDirs = dir.entryInfoList(QDir::NoDotAndDotDot | QDir::System | QDir::Hidden | QDir::AllDirs | QDir::Files, QDir::DirsFirst);
const QFileInfoList infoDirs = dir.entryInfoList(QDir::NoDotAndDotDot | QDir::System | QDir::Hidden | QDir::AllDirs | QDir::Files, QDir::DirsFirst);
for (const QFileInfo &info : infoDirs) {
if (info.isDir()) {
result = removeDir(info.absoluteFilePath());
......@@ -75,14 +75,14 @@ private Q_SLOTS:
qDebug() << emailContactsDir;
qDebug() << notesDir;
// EmailIndexer emailIndexer(emailDir, emailContactsDir);
// ContactIndexer contactIndexer(contactsDir);
// EmailIndexer emailIndexer(emailDir, emailContactsDir);
// ContactIndexer contactIndexer(contactsDir);
// Akonadi::Search::EmailSearchStore *emailSearchStore = new Akonadi::Search::EmailSearchStore(this);
// emailSearchStore->setDbPath(emailDir);
// Akonadi::Search::ContactSearchStore *contactSearchStore = new Akonadi::Search::ContactSearchStore(this);
// contactSearchStore->setDbPath(contactsDir);
// Akonadi::Search::SearchStore::overrideSearchStores(QList<Akonadi::Search::SearchStore*>() << emailSearchStore << contactSearchStore);
// Akonadi::Search::EmailSearchStore *emailSearchStore = new Akonadi::Search::EmailSearchStore(this);
// emailSearchStore->setDbPath(emailDir);
// Akonadi::Search::ContactSearchStore *contactSearchStore = new Akonadi::Search::ContactSearchStore(this);
// contactSearchStore->setDbPath(contactsDir);
// Akonadi::Search::SearchStore::overrideSearchStores(QList<Akonadi::Search::SearchStore*>() << emailSearchStore << contactSearchStore);
}
QSet<qint64> getAllItems()
......
......@@ -5,16 +5,16 @@
* SPDX-License-Identifier: LGPL-2.1-only OR LGPL-3.0-only OR LicenseRef-KDE-Accepted-LGPL
*
*/
#include <scheduler.h>
#include <collectionindexingjob.h>
#include <scheduler.h>
#include <QTest>
#include <AkonadiCore/Collection>
#include <AkonadiCore/ServerManager>
#include <AkonadiCore/qtest_akonadi.h>
#include <KConfig>
#include <KConfigGroup>
#include <QStandardPaths>
#include <QTest>
class DummyIndexingJob : public CollectionIndexingJob
{
......@@ -44,7 +44,11 @@ public:
Akonadi::Item::List indexedItems;
QList<bool> fullSyncs;
CollectionIndexingJob *createCollectionIndexingJob(Index &index, const Akonadi::Collection &col, const QList<Akonadi::Item::Id> &pending, bool fullSync, QObject *parent = nullptr) override
CollectionIndexingJob *createCollectionIndexingJob(Index &index,
const Akonadi::Collection &col,
const QList<Akonadi::Item::Id> &pending,
bool fullSync,
QObject *parent = nullptr) override
{
for (qint64 id : pending) {
indexedItems << Akonadi::Item(id);
......@@ -84,7 +88,7 @@ private Q_SLOTS:
Scheduler scheduler(index, config, factory);
QSignalSpy statusSpy(&scheduler, &Scheduler::status);
scheduler.setBusyTimeout(0);
//Wait for ready signal (indicates that indexing is complete)
// Wait for ready signal (indicates that indexing is complete)
QTRY_COMPARE(statusSpy.count(), 1);
QTRY_COMPARE(factory->indexedCollections.size(), 2);
QVERIFY(factory->fullSyncs.at(0));
......@@ -109,14 +113,14 @@ private Q_SLOTS:
Akonadi::Collection col2(4);
scheduler.scheduleCollection(col2, true);
//Wait for ready signal (indicates that indexing is complete)
// Wait for ready signal (indicates that indexing is complete)
QTRY_COMPARE(statusSpy.count(), 1);
QTRY_COMPARE(factory->indexedCollections.size(), 2);
QCOMPARE(factory->indexedCollections.at(0).id(), col1.id());
QVERIFY(!factory->fullSyncs.at(0));
QCOMPARE(factory->indexedCollections.at(1).id(), col2.id());
QVERIFY(factory->fullSyncs.at(1));
//We index 2 collections.
// We index 2 collections.
QCOMPARE(finishedIndexing.count(), 2);
}
......@@ -146,7 +150,7 @@ private Q_SLOTS:
item3.setParentCollection(parent2);
scheduler.addItem(item3);
//Wait for ready signal (indicates that indexing is complete)
// Wait for ready signal (indicates that indexing is complete)
QTRY_COMPARE(statusSpy.count(), 1);
QTRY_COMPARE(factory->indexedCollections.size(), 2);
QCOMPARE(factory->indexedCollections.at(0).id(), parent1.id());
......@@ -168,7 +172,7 @@ private Q_SLOTS:
Index index;
//Populate dirty collections
// Populate dirty collections
{
QSharedPointer<DummyJobFactory> factory(new DummyJobFactory());
Scheduler scheduler(index, config, factory);
......
......@@ -7,8 +7,8 @@
*/
#include "calendarindexer.h"
#include "xapiandocument.h"
#include "akonadi_indexer_agent_debug.h"
#include "xapiandocument.h"
#include <KCalendarCore/Attendee>
......@@ -35,10 +35,8 @@ CalendarIndexer::~CalendarIndexer()
QStringList CalendarIndexer::mimeTypes() const
{
return QStringList() << QStringLiteral("application/x-vnd.akonadi.calendar.event")
<< QStringLiteral("application/x-vnd.akonadi.calendar.todo")
<< QStringLiteral("application/x-vnd.akonadi.calendar.journal")
<< QStringLiteral("application/x-vnd.akonadi.calendar.freebusy");
return QStringList() << QStringLiteral("application/x-vnd.akonadi.calendar.event") << QStringLiteral("application/x-vnd.akonadi.calendar.todo")
<< QStringLiteral("application/x-vnd.akonadi.calendar.journal") << QStringLiteral("application/x-vnd.akonadi.calendar.freebusy");
}
void CalendarIndexer::index(const Akonadi::Item &item)
......@@ -136,8 +134,7 @@ void CalendarIndexer::indexEventItem(const Akonadi::Item &item, const KCalendarC
}
// Parent collection
Q_ASSERT_X(item.parentCollection().isValid(), "Akonadi::Search::CalenderIndexer::index",
"Item does not have a valid parent collection");
Q_ASSERT_X(item.parentCollection().isValid(), "Akonadi::Search::CalenderIndexer::index", "Item does not have a valid parent collection");
const Akonadi::Collection::Id colId = item.parentCollection().id();
doc.addBoolTerm(colId, QStringLiteral("C"));
......@@ -147,20 +144,20 @@ void CalendarIndexer::indexEventItem(const Akonadi::Item &item, const KCalendarC
void CalendarIndexer::indexJournalItem(const Akonadi::Item &item, const KCalendarCore::Journal::Ptr &journal)
{
//TODO
// TODO
Q_UNUSED(item)
Q_UNUSED(journal)
}
void CalendarIndexer::indexTodoItem(const Akonadi::Item &item, const KCalendarCore::Todo::Ptr &todo)
{
//TODO
// TODO
Q_UNUSED(item)
Q_UNUSED(todo)
}
void CalendarIndexer::updateIncidenceItem(const KCalendarCore::Incidence::Ptr &calInc)
{
//TODO
// TODO
Q_UNUSED(calInc)
}
......@@ -14,8 +14,8 @@
#include <AkonadiCore/Collection>
#include <AkonadiCore/Item>
#include <KCalendarCore/Journal>
#include <KCalendarCore/Event>
#include <KCalendarCore/Journal>
#include <KCalendarCore/Todo>
class CalendarIndexer : public AbstractIndexer
......@@ -36,6 +36,7 @@ public:
void remove(const Akonadi::Item &item) override;
void remove(const Akonadi::Collection &collection) override;
void move(Akonadi::Item::Id itemId, Akonadi::Collection::Id from, Akonadi::Collection::Id to) override;
private:
void indexEventItem(const Akonadi::Item &item, const KCalendarCore::Event::Ptr &event);
void indexJournalItem(const Akonadi::Item &item, const KCalendarCore::Journal::Ptr &journal);
......
......@@ -10,9 +10,9 @@
#include "collectionindexer.h"
#include "xapiandocument.h"
#include <QStringList>
#include <AkonadiCore/collectionidentificationattribute.h>
#include <AkonadiCore/AttributeFactory>
#include <AkonadiCore/collectionidentificationattribute.h>
#include <QStringList>
#include "akonadi_indexer_agent_debug.h"
......@@ -54,7 +54,7 @@ void CollectionIndexer::index(const Akonadi::Collection &collection)
if (!m_db) {
return;
}
//qCDebug(AKONADI_INDEXER_AGENT_LOG) << "Indexing " << collection.id() << collection.displayName() << collection.name();
// qCDebug(AKONADI_INDEXER_AGENT_LOG) << "Indexing " << collection.id() << collection.displayName() << collection.name();
try {
Xapian::Document doc;
......@@ -65,7 +65,7 @@ void CollectionIndexer::index(const Akonadi::Collection &collection)
gen.index_text_without_positions(collection.displayName().toStdString());
gen.index_text_without_positions(collection.displayName().toStdString(), 1, "N");
//We index with positions so we can do phrase searches (required for exact matches)
// We index with positions so we can do phrase searches (required for exact matches)
{
const QByteArray path = getPath(collection);
gen.index_text(path.constData(), 1, "P");
......@@ -88,7 +88,7 @@ void CollectionIndexer::index(const Akonadi::Collection &collection)
}
}
{
//We must add the term also with an empty namespace, so we can search for that as well
// We must add the term also with an empty namespace, so we can search for that as well
const QByteArray term = "NS" + ns;
doc.add_boolean_term(term.constData());
}
......@@ -115,14 +115,14 @@ void CollectionIndexer::remove(const Akonadi::Collection &col)
return;
}
//Remove collection
// Remove collection
try {
m_db->delete_document(col.id());
} catch (const Xapian::Error &e) {
qCWarning(AKONADI_INDEXER_AGENT_LOG) << "Xapian error in indexer:" << e.get_msg().c_str();
}
//Remove subcollections
// Remove subcollections
try {
Xapian::Query query('C' + QString::number(col.id()).toStdString());
Xapian::Enquire enquire(*m_db);
......
......@@ -11,7 +11,8 @@
#include <AkonadiCore/collection.h>
#include <QString>
namespace Xapian {
namespace Xapian
{
class WritableDatabase;
}
......
......@@ -5,17 +5,17 @@
*
*/
#include "collectionindexingjob.h"
#include <akonadi_indexer_agent_debug.h>
#include "abstractindexer.h"
#include <AkonadiAgentBase/AgentBase>
#include <AkonadiCore/ItemFetchJob>
#include <AkonadiCore/ItemFetchScope>
#include <AkonadiCore/CollectionFetchJob>
#include <AkonadiCore/CollectionFetchScope>
#include <AkonadiCore/ServerManager>
#include <AkonadiCore/CollectionStatistics>
#include <AkonadiCore/IndexPolicyAttribute>
#include <AkonadiCore/ItemFetchJob>
#include <AkonadiCore/ItemFetchScope>
#include <AkonadiCore/ServerManager>
#include <KLocalizedString>
#include <akonadi_indexer_agent_debug.h>
CollectionIndexingJob::CollectionIndexingJob(Index &index, const Akonadi::Collection &col, const QList<Akonadi::Item::Id> &pending, QObject *parent)
: KJob(parent)
......@@ -35,7 +35,7 @@ void CollectionIndexingJob::start()
qCDebug(AKONADI_INDEXER_AGENT_LOG);
m_time.start();
//Fetch collection for statistics
// Fetch collection for statistics
auto *job = new Akonadi::CollectionFetchJob(m_collection, Akonadi::CollectionFetchJob::Base);
job->fetchScope().setIncludeStatistics(true);
job->fetchScope().setListFilter(Akonadi::CollectionFetchScope::NoFilter);
......@@ -54,8 +54,7 @@ void CollectionIndexingJob::slotOnCollectionFetched(KJob *job)
}
m_collection = static_cast<Akonadi::CollectionFetchJob *>(job)->collections().at(0);
if (m_collection.isVirtual()
|| (m_collection.hasAttribute<Akonadi::IndexPolicyAttribute>()
&& !m_collection.attribute<Akonadi::IndexPolicyAttribute>()->indexingEnabled())) {
|| (m_collection.hasAttribute<Akonadi::IndexPolicyAttribute>() && !m_collection.attribute<Akonadi::IndexPolicyAttribute>()->indexingEnabled())) {
emitResult();
return;
}
......@@ -103,8 +102,7 @@ void CollectionIndexingJob::indexItems(const QList<Akonadi::Item::Id> &itemIds)
m_progressTotal = items.size();
m_progressCounter = 0;
connect(fetchJob, &Akonadi::ItemFetchJob::itemsReceived,
this, &CollectionIndexingJob::slotPendingItemsReceived);