Differential D11529 Diff 30573 src/file/fileindexscheduler.cpp

Changeset View

Standalone View

src/file/fileindexscheduler.cpp

Show All 20 Lines
21		21
22	#include "firstrunindexer.h"	22		#include "firstrunindexer.h"
23	#include "newfileindexer.h"	23		#include "newfileindexer.h"
24	#include "modifiedfileindexer.h"	24		#include "modifiedfileindexer.h"
25	#include "xattrindexer.h"	25		#include "xattrindexer.h"
26	#include "filecontentindexer.h"	26		#include "filecontentindexer.h"
27	#include "filecontentindexerprovider.h"	27		#include "filecontentindexerprovider.h"
28	#include "unindexedfileindexer.h"	28		#include "unindexedfileindexer.h"
		29		#include "indexcleaner.h"
29		30
30	#include "fileindexerconfig.h"	31		#include "fileindexerconfig.h"
31		32
32	#include <QTimer>	33		#include <QTimer>
33	#include <QDebug>	34		#include <QDebug>
34	#include <QDBusConnection>	35		#include <QDBusConnection>
35		36
36	using namespace Baloo;	37		using namespace Baloo;
▲ Show 20 Lines • Show All 93 Lines • ▼ Show 20 Line(s)		129	if (m_checkUnindexedFiles) {
130	connect(runnable, &UnindexedFileIndexer::done, this, &FileIndexScheduler::scheduleIndexing);	131		connect(runnable, &UnindexedFileIndexer::done, this, &FileIndexScheduler::scheduleIndexing);
131		132
132	m_threadPool.start(runnable);	133		m_threadPool.start(runnable);
133	m_checkUnindexedFiles = false;	134		m_checkUnindexedFiles = false;
134	m_indexerState = UnindexedFileCheck;	135		m_indexerState = UnindexedFileCheck;
135	Q_EMIT stateChanged(m_indexerState);	136		Q_EMIT stateChanged(m_indexerState);
136	return;	137		return;
137	}	138		}
		139
		140		if (m_purgeDeindexableFiles) {
			michaelhUnsubmitted Done Same as above michaelh: Same as above
		141		auto runnable = new IndexCleaner(m_db, m_config);
		142		connect(runnable, &IndexCleaner::done, this, &FileIndexScheduler::scheduleIndexing);
		143
		144		m_threadPool.start(runnable);
		145		m_purgeDeindexableFiles = false;
		146		m_indexerState = DeindexingFileCheck;
		147		Q_EMIT stateChanged(m_indexerState);
		148		return;
		149		}
		150
138	m_indexerState = Idle;	151		m_indexerState = Idle;
139	Q_EMIT stateChanged(m_indexerState);	152		Q_EMIT stateChanged(m_indexerState);
140	}	153		}
141		154
142	static void removeStartsWith(QStringList& list, const QString& dir)	155		static void removeStartsWith(QStringList& list, const QString& dir)
143	{	156		{
144	QMutableListIterator<QString> it(list);	157		QMutableListIterator<QString> it(list);
145	while (it.hasNext()) {	158		while (it.hasNext()) {
▲ Show 20 Lines • Show All 58 Lines • ▼ Show 20 Line(s)
204	}	217		}
205		218
206	void FileIndexScheduler::checkUnindexedFiles()	219		void FileIndexScheduler::checkUnindexedFiles()
207	{	220		{
208	m_checkUnindexedFiles = true;	221		m_checkUnindexedFiles = true;
209	scheduleIndexing();	222		scheduleIndexing();
210	}	223		}
211		224
		225		void FileIndexScheduler::purgeDeindexableFiles()
			michaelhUnsubmitted Done Same as above michaelh: Same as above
		226		{
		227		m_purgeDeindexableFiles = true;
			michaelhUnsubmitted Done Same as above michaelh: Same as above
		228		scheduleIndexing();
		229		}
		230
212	uint FileIndexScheduler::getBatchSize()	231		uint FileIndexScheduler::getBatchSize()
213	{	232		{
214	return m_config->maxUncomittedFiles();	233		return m_config->maxUncomittedFiles();
215	}	234		}