Allow compiling Dolphin with KF5

[dolphin.git] / src / kitemviews / kfileitemmodelrolesupdater.cpp

diff --git a/src/kitemviews/kfileitemmodelrolesupdater.cpp b/src/kitemviews/kfileitemmodelrolesupdater.cpp
index a6d2e9a7fde1a152539846faf54e4a3b7a269547..4eb23fca8604749465296077de0ea2c199c160d7 100644 (file)
--- a/src/kitemviews/kfileitemmodelrolesupdater.cpp
+++ b/src/kitemviews/kfileitemmodelrolesupdater.cpp
@@ -24,13 +24,15 @@
 #include <KConfig>
 #include <KConfigGroup>
 #include <KDebug>
 #include <KConfig>
 #include <KConfigGroup>
 #include <KDebug>

-#include <KDirWatch>

 #include <KFileItem>
 #include <KGlobal>
 #include <KFileItem>
 #include <KGlobal>

+#include <KIconLoader>
+#include <KJobWidgets>

 #include <KIO/JobUiDelegate>
 #include <KIO/PreviewJob>
 
 #include "private/kpixmapmodifier.h"
 #include <KIO/JobUiDelegate>
 #include <KIO/PreviewJob>
 
 #include "private/kpixmapmodifier.h"

+#include "private/kdirectorycontentscounter.h"

 
 #include <QApplication>
 #include <QPainter>
 
 #include <QApplication>
 #include <QPainter>


@@ -38,17 +40,13 @@
 #include <QElapsedTimer>
 #include <QTimer>
 
 #include <QElapsedTimer>
 #include <QTimer>
 

-#ifdef HAVE_NEPOMUK
-    #include "private/knepomukrolesprovider.h"
-    #include <Nepomuk2/ResourceWatcher>
-#endif
+#include <algorithm>

 
 

-// Required includes for subItemsCount():
-#ifdef Q_WS_WIN
-    #include <QDir>
-#else
-    #include <dirent.h>
-    #include <QFile>
+#ifdef HAVE_BALOO
+    #include "private/kbaloorolesprovider.h"
+    #include <baloo/file.h>
+    #include <baloo/filefetchjob.h>
+    #include <baloo/filemonitor.h>

 #endif
 
 // #define KFILEITEMMODELROLESUPDATER_DEBUG
 #endif
 
 // #define KFILEITEMMODELROLESUPDATER_DEBUG


@@ -58,39 +56,43 @@ namespace {
     // may perform a blocking operation
     const int MaxBlockTimeout = 200;
 
     // may perform a blocking operation
     const int MaxBlockTimeout = 200;
 

-    // Maximum number of items that will get resolved synchronously.
-    // The value should roughly represent the number of maximum visible
-    // items, as it does not make sense to resolve more items synchronously
-    // and probably reach the MaxBlockTimeout because of invisible items.
-    const int MaxResolveItemsCount = 100;
+    // If the number of items is smaller than ResolveAllItemsLimit,
+    // the roles of all items will be resolved.
+    const int ResolveAllItemsLimit = 500;
+
+    // Not only the visible area, but up to ReadAheadPages before and after
+    // this area will be resolved.
+    const int ReadAheadPages = 5;

 }
 
 KFileItemModelRolesUpdater::KFileItemModelRolesUpdater(KFileItemModel* model, QObject* parent) :
     QObject(parent),
 }
 
 KFileItemModelRolesUpdater::KFileItemModelRolesUpdater(KFileItemModel* model, QObject* parent) :
     QObject(parent),

-    m_paused(false),
+    m_state(Idle),

     m_previewChangedDuringPausing(false),
     m_iconSizeChangedDuringPausing(false),
     m_rolesChangedDuringPausing(false),
     m_previewShown(false),
     m_enlargeSmallPreviews(true),
     m_clearPreviews(false),
     m_previewChangedDuringPausing(false),
     m_iconSizeChangedDuringPausing(false),
     m_rolesChangedDuringPausing(false),
     m_previewShown(false),
     m_enlargeSmallPreviews(true),
     m_clearPreviews(false),

-    m_sortingProgress(-1),
+    m_finishedItems(),

     m_model(model),
     m_iconSize(),
     m_firstVisibleIndex(0),
     m_lastVisibleIndex(-1),
     m_model(model),
     m_iconSize(),
     m_firstVisibleIndex(0),
     m_lastVisibleIndex(-1),

+    m_maximumVisibleItems(50),

     m_roles(),
     m_roles(),

+    m_resolvableRoles(),

     m_enabledPlugins(),
     m_enabledPlugins(),

-    m_pendingVisibleItems(),
-    m_pendingInvisibleItems(),
-    m_previewJobs(),
-    m_changedItemsTimer(0),
+    m_pendingSortRoleItems(),
+    m_pendingIndexes(),
+    m_pendingPreviewItems(),
+    m_previewJob(),
+    m_recentlyChangedItemsTimer(0),
+    m_recentlyChangedItems(),

     m_changedItems(),
     m_changedItems(),

-    m_dirWatcher(0),
-    m_watchedDirs()
-  #ifdef HAVE_NEPOMUK
-  , m_nepomukResourceWatcher(0),
-    m_nepomukUriItems()
+    m_directoryContentsCounter(0)
+  #ifdef HAVE_BALOO
+  , m_balooFileMonitor(0)

   #endif
 {
     Q_ASSERT(model);
   #endif
 {
     Q_ASSERT(model);


@@ -107,46 +109,46 @@ KFileItemModelRolesUpdater::KFileItemModelRolesUpdater(KFileItemModel* model, QO
             this,    SLOT(slotItemsRemoved(KItemRangeList)));
     connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
             this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
             this,    SLOT(slotItemsRemoved(KItemRangeList)));
     connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
             this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));

+    connect(m_model, SIGNAL(itemsMoved(KItemRange,QList<int>)),
+            this,    SLOT(slotItemsMoved(KItemRange,QList<int>)));

     connect(m_model, SIGNAL(sortRoleChanged(QByteArray,QByteArray)),
             this,    SLOT(slotSortRoleChanged(QByteArray,QByteArray)));
 
     // Use a timer to prevent that each call of slotItemsChanged() results in a synchronous
     // resolving of the roles. Postpone the resolving until no update has been done for 1 second.
     connect(m_model, SIGNAL(sortRoleChanged(QByteArray,QByteArray)),
             this,    SLOT(slotSortRoleChanged(QByteArray,QByteArray)));
 
     // Use a timer to prevent that each call of slotItemsChanged() results in a synchronous
     // resolving of the roles. Postpone the resolving until no update has been done for 1 second.

-    m_changedItemsTimer = new QTimer(this);
-    m_changedItemsTimer->setInterval(1000);
-    m_changedItemsTimer->setSingleShot(true);
-    connect(m_changedItemsTimer, SIGNAL(timeout()), this, SLOT(resolveChangedItems()));
+    m_recentlyChangedItemsTimer = new QTimer(this);
+    m_recentlyChangedItemsTimer->setInterval(1000);
+    m_recentlyChangedItemsTimer->setSingleShot(true);
+    connect(m_recentlyChangedItemsTimer, SIGNAL(timeout()), this, SLOT(resolveRecentlyChangedItems()));

 
     m_resolvableRoles.insert("size");
     m_resolvableRoles.insert("type");
     m_resolvableRoles.insert("isExpandable");
 
     m_resolvableRoles.insert("size");
     m_resolvableRoles.insert("type");
     m_resolvableRoles.insert("isExpandable");

-#ifdef HAVE_NEPOMUK
-    m_resolvableRoles += KNepomukRolesProvider::instance().roles();
+#ifdef HAVE_BALOO
+    m_resolvableRoles += KBalooRolesProvider::instance().roles();

 #endif
 
 #endif
 

-    // When folders are expandable or the item-count is shown for folders, it is necessary
-    // to watch the number of items of the sub-folder to be able to react on changes.
-    m_dirWatcher = new KDirWatch(this);
-    connect(m_dirWatcher, SIGNAL(dirty(QString)), this, SLOT(slotDirWatchDirty(QString)));
+    m_directoryContentsCounter = new KDirectoryContentsCounter(m_model, this);
+    connect(m_directoryContentsCounter, SIGNAL(result(QString,int)),
+            this,                       SLOT(slotDirectoryContentsCountReceived(QString,int)));

 }
 
 KFileItemModelRolesUpdater::~KFileItemModelRolesUpdater()
 {
 }
 
 KFileItemModelRolesUpdater::~KFileItemModelRolesUpdater()
 {

-    resetPendingRoles();
+    killPreviewJob();

 }
 
 void KFileItemModelRolesUpdater::setIconSize(const QSize& size)
 {
     if (size != m_iconSize) {
         m_iconSize = size;
 }
 
 void KFileItemModelRolesUpdater::setIconSize(const QSize& size)
 {
     if (size != m_iconSize) {
         m_iconSize = size;

-        if (m_paused) {
+        if (m_state == Paused) {

             m_iconSizeChangedDuringPausing = true;
         } else if (m_previewShown) {
             // An icon size change requires the regenerating of
             // all previews
             m_iconSizeChangedDuringPausing = true;
         } else if (m_previewShown) {
             // An icon size change requires the regenerating of
             // all previews

-            sortAndResolveAllRoles();
-        } else {
-            sortAndResolvePendingRoles();
+            m_finishedItems.clear();
+            startUpdating();

         }
     }
 }
         }
     }
 }


@@ -173,9 +175,12 @@ void KFileItemModelRolesUpdater::setVisibleIndexRange(int index, int count)
     m_firstVisibleIndex = index;
     m_lastVisibleIndex = qMin(index + count - 1, m_model->count() - 1);
 
     m_firstVisibleIndex = index;
     m_lastVisibleIndex = qMin(index + count - 1, m_model->count() - 1);
 

-    if (hasPendingRoles() && !m_paused) {
-        sortAndResolvePendingRoles();
-    }
+    startUpdating();
+}
+
+void KFileItemModelRolesUpdater::setMaximumVisibleItems(int count)
+{
+    m_maximumVisibleItems = count;

 }
 
 void KFileItemModelRolesUpdater::setPreviewsShown(bool show)
 }
 
 void KFileItemModelRolesUpdater::setPreviewsShown(bool show)


@@ -224,31 +229,33 @@ void KFileItemModelRolesUpdater::setEnabledPlugins(const QStringList& list)
 
 void KFileItemModelRolesUpdater::setPaused(bool paused)
 {
 
 void KFileItemModelRolesUpdater::setPaused(bool paused)
 {

-    if (paused == m_paused) {
+    if (paused == (m_state == Paused)) {

         return;
     }
 
         return;
     }
 

-    m_paused = paused;

     if (paused) {
     if (paused) {

-        if (hasPendingRoles()) {
-            foreach (KJob* job, m_previewJobs) {
-                job->kill();
-            }
-            Q_ASSERT(m_previewJobs.isEmpty());
-        }
+        m_state = Paused;
+        killPreviewJob();

     } else {
     } else {

-        const bool resolveAll = (m_iconSizeChangedDuringPausing && m_previewShown) ||
-                                m_previewChangedDuringPausing ||
-                                m_rolesChangedDuringPausing;
+        const bool updatePreviews = (m_iconSizeChangedDuringPausing && m_previewShown) ||
+                                    m_previewChangedDuringPausing;
+        const bool resolveAll = updatePreviews || m_rolesChangedDuringPausing;

         if (resolveAll) {
         if (resolveAll) {

-            sortAndResolveAllRoles();
-        } else {
-            sortAndResolvePendingRoles();
+            m_finishedItems.clear();

         }
 
         m_iconSizeChangedDuringPausing = false;
         m_previewChangedDuringPausing = false;
         m_rolesChangedDuringPausing = false;
         }
 
         m_iconSizeChangedDuringPausing = false;
         m_previewChangedDuringPausing = false;
         m_rolesChangedDuringPausing = false;

+
+        if (!m_pendingSortRoleItems.isEmpty()) {
+            m_state = ResolvingSortRole;
+            resolveNextSortRole();
+        } else {
+            m_state = Idle;
+        }
+
+        startUpdating();

     }
 }
 
     }
 }
 


@@ -257,41 +264,36 @@ void KFileItemModelRolesUpdater::setRoles(const QSet<QByteArray>& roles)
     if (m_roles != roles) {
         m_roles = roles;
 
     if (m_roles != roles) {
         m_roles = roles;
 

-#ifdef HAVE_NEPOMUK
+#ifdef HAVE_BALOO

         // Check whether there is at least one role that must be resolved
         // Check whether there is at least one role that must be resolved

-        // with the help of Nepomuk. If this is the case, a (quite expensive)
+        // with the help of Baloo. If this is the case, a (quite expensive)

         // resolving will be done in KFileItemModelRolesUpdater::rolesData() and
         // the role gets watched for changes.
         // resolving will be done in KFileItemModelRolesUpdater::rolesData() and
         // the role gets watched for changes.

-        const KNepomukRolesProvider& rolesProvider = KNepomukRolesProvider::instance();
-        bool hasNepomukRole = false;
+        const KBalooRolesProvider& rolesProvider = KBalooRolesProvider::instance();
+        bool hasBalooRole = false;

         QSetIterator<QByteArray> it(roles);
         while (it.hasNext()) {
             const QByteArray& role = it.next();
             if (rolesProvider.roles().contains(role)) {
         QSetIterator<QByteArray> it(roles);
         while (it.hasNext()) {
             const QByteArray& role = it.next();
             if (rolesProvider.roles().contains(role)) {

-                hasNepomukRole = true;
+                hasBalooRole = true;

                 break;
             }
         }
 
                 break;
             }
         }
 

-        if (hasNepomukRole && !m_nepomukResourceWatcher) {
-            Q_ASSERT(m_nepomukUriItems.isEmpty());
-
-            m_nepomukResourceWatcher = new Nepomuk2::ResourceWatcher(this);
-            connect(m_nepomukResourceWatcher, SIGNAL(propertyChanged(Nepomuk2::Resource,Nepomuk2::Types::Property,QVariantList,QVariantList)),
-                    this, SLOT(applyChangedNepomukRoles(Nepomuk2::Resource)));
-        } else if (!hasNepomukRole && m_nepomukResourceWatcher) {
-            delete m_nepomukResourceWatcher;
-            m_nepomukResourceWatcher = 0;
-            m_nepomukUriItems.clear();
+        if (hasBalooRole && !m_balooFileMonitor) {
+            m_balooFileMonitor = new Baloo::FileMonitor(this);
+            connect(m_balooFileMonitor, SIGNAL(fileMetaDataChanged(QString)),
+                    this, SLOT(applyChangedBalooRoles(QString)));
+        } else if (!hasBalooRole && m_balooFileMonitor) {
+            delete m_balooFileMonitor;
+            m_balooFileMonitor = 0;

         }
 #endif
 
         }
 #endif
 

-        updateSortProgress();
-
-        if (m_paused) {
+        if (m_state == Paused) {

             m_rolesChangedDuringPausing = true;
         } else {
             m_rolesChangedDuringPausing = true;
         } else {

-            sortAndResolveAllRoles();
+            startUpdating();

         }
     }
 }
         }
     }
 }


@@ -303,7 +305,7 @@ QSet<QByteArray> KFileItemModelRolesUpdater::roles() const
 
 bool KFileItemModelRolesUpdater::isPaused() const
 {
 
 bool KFileItemModelRolesUpdater::isPaused() const
 {

-    return m_paused;
+    return m_state == Paused;

 }
 
 QStringList KFileItemModelRolesUpdater::enabledPlugins() const
 }
 
 QStringList KFileItemModelRolesUpdater::enabledPlugins() const


@@ -313,7 +315,37 @@ QStringList KFileItemModelRolesUpdater::enabledPlugins() const
 
 void KFileItemModelRolesUpdater::slotItemsInserted(const KItemRangeList& itemRanges)
 {
 
 void KFileItemModelRolesUpdater::slotItemsInserted(const KItemRangeList& itemRanges)
 {

-    startUpdating(itemRanges);
+    QElapsedTimer timer;
+    timer.start();
+
+    // Determine the sort role synchronously for as many items as possible.
+    if (m_resolvableRoles.contains(m_model->sortRole())) {
+        int insertedCount = 0;
+        foreach (const KItemRange& range, itemRanges) {
+            const int lastIndex = insertedCount + range.index + range.count - 1;
+            for (int i = insertedCount + range.index; i <= lastIndex; ++i) {
+                if (timer.elapsed() < MaxBlockTimeout) {
+                    applySortRole(i);
+                } else {
+                    m_pendingSortRoleItems.insert(m_model->fileItem(i));
+                }
+            }
+            insertedCount += range.count;
+        }
+
+        applySortProgressToModel();
+
+        // If there are still items whose sort role is unknown, check if the
+        // asynchronous determination of the sort role is already in progress,
+        // and start it if that is not the case.
+        if (!m_pendingSortRoleItems.isEmpty() && m_state != ResolvingSortRole) {
+            killPreviewJob();
+            m_state = ResolvingSortRole;
+            resolveNextSortRole();
+        }
+    }
+
+    startUpdating();

 }
 
 void KFileItemModelRolesUpdater::slotItemsRemoved(const KItemRangeList& itemRanges)
 }
 
 void KFileItemModelRolesUpdater::slotItemsRemoved(const KItemRangeList& itemRanges)


@@ -322,104 +354,87 @@ void KFileItemModelRolesUpdater::slotItemsRemoved(const KItemRangeList& itemRang
 
     const bool allItemsRemoved = (m_model->count() == 0);
 
 
     const bool allItemsRemoved = (m_model->count() == 0);
 

-    if (!m_watchedDirs.isEmpty()) {
-        // Don't let KDirWatch watch for removed items
-        if (allItemsRemoved) {
-            foreach (const QString& path, m_watchedDirs) {
-                m_dirWatcher->removeDir(path);
-            }
-            m_watchedDirs.clear();
-        } else {
-            QMutableSetIterator<QString> it(m_watchedDirs);
-            while (it.hasNext()) {
-                const QString& path = it.next();
-                if (m_model->index(KUrl(path)) < 0) {
-                    m_dirWatcher->removeDir(path);
-                    it.remove();
-                }
-            }
-        }
-    }
-
-#ifdef HAVE_NEPOMUK
-    if (m_nepomukResourceWatcher) {
-        // Don't let the ResourceWatcher watch for removed items
+#ifdef HAVE_BALOO
+    if (m_balooFileMonitor) {
+        // Don't let the FileWatcher watch for removed items

         if (allItemsRemoved) {
         if (allItemsRemoved) {

-            m_nepomukResourceWatcher->setResources(QList<Nepomuk2::Resource>());
-            m_nepomukResourceWatcher->stop();
-            m_nepomukUriItems.clear();
+            m_balooFileMonitor->clear();

         } else {
         } else {

-            QList<Nepomuk2::Resource> newResources;
-            const QList<Nepomuk2::Resource> oldResources = m_nepomukResourceWatcher->resources();
-            foreach (const Nepomuk2::Resource& resource, oldResources) {
-                const QUrl uri = resource.uri();
-                const KUrl itemUrl = m_nepomukUriItems.value(uri);
+            QStringList newFileList;
+            foreach (const QString& itemUrl, m_balooFileMonitor->files()) {

                 if (m_model->index(itemUrl) >= 0) {
                 if (m_model->index(itemUrl) >= 0) {

-                    newResources.append(resource);
-                } else {
-                    m_nepomukUriItems.remove(uri);
+                    newFileList.append(itemUrl);

                 }
             }
                 }
             }

-            m_nepomukResourceWatcher->setResources(newResources);
-            if (newResources.isEmpty()) {
-                Q_ASSERT(m_nepomukUriItems.isEmpty());
-                m_nepomukResourceWatcher->stop();
-            }
+            m_balooFileMonitor->setFiles(newFileList);

         }
     }
 #endif
 
         }
     }
 #endif
 

-    m_firstVisibleIndex = 0;
-    m_lastVisibleIndex = -1;
-    if (!hasPendingRoles()) {
-        return;
-    }
-

     if (allItemsRemoved) {
     if (allItemsRemoved) {

-        // Most probably a directory change is done. Clear all pending items
-        // and also kill all ongoing preview-jobs.
-        resetPendingRoles();
-
+        m_state = Idle;
+
+        m_finishedItems.clear();
+        m_pendingSortRoleItems.clear();
+        m_pendingIndexes.clear();
+        m_pendingPreviewItems.clear();
+        m_recentlyChangedItems.clear();
+        m_recentlyChangedItemsTimer->stop();

         m_changedItems.clear();
         m_changedItems.clear();

-        m_changedItemsTimer->stop();
+
+        killPreviewJob();

     } else {
     } else {

-        // Remove all items from m_pendingVisibleItems and m_pendingInvisibleItems
-        // that are not part of the model anymore. The items from m_changedItems
-        // don't need to be handled here, removed items are just skipped in
-        // resolveChangedItems().
-        for (int i = 0; i <= 1; ++i) {
-            QSet<KFileItem>& pendingItems = (i == 0) ? m_pendingVisibleItems : m_pendingInvisibleItems;
-            QMutableSetIterator<KFileItem> it(pendingItems);
-            while (it.hasNext()) {
-                const KFileItem item = it.next();
-                if (m_model->index(item) < 0) {
-                    pendingItems.remove(item);
-                }
+        // Only remove the items from m_finishedItems. They will be removed
+        // from the other sets later on.
+        QSet<KFileItem>::iterator it = m_finishedItems.begin();
+        while (it != m_finishedItems.end()) {
+            if (m_model->index(*it) < 0) {
+                it = m_finishedItems.erase(it);
+            } else {
+                ++it;

             }
         }
             }
         }

+
+        // The visible items might have changed.
+        startUpdating();

     }
 }
 
     }
 }
 

+void KFileItemModelRolesUpdater::slotItemsMoved(const KItemRange& itemRange, QList<int> movedToIndexes)
+{
+    Q_UNUSED(itemRange);
+    Q_UNUSED(movedToIndexes);
+
+    // The visible items might have changed.
+    startUpdating();
+}
+

 void KFileItemModelRolesUpdater::slotItemsChanged(const KItemRangeList& itemRanges,
                                                   const QSet<QByteArray>& roles)
 {
     Q_UNUSED(roles);
 
 void KFileItemModelRolesUpdater::slotItemsChanged(const KItemRangeList& itemRanges,
                                                   const QSet<QByteArray>& roles)
 {
     Q_UNUSED(roles);
 

-    if (m_changedItemsTimer->isActive()) {
-        // A call of slotItemsChanged() has been done recently. Postpone the resolving
-        // of the roles until the timer has exceeded.
-        foreach (const KItemRange& itemRange, itemRanges) {
-            int index = itemRange.index;
-            for (int count = itemRange.count; count > 0; --count) {
-                m_changedItems.insert(m_model->fileItem(index));
-                ++index;
-            }
+    // Find out if slotItemsChanged() has been done recently. If that is the
+    // case, resolving the roles is postponed until a timer has exceeded
+    // to prevent expensive repeated updates if files are updated frequently.
+    const bool itemsChangedRecently = m_recentlyChangedItemsTimer->isActive();
+
+    QSet<KFileItem>& targetSet = itemsChangedRecently ? m_recentlyChangedItems : m_changedItems;
+
+    foreach (const KItemRange& itemRange, itemRanges) {
+        int index = itemRange.index;
+        for (int count = itemRange.count; count > 0; --count) {
+            const KFileItem item = m_model->fileItem(index);
+            targetSet.insert(item);
+            ++index;

         }
         }

-    } else {
-        // No call of slotItemsChanged() has been done recently, resolve the roles now.
-        startUpdating(itemRanges);

     }
     }

-    m_changedItemsTimer->start();
+
+    m_recentlyChangedItemsTimer->start();
+
+    if (!itemsChangedRecently) {
+        updateChangedItems();
+    }

 }
 
 void KFileItemModelRolesUpdater::slotSortRoleChanged(const QByteArray& current,
 }
 
 void KFileItemModelRolesUpdater::slotSortRoleChanged(const QByteArray& current,


@@ -427,13 +442,46 @@ void KFileItemModelRolesUpdater::slotSortRoleChanged(const QByteArray& current,
 {
     Q_UNUSED(current);
     Q_UNUSED(previous);
 {
     Q_UNUSED(current);
     Q_UNUSED(previous);

-    updateSortProgress();
+
+    if (m_resolvableRoles.contains(current)) {
+        m_pendingSortRoleItems.clear();
+        m_finishedItems.clear();
+
+        const int count = m_model->count();
+        QElapsedTimer timer;
+        timer.start();
+
+        // Determine the sort role synchronously for as many items as possible.
+        for (int index = 0; index < count; ++index) {
+            if (timer.elapsed() < MaxBlockTimeout) {
+                applySortRole(index);
+            } else {
+                m_pendingSortRoleItems.insert(m_model->fileItem(index));
+            }
+        }
+
+        applySortProgressToModel();
+
+        if (!m_pendingSortRoleItems.isEmpty()) {
+            // Trigger the asynchronous determination of the sort role.
+            killPreviewJob();
+            m_state = ResolvingSortRole;
+            resolveNextSortRole();
+        }
+    } else {
+        m_state = Idle;
+        m_pendingSortRoleItems.clear();
+        applySortProgressToModel();
+    }

 }
 
 void KFileItemModelRolesUpdater::slotGotPreview(const KFileItem& item, const QPixmap& pixmap)
 {
 }
 
 void KFileItemModelRolesUpdater::slotGotPreview(const KFileItem& item, const QPixmap& pixmap)
 {

-    m_pendingVisibleItems.remove(item);
-    m_pendingInvisibleItems.remove(item);
+    if (m_state != PreviewJobRunning) {
+        return;
+    }
+
+    m_changedItems.remove(item);

 
     const int index = m_model->index(item);
     if (index < 0) {
 
     const int index = m_model->index(item);
     if (index < 0) {


@@ -479,6 +527,22 @@ void KFileItemModelRolesUpdater::slotGotPreview(const KFileItem& item, const QPi
     }
 
     QHash<QByteArray, QVariant> data = rolesData(item);
     }
 
     QHash<QByteArray, QVariant> data = rolesData(item);

+
+    const QStringList overlays = data["iconOverlays"].toStringList();
+    // Strangely KFileItem::overlays() returns empty string-values, so
+    // we need to check first whether an overlay must be drawn at all.
+    // It is more efficient to do it here, as KIconLoader::drawOverlays()
+    // assumes that an overlay will be drawn and has some additional
+    // setup time.
+    foreach (const QString& overlay, overlays) {
+        if (!overlay.isEmpty()) {
+            // There is at least one overlay, draw all overlays above m_pixmap
+            // and cancel the check
+            KIconLoader::global()->drawOverlays(overlays, scaledPixmap, KIconLoader::Desktop);
+            break;
+        }
+    }
+

     data.insert("iconPixmap", scaledPixmap);
 
     disconnect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
     data.insert("iconPixmap", scaledPixmap);
 
     disconnect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),


@@ -487,105 +551,152 @@ void KFileItemModelRolesUpdater::slotGotPreview(const KFileItem& item, const QPi
     connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
             this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
 
     connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
             this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
 

-    applySortProgressToModel();
+    m_finishedItems.insert(item);

 }
 
 void KFileItemModelRolesUpdater::slotPreviewFailed(const KFileItem& item)
 {
 }
 
 void KFileItemModelRolesUpdater::slotPreviewFailed(const KFileItem& item)
 {

-    m_pendingVisibleItems.remove(item);
-    m_pendingInvisibleItems.remove(item);
+    if (m_state != PreviewJobRunning) {
+        return;
+    }

 
 

-    const bool clearPreviews = m_clearPreviews;
-    m_clearPreviews = true;
-    applyResolvedRoles(item, ResolveAll);
-    m_clearPreviews = clearPreviews;
+    m_changedItems.remove(item);
+
+    const int index = m_model->index(item);
+    if (index >= 0) {
+        QHash<QByteArray, QVariant> data;
+        data.insert("iconPixmap", QPixmap());

 
 

-    applySortProgressToModel();
+        disconnect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
+                   this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
+        m_model->setData(index, data);
+        connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
+                this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
+
+        applyResolvedRoles(index, ResolveAll);
+        m_finishedItems.insert(item);
+    }

 }
 
 }
 

-void KFileItemModelRolesUpdater::slotPreviewJobFinished(KJob* job)
+void KFileItemModelRolesUpdater::slotPreviewJobFinished()

 {
 {

-#ifdef KFILEITEMMODELROLESUPDATER_DEBUG
-    kDebug() << "Preview job finished. Pending visible:" << m_pendingVisibleItems.count() << "invisible:" << m_pendingInvisibleItems.count();
-#endif
+    m_previewJob = 0;

 
 

-    m_previewJobs.removeOne(job);
-    if (!m_previewJobs.isEmpty() || !hasPendingRoles()) {
+    if (m_state != PreviewJobRunning) {

         return;
     }
 
         return;
     }
 

-    const KFileItemList visibleItems = sortedItems(m_pendingVisibleItems);
-    startPreviewJob(visibleItems + m_pendingInvisibleItems.toList());
+    m_state = Idle;
+
+    if (!m_pendingPreviewItems.isEmpty()) {
+        startPreviewJob();
+    } else {
+        if (!m_changedItems.isEmpty()) {
+            updateChangedItems();
+        }
+    }

 }
 
 }
 

-void KFileItemModelRolesUpdater::resolveNextPendingRoles()
+void KFileItemModelRolesUpdater::resolveNextSortRole()

 {
 {

-    if (m_paused) {
+    if (m_state != ResolvingSortRole) {

         return;
     }
 
         return;
     }
 

-    if (m_previewShown) {
-        // The preview has been turned on since the last run. Skip
-        // resolving further pending roles as this is done as soon
-        // as a preview has been received.
-        return;
-    }
+    QSet<KFileItem>::iterator it = m_pendingSortRoleItems.begin();
+    while (it != m_pendingSortRoleItems.end()) {
+        const KFileItem item = *it;
+        const int index = m_model->index(item);

 
 

-    int resolvedCount = 0;
-    bool changed = false;
-    for (int i = 0; i <= 1; ++i) {
-        QSet<KFileItem>& pendingItems = (i == 0) ? m_pendingVisibleItems : m_pendingInvisibleItems;
-        QSet<KFileItem>::iterator it = pendingItems.begin();
-        while (it != pendingItems.end() && !changed && resolvedCount < MaxResolveItemsCount) {
-            changed = applyResolvedRoles(*it, ResolveAll);
-            it = pendingItems.erase(it);
-            ++resolvedCount;
+        // Continue if the sort role has already been determined for the
+        // item, and the item has not been changed recently.
+        if (!m_changedItems.contains(item) && m_model->data(index).contains(m_model->sortRole())) {
+            it = m_pendingSortRoleItems.erase(it);
+            continue;

         }
         }

-    }

 
 

-    if (hasPendingRoles()) {
-        QTimer::singleShot(0, this, SLOT(resolveNextPendingRoles()));
-    } else {
-        m_clearPreviews = false;
+        applySortRole(index);
+        m_pendingSortRoleItems.erase(it);
+        break;

     }
 
     }
 

-    applySortProgressToModel();
+    if (!m_pendingSortRoleItems.isEmpty()) {
+        applySortProgressToModel();
+        QTimer::singleShot(0, this, SLOT(resolveNextSortRole()));
+    } else {
+        m_state = Idle;

 
 

-#ifdef KFILEITEMMODELROLESUPDATER_DEBUG
-    static int callCount = 0;
-    ++callCount;
-    if (callCount % 100 == 0) {
-        kDebug() << "Remaining visible roles to resolve:" << m_pendingVisibleItems.count()
-                 << "invisible:" << m_pendingInvisibleItems.count();
+        // Prevent that we try to update the items twice.
+        disconnect(m_model, SIGNAL(itemsMoved(KItemRange,QList<int>)),
+                   this,    SLOT(slotItemsMoved(KItemRange,QList<int>)));
+        applySortProgressToModel();
+        connect(m_model, SIGNAL(itemsMoved(KItemRange,QList<int>)),
+                this,    SLOT(slotItemsMoved(KItemRange,QList<int>)));
+        startUpdating();

     }
     }

-#endif

 }
 
 }
 

-void KFileItemModelRolesUpdater::resolveChangedItems()
+void KFileItemModelRolesUpdater::resolveNextPendingRoles()

 {
 {

-    if (m_changedItems.isEmpty()) {
+    if (m_state != ResolvingAllRoles) {

         return;
     }
 
         return;
     }
 

-    KItemRangeList itemRanges;
+    while (!m_pendingIndexes.isEmpty()) {
+        const int index = m_pendingIndexes.takeFirst();
+        const KFileItem item = m_model->fileItem(index);

 
 

-    QSetIterator<KFileItem> it(m_changedItems);
-    while (it.hasNext()) {
-        const KFileItem& item = it.next();
-        const int index = m_model->index(item);
-        if (index >= 0) {
-            itemRanges.append(KItemRange(index, 1));
+        if (m_finishedItems.contains(item)) {
+            continue;

         }
         }

+
+        applyResolvedRoles(index, ResolveAll);
+        m_finishedItems.insert(item);
+        m_changedItems.remove(item);
+        break;

     }
     }

-    m_changedItems.clear();

 
 

-    startUpdating(itemRanges);
+    if (!m_pendingIndexes.isEmpty()) {
+        QTimer::singleShot(0, this, SLOT(resolveNextPendingRoles()));
+    } else {
+        m_state = Idle;
+
+        if (m_clearPreviews) {
+            // Only go through the list if there are items which might still have previews.
+            if (m_finishedItems.count() != m_model->count()) {
+                QHash<QByteArray, QVariant> data;
+                data.insert("iconPixmap", QPixmap());
+
+                disconnect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
+                           this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
+                for (int index = 0; index <= m_model->count(); ++index) {
+                    if (m_model->data(index).contains("iconPixmap")) {
+                        m_model->setData(index, data);
+                    }
+                }
+                connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
+                        this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
+
+            }
+            m_clearPreviews = false;
+        }
+
+        if (!m_changedItems.isEmpty()) {
+            updateChangedItems();
+        }
+    }
+}
+
+void KFileItemModelRolesUpdater::resolveRecentlyChangedItems()
+{
+    m_changedItems += m_recentlyChangedItems;
+    m_recentlyChangedItems.clear();
+    updateChangedItems();

 }
 
 }
 

-void KFileItemModelRolesUpdater::applyChangedNepomukRoles(const Nepomuk2::Resource& resource)
+void KFileItemModelRolesUpdater::applyChangedBalooRoles(const QString& itemUrl)

 {
 {

-#ifdef HAVE_NEPOMUK
-    const KUrl itemUrl = m_nepomukUriItems.value(resource.uri());
+#ifdef HAVE_BALOO

     const KFileItem item = m_model->fileItem(itemUrl);
 
     if (item.isNull()) {
     const KFileItem item = m_model->fileItem(itemUrl);
 
     if (item.isNull()) {


@@ -594,10 +705,34 @@ void KFileItemModelRolesUpdater::applyChangedNepomukRoles(const Nepomuk2::Resour
         return;
     }
 
         return;
     }
 

-    QHash<QByteArray, QVariant> data = rolesData(item);
+    Baloo::FileFetchJob* job = new Baloo::FileFetchJob(item.localPath());
+    connect(job, SIGNAL(finished(KJob*)), this, SLOT(applyChangedBalooRolesJobFinished(KJob*)));
+    job->setProperty("item", QVariant::fromValue(item));
+    job->start();
+#else
+#ifndef Q_CC_MSVC
+    Q_UNUSED(itemUrl);
+#endif
+#endif
+}

 
 

-    const KNepomukRolesProvider& rolesProvider = KNepomukRolesProvider::instance();
-    QHashIterator<QByteArray, QVariant> it(rolesProvider.roleValues(resource, m_roles));
+void KFileItemModelRolesUpdater::applyChangedBalooRolesJobFinished(KJob* kjob)
+{
+#ifdef HAVE_BALOO
+    const KFileItem item = kjob->property("item").value<KFileItem>();
+
+    const KBalooRolesProvider& rolesProvider = KBalooRolesProvider::instance();
+    QHash<QByteArray, QVariant> data;
+
+    foreach (const QByteArray& role, rolesProvider.roles()) {
+        // Overwrite all the role values with an empty QVariant, because the roles
+        // provider doesn't overwrite it when the property value list is empty.
+        // See bug 322348
+        data.insert(role, QVariant());
+    }
+
+    Baloo::FileFetchJob* job = static_cast<Baloo::FileFetchJob*>(kjob);
+    QHashIterator<QByteArray, QVariant> it(rolesProvider.roleValues(job->file(), m_roles));

     while (it.hasNext()) {
         it.next();
         data.insert(it.key(), it.value());
     while (it.hasNext()) {
         it.next();
         data.insert(it.key(), it.value());


@@ -609,14 +744,10 @@ void KFileItemModelRolesUpdater::applyChangedNepomukRoles(const Nepomuk2::Resour
     m_model->setData(index, data);
     connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
             this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
     m_model->setData(index, data);
     connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
             this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));

-#else
-#ifndef Q_CC_MSVC
-    Q_UNUSED(resource);
-#endif

 #endif
 }
 
 #endif
 }
 

-void KFileItemModelRolesUpdater::slotDirWatchDirty(const QString& path)
+void KFileItemModelRolesUpdater::slotDirectoryContentsCountReceived(const QString& path, int count)

 {
     const bool getSizeRole = m_roles.contains("size");
     const bool getIsExpandableRole = m_roles.contains("isExpandable");
 {
     const bool getSizeRole = m_roles.contains("size");
     const bool getIsExpandableRole = m_roles.contains("isExpandable");


@@ -626,7 +757,6 @@ void KFileItemModelRolesUpdater::slotDirWatchDirty(const QString& path)
         if (index >= 0) {
             QHash<QByteArray, QVariant> data;
 
         if (index >= 0) {
             QHash<QByteArray, QVariant> data;
 

-            const int count = subItemsCount(path);

             if (getSizeRole) {
                 data.insert("size", count);
             }
             if (getSizeRole) {
                 data.insert("size", count);
             }


@@ -634,56 +764,98 @@ void KFileItemModelRolesUpdater::slotDirWatchDirty(const QString& path)
                 data.insert("isExpandable", count > 0);
             }
 
                 data.insert("isExpandable", count > 0);
             }
 

+            disconnect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
+                       this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));

             m_model->setData(index, data);
             m_model->setData(index, data);

+            connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
+                    this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));

         }
     }
 }
 
         }
     }
 }
 

-void KFileItemModelRolesUpdater::startUpdating(const KItemRangeList& itemRanges)
+void KFileItemModelRolesUpdater::startUpdating()

 {
 {

-    // If no valid index range is given assume that all items are visible.
-    // A cleanup will be done later as soon as the index range has been set.
-    const bool hasValidIndexRange = (m_lastVisibleIndex >= 0);
-
-    if (hasValidIndexRange) {
-        // Move all current pending visible items that are not visible anymore
-        // to the pending invisible items.
-        QSet<KFileItem>::iterator it = m_pendingVisibleItems.begin();
-        while (it != m_pendingVisibleItems.end()) {
-            const KFileItem item = *it;
-            const int index = m_model->index(item);
-            if (index < m_firstVisibleIndex || index > m_lastVisibleIndex) {
-                it = m_pendingVisibleItems.erase(it);
-                m_pendingInvisibleItems.insert(item);
-            } else {
-                ++it;
-            }
-        }
+    if (m_state == Paused) {
+        return;

     }
 
     }
 

-    int rangesCount = 0;
+    if (m_finishedItems.count() == m_model->count()) {
+        // All roles have been resolved already.
+        m_state = Idle;
+        return;
+    }

 
 

-    foreach (const KItemRange& range, itemRanges) {
-        rangesCount += range.count;
+    // Terminate all updates that are currently active.
+    killPreviewJob();
+    m_pendingIndexes.clear();

 
 

-        // Add the inserted items to the pending visible and invisible items
-        const int lastIndex = range.index + range.count - 1;
-        for (int i = range.index; i <= lastIndex; ++i) {
-            const KFileItem item = m_model->fileItem(i);
-            if (!hasValidIndexRange || (i >= m_firstVisibleIndex && i <= m_lastVisibleIndex)) {
-                m_pendingVisibleItems.insert(item);
-            } else {
-                m_pendingInvisibleItems.insert(item);
+    QElapsedTimer timer;
+    timer.start();
+
+    // Determine the icons for the visible items synchronously.
+    updateVisibleIcons();
+
+    // A detailed update of the items in and near the visible area
+    // only makes sense if sorting is finished.
+    if (m_state == ResolvingSortRole) {
+        return;
+    }
+
+    // Start the preview job or the asynchronous resolving of all roles.
+    QList<int> indexes = indexesToResolve();
+
+    if (m_previewShown) {
+        m_pendingPreviewItems.clear();
+        m_pendingPreviewItems.reserve(indexes.count());
+
+        foreach (int index, indexes) {
+            const KFileItem item = m_model->fileItem(index);
+            if (!m_finishedItems.contains(item)) {
+                m_pendingPreviewItems.append(item);

             }
         }
             }
         }

+
+        startPreviewJob();
+    } else {
+        m_pendingIndexes = indexes;
+        // Trigger the asynchronous resolving of all roles.
+        m_state = ResolvingAllRoles;
+        QTimer::singleShot(0, this, SLOT(resolveNextPendingRoles()));
+    }
+}
+
+void KFileItemModelRolesUpdater::updateVisibleIcons()
+{
+    int lastVisibleIndex = m_lastVisibleIndex;
+    if (lastVisibleIndex <= 0) {
+        // Guess a reasonable value for the last visible index if the view
+        // has not told us about the real value yet.
+        lastVisibleIndex = qMin(m_firstVisibleIndex + m_maximumVisibleItems, m_model->count() - 1);
+        if (lastVisibleIndex <= 0) {
+            lastVisibleIndex = qMin(200, m_model->count() - 1);
+        }
+    }
+
+    QElapsedTimer timer;
+    timer.start();
+
+    // Try to determine the final icons for all visible items.
+    int index;
+    for (index = m_firstVisibleIndex; index <= lastVisibleIndex && timer.elapsed() < MaxBlockTimeout; ++index) {
+        applyResolvedRoles(index, ResolveFast);

     }
 
     }
 

-    resolvePendingRoles();
+    // KFileItemListView::initializeItemListWidget(KItemListWidget*) will load
+    // preliminary icons (i.e., without mime type determination) for the
+    // remaining items.

 }
 
 }
 

-void KFileItemModelRolesUpdater::startPreviewJob(const KFileItemList& items)
+void KFileItemModelRolesUpdater::startPreviewJob()

 {
 {

-    if (items.isEmpty() || m_paused) {
+    m_state = PreviewJobRunning;
+
+    if (m_pendingPreviewItems.isEmpty()) {
+        QTimer::singleShot(0, this, SLOT(slotPreviewJobFinished()));

         return;
     }
 
         return;
     }
 


@@ -693,36 +865,41 @@ void KFileItemModelRolesUpdater::startPreviewJob(const KFileItemList& items)
     // do a downscaling anyhow because of the frame, so in this case only the provided
     // cache sizes are requested.
     const QSize cacheSize = (m_iconSize.width() > 128) || (m_iconSize.height() > 128)
     // do a downscaling anyhow because of the frame, so in this case only the provided
     // cache sizes are requested.
     const QSize cacheSize = (m_iconSize.width() > 128) || (m_iconSize.height() > 128)

-                            ? QSize(256, 256) : QSize(128, 128);
+                             ? QSize(256, 256) : QSize(128, 128);

 
     // KIO::filePreview() will request the MIME-type of all passed items, which (in the
     // worst case) might block the application for several seconds. To prevent such
 
     // KIO::filePreview() will request the MIME-type of all passed items, which (in the
     // worst case) might block the application for several seconds. To prevent such

-    // a blocking the MIME-type of the items will determined until the MaxBlockTimeout
-    // has been reached and only those items will get passed. As soon as the MIME-type
-    // has been resolved once KIO::PreviewJob() can already access the resolved
-    // MIME-type in a fast way.
-    QElapsedTimer timer;
-    timer.start();
-
+    // a blocking, we only pass items with known mime type to the preview job.
+    const int count = m_pendingPreviewItems.count();

     KFileItemList itemSubSet;
     KFileItemList itemSubSet;

-    const int count = items.count();

     itemSubSet.reserve(count);
     itemSubSet.reserve(count);

-    for (int i = 0; i < count; ++i) {
-        KFileItem item = items.at(i);
-        item.determineMimeType();
-        itemSubSet.append(item);
-        if (timer.elapsed() > MaxBlockTimeout) {
-#ifdef KFILEITEMMODELROLESUPDATER_DEBUG
-            kDebug() << "Maximum time of" << MaxBlockTimeout << "ms exceeded, creating only previews for"
-                     << (i + 1) << "items," << (items.count() - (i + 1)) << "will be resolved later";
-#endif
-            break;
-        }
+
+    if (m_pendingPreviewItems.first().isMimeTypeKnown()) {
+        // Some mime types are known already, probably because they were
+        // determined when loading the icons for the visible items. Start
+        // a preview job for all items at the beginning of the list which
+        // have a known mime type.
+        do {
+            itemSubSet.append(m_pendingPreviewItems.takeFirst());
+        } while (!m_pendingPreviewItems.isEmpty() && m_pendingPreviewItems.first().isMimeTypeKnown());
+    } else {
+        // Determine mime types for MaxBlockTimeout ms, and start a preview
+        // job for the corresponding items.
+        QElapsedTimer timer;
+        timer.start();
+
+        do {
+            const KFileItem item = m_pendingPreviewItems.takeFirst();
+            item.determineMimeType();
+            itemSubSet.append(item);
+        } while (!m_pendingPreviewItems.isEmpty() && timer.elapsed() < MaxBlockTimeout);

     }
     }

+

     KIO::PreviewJob* job = new KIO::PreviewJob(itemSubSet, cacheSize, &m_enabledPlugins);
     KIO::PreviewJob* job = new KIO::PreviewJob(itemSubSet, cacheSize, &m_enabledPlugins);

-    job->setIgnoreMaximumSize(items.first().isLocalFile());
+
+    job->setIgnoreMaximumSize(itemSubSet.first().isLocalFile());

     if (job->ui()) {
     if (job->ui()) {

-        job->ui()->setWindow(qApp->activeWindow());
+        KJobWidgets::setWindow(job, qApp->activeWindow());

     }
 
     connect(job,  SIGNAL(gotPreview(KFileItem,QPixmap)),
     }
 
     connect(job,  SIGNAL(gotPreview(KFileItem,QPixmap)),


@@ -730,279 +907,128 @@ void KFileItemModelRolesUpdater::startPreviewJob(const KFileItemList& items)
     connect(job,  SIGNAL(failed(KFileItem)),
             this, SLOT(slotPreviewFailed(KFileItem)));
     connect(job,  SIGNAL(finished(KJob*)),
     connect(job,  SIGNAL(failed(KFileItem)),
             this, SLOT(slotPreviewFailed(KFileItem)));
     connect(job,  SIGNAL(finished(KJob*)),

-            this, SLOT(slotPreviewJobFinished(KJob*)));
-
-    m_previewJobs.append(job);
-}
-
-
-bool KFileItemModelRolesUpdater::hasPendingRoles() const
-{
-    return !m_pendingVisibleItems.isEmpty() || !m_pendingInvisibleItems.isEmpty();
-}
-
-void KFileItemModelRolesUpdater::resolvePendingRoles()
-{
-    int resolvedCount = 0;
-
-    bool hasSlowRoles = m_previewShown;
-    if (!hasSlowRoles) {
-        QSetIterator<QByteArray> it(m_roles);
-        while (it.hasNext()) {
-            if (m_resolvableRoles.contains(it.next())) {
-                hasSlowRoles = true;
-                break;
-            }
-        }
-    }
-
-    const ResolveHint resolveHint = hasSlowRoles ? ResolveFast : ResolveAll;
-
-    // Resolving the MIME type can be expensive. Assure that not more than MaxBlockTimeout ms are
-    // spend for resolving them synchronously. Usually this is more than enough to determine
-    // all visible items, but there are corner cases where this limit gets easily exceeded.
-    QElapsedTimer timer;
-    timer.start();
-
-    // Resolve the MIME type of all visible items
-    QSet<KFileItem>::iterator visibleIt = m_pendingVisibleItems.begin();
-    while (visibleIt != m_pendingVisibleItems.end()) {
-        const KFileItem item = *visibleIt;
-        if (!hasSlowRoles) {
-            Q_ASSERT(!m_pendingInvisibleItems.contains(item));
-            // All roles will be resolved by applyResolvedRoles()
-            visibleIt = m_pendingVisibleItems.erase(visibleIt);
-        } else {
-            ++visibleIt;
-        }
-        applyResolvedRoles(item, resolveHint);
-        ++resolvedCount;
-
-        if (timer.elapsed() > MaxBlockTimeout) {
-            break;
-        }
-    }
-
-    // Resolve the MIME type of the invisible items at least until the timeout
-    // has been exceeded or the maximum number of items has been reached
-    KFileItemList invisibleItems;
-    if (m_lastVisibleIndex >= 0) {
-        // The visible range is valid, don't care about the order how the MIME
-        // type of invisible items get resolved
-        invisibleItems = m_pendingInvisibleItems.toList();
-    } else {
-        // The visible range is temporary invalid (e.g. happens when loading
-        // a directory) so take care to sort the currently invisible items where
-        // a part will get visible later
-        invisibleItems = sortedItems(m_pendingInvisibleItems);
-    }
-
-    int index = 0;
-    while (resolvedCount < MaxResolveItemsCount && index < invisibleItems.count() && timer.elapsed() <= MaxBlockTimeout) {
-        const KFileItem item = invisibleItems.at(index);
-        applyResolvedRoles(item, resolveHint);
-
-        if (!hasSlowRoles) {
-            // All roles have been resolved already by applyResolvedRoles()
-            m_pendingInvisibleItems.remove(item);
-        }
-        ++index;
-        ++resolvedCount;
-    }
-
-    if (m_previewShown) {
-        KFileItemList items = sortedItems(m_pendingVisibleItems);
-        items += invisibleItems;
-        startPreviewJob(items);
-    } else {
-        QTimer::singleShot(0, this, SLOT(resolveNextPendingRoles()));
-    }
-
-#ifdef KFILEITEMMODELROLESUPDATER_DEBUG
-    if (timer.elapsed() > MaxBlockTimeout) {
-        kDebug() << "Maximum time of" << MaxBlockTimeout
-                 << "ms exceeded, skipping items... Remaining visible:" << m_pendingVisibleItems.count()
-                 << "invisible:" << m_pendingInvisibleItems.count();
-    }
-    kDebug() << "[TIME] Resolved pending roles:" << timer.elapsed();
-#endif
-
-    applySortProgressToModel();
-}
-
-void KFileItemModelRolesUpdater::resetPendingRoles()
-{
-    m_pendingVisibleItems.clear();
-    m_pendingInvisibleItems.clear();
+            this, SLOT(slotPreviewJobFinished()));

 
 

-    foreach (KJob* job, m_previewJobs) {
-        job->kill();
-    }
-    Q_ASSERT(m_previewJobs.isEmpty());
+    m_previewJob = job;

 }
 
 }
 

-void KFileItemModelRolesUpdater::sortAndResolveAllRoles()
+void KFileItemModelRolesUpdater::updateChangedItems()

 {
 {

-    if (m_paused) {
+    if (m_state == Paused) {

         return;
     }
 
         return;
     }
 

-    resetPendingRoles();
-    Q_ASSERT(m_pendingVisibleItems.isEmpty());
-    Q_ASSERT(m_pendingInvisibleItems.isEmpty());
-
-    if (m_model->count() == 0) {
+    if (m_changedItems.isEmpty()) {

         return;
     }
 
         return;
     }
 

-    // Determine all visible items
-    Q_ASSERT(m_firstVisibleIndex >= 0);
-    for (int i = m_firstVisibleIndex; i <= m_lastVisibleIndex; ++i) {
-        const KFileItem item = m_model->fileItem(i);
-        if (!item.isNull()) {
-            m_pendingVisibleItems.insert(item);
-        }
-    }
+    m_finishedItems -= m_changedItems;

 
 

-    // Determine all invisible items
-    for (int i = 0; i < m_firstVisibleIndex; ++i) {
-        const KFileItem item = m_model->fileItem(i);
-        if (!item.isNull()) {
-            m_pendingInvisibleItems.insert(item);
-        }
-    }
-    const int count = m_model->count();
-    for (int i = m_lastVisibleIndex + 1; i < count; ++i) {
-        const KFileItem item = m_model->fileItem(i);
-        if (!item.isNull()) {
-            m_pendingInvisibleItems.insert(item);
-        }
-    }
+    if (m_resolvableRoles.contains(m_model->sortRole())) {
+        m_pendingSortRoleItems += m_changedItems;

 
 

-    resolvePendingRoles();
-}
+        if (m_state != ResolvingSortRole) {
+            // Stop the preview job if necessary, and trigger the
+            // asynchronous determination of the sort role.
+            killPreviewJob();
+            m_state = ResolvingSortRole;
+            QTimer::singleShot(0, this, SLOT(resolveNextSortRole()));
+        }

 
 

-void KFileItemModelRolesUpdater::sortAndResolvePendingRoles()
-{
-    Q_ASSERT(!m_paused);
-    if (m_model->count() == 0) {

         return;
     }
 
         return;
     }
 

-    // If no valid index range is given assume that all items are visible.
-    // A cleanup will be done later as soon as the index range has been set.
-    const bool hasValidIndexRange = (m_lastVisibleIndex >= 0);
+    QList<int> visibleChangedIndexes;
+    QList<int> invisibleChangedIndexes;

 
 

-    // Trigger a preview generation of all pending items. Assure that the visible
-    // pending items get generated first.
+    foreach (const KFileItem& item, m_changedItems) {
+        const int index = m_model->index(item);

 
 

-    // Step 1: Check if any items in m_pendingVisibleItems are not visible any more
-    //         and move them to m_pendingInvisibleItems.
-    QSet<KFileItem>::iterator itVisible = m_pendingVisibleItems.begin();
-    while (itVisible != m_pendingVisibleItems.end()) {
-        const KFileItem item = *itVisible;
-        if (item.isNull()) {
-            itVisible = m_pendingVisibleItems.erase(itVisible);
+        if (index < 0) {
+            m_changedItems.remove(item);

             continue;
         }
 
             continue;
         }
 

-        const int index = m_model->index(item);
-        if (!hasValidIndexRange || (index >= m_firstVisibleIndex && index <= m_lastVisibleIndex)) {
-            ++itVisible;
+        if (index >= m_firstVisibleIndex && index <= m_lastVisibleIndex) {
+            visibleChangedIndexes.append(index);

         } else {
         } else {

-            itVisible = m_pendingVisibleItems.erase(itVisible);
-            m_pendingInvisibleItems.insert(item);
+            invisibleChangedIndexes.append(index);

         }
     }
 
         }
     }
 

-    // Step 2: Check if any items in m_pendingInvisibleItems have become visible
-    //         and move them to m_pendingVisibleItems.
-    QSet<KFileItem>::iterator itInvisible = m_pendingInvisibleItems.begin();
-    while (itInvisible != m_pendingInvisibleItems.end()) {
-        const KFileItem item = *itInvisible;
-        if (item.isNull()) {
-            itInvisible = m_pendingInvisibleItems.erase(itInvisible);
-            continue;
-        }
+    std::sort(visibleChangedIndexes.begin(), visibleChangedIndexes.end());

 
 

-        const int index = m_model->index(item);
-        if (!hasValidIndexRange || (index >= m_firstVisibleIndex && index <= m_lastVisibleIndex)) {
-            itInvisible = m_pendingInvisibleItems.erase(itInvisible);
-            m_pendingVisibleItems.insert(item);
-        } else {
-            ++itInvisible;
+    if (m_previewShown) {
+        foreach (int index, visibleChangedIndexes) {
+            m_pendingPreviewItems.append(m_model->fileItem(index));

         }
         }

-    }
-
-    resolvePendingRoles();
-}

 
 

-void KFileItemModelRolesUpdater::applySortProgressToModel()
-{
-    if (m_sortingProgress < 0) {
-        return;
-    }
+        foreach (int index, invisibleChangedIndexes) {
+            m_pendingPreviewItems.append(m_model->fileItem(index));
+        }

 
 

-    // Inform the model about the progress of the resolved items,
-    // so that it can give an indication when the sorting has been finished.
-    const int resolvedCount = m_model->count()
-                              - m_pendingVisibleItems.count()
-                              - m_pendingInvisibleItems.count();
-    if (resolvedCount > 0) {
-        m_model->emitSortProgress(resolvedCount);
-        if (resolvedCount == m_model->count()) {
-            m_sortingProgress = -1;
+        if (!m_previewJob) {
+            startPreviewJob();
+        }
+    } else {
+        const bool resolvingInProgress = !m_pendingIndexes.isEmpty();
+        m_pendingIndexes = visibleChangedIndexes + m_pendingIndexes + invisibleChangedIndexes;
+        if (!resolvingInProgress) {
+            // Trigger the asynchronous resolving of the changed roles.
+            m_state = ResolvingAllRoles;
+            QTimer::singleShot(0, this, SLOT(resolveNextPendingRoles()));

         }
     }
 }
 
         }
     }
 }
 

-void KFileItemModelRolesUpdater::updateSortProgress()
+void KFileItemModelRolesUpdater::applySortRole(int index)

 {
 {

-    const QByteArray sortRole = m_model->sortRole();
-
-    // Optimization if the sorting is done by type: In case if all MIME-types
-    // are known, the types have been resolved already by KFileItemModel and
-    // no sort-progress feedback is required.
-    const bool showProgress = (sortRole == "type")
-                              ? hasUnknownMimeTypes()
-                              : m_resolvableRoles.contains(sortRole);
-
-    if (m_sortingProgress >= 0) {
-        // Mark the current sorting as finished
-        m_model->emitSortProgress(m_model->count());
-    }
-    m_sortingProgress = showProgress ? 0 : -1;
-}
+    QHash<QByteArray, QVariant> data;
+    const KFileItem item = m_model->fileItem(index);

 
 

-bool KFileItemModelRolesUpdater::hasUnknownMimeTypes() const
-{
-    const int count = m_model->count();
-    for (int i = 0; i < count; ++i) {
-        const KFileItem item = m_model->fileItem(i);
+    if (m_model->sortRole() == "type") {

         if (!item.isMimeTypeKnown()) {
         if (!item.isMimeTypeKnown()) {

-            return true;
+            item.determineMimeType();

         }
         }

+
+        data.insert("type", item.mimeComment());
+    } else if (m_model->sortRole() == "size" && item.isLocalFile() && item.isDir()) {
+        const QString path = item.localPath();
+        data.insert("size", m_directoryContentsCounter->countDirectoryContentsSynchronously(path));
+    } else {
+        // Probably the sort role is a baloo role - just determine all roles.
+        data = rolesData(item);

     }
 
     }
 

-    return false;
+    disconnect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
+               this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));
+    m_model->setData(index, data);
+    connect(m_model, SIGNAL(itemsChanged(KItemRangeList,QSet<QByteArray>)),
+            this,    SLOT(slotItemsChanged(KItemRangeList,QSet<QByteArray>)));

 }
 
 }
 

-bool KFileItemModelRolesUpdater::applyResolvedRoles(const KFileItem& item, ResolveHint hint)
+void KFileItemModelRolesUpdater::applySortProgressToModel()

 {
 {

-    if (item.isNull()) {
-        return false;
-    }
+    // Inform the model about the progress of the resolved items,
+    // so that it can give an indication when the sorting has been finished.
+    const int resolvedCount = m_model->count() - m_pendingSortRoleItems.count();
+    m_model->emitSortProgress(resolvedCount);
+}

 
 

+bool KFileItemModelRolesUpdater::applyResolvedRoles(int index, ResolveHint hint)
+{
+    const KFileItem item = m_model->fileItem(index);

     const bool resolveAll = (hint == ResolveAll);
 
     const bool resolveAll = (hint == ResolveAll);
 

-    bool mimeTypeChanged = false;
-    if (!item.isMimeTypeKnown()) {
+    bool iconChanged = false;
+    if (!item.isMimeTypeKnown() || !item.isFinalIconKnown()) {

         item.determineMimeType();
         item.determineMimeType();

-        mimeTypeChanged = true;
+        iconChanged = true;
+    } else if (!m_model->data(index).contains("iconName")) {
+        iconChanged = true;

     }
 
     }
 

-    if (mimeTypeChanged || resolveAll || m_clearPreviews) {
-        const int index = m_model->index(item);
+    if (iconChanged || resolveAll || m_clearPreviews) {

         if (index < 0) {
             return false;
         }
         if (index < 0) {
             return false;
         }


@@ -1029,7 +1055,7 @@ bool KFileItemModelRolesUpdater::applyResolvedRoles(const KFileItem& item, Resol
     return false;
 }
 
     return false;
 }
 

-QHash<QByteArray, QVariant> KFileItemModelRolesUpdater::rolesData(const KFileItem& item) const
+QHash<QByteArray, QVariant> KFileItemModelRolesUpdater::rolesData(const KFileItem& item)

 {
     QHash<QByteArray, QVariant> data;
 
 {
     QHash<QByteArray, QVariant> data;
 


@@ -1038,19 +1064,10 @@ QHash<QByteArray, QVariant> KFileItemModelRolesUpdater::rolesData(const KFileIte
 
     if ((getSizeRole || getIsExpandableRole) && item.isDir()) {
         if (item.isLocalFile()) {
 
     if ((getSizeRole || getIsExpandableRole) && item.isDir()) {
         if (item.isLocalFile()) {

+            // Tell m_directoryContentsCounter that we want to count the items
+            // inside the directory. The result will be received in slotDirectoryContentsCountReceived.

             const QString path = item.localPath();
             const QString path = item.localPath();

-            const int count = subItemsCount(path);
-            if (getSizeRole) {
-                data.insert("size", count);
-            }
-            if (getIsExpandableRole) {
-                data.insert("isExpandable", count > 0);
-            }
-
-            if (!m_dirWatcher->contains(path)) {
-                m_dirWatcher->addDir(path);
-                m_watchedDirs.insert(path);
-            }
+            m_directoryContentsCounter->addDirectory(path);

         } else if (getSizeRole) {
             data.insert("size", -1); // -1 indicates an unknown number of items
         }
         } else if (getSizeRole) {
             data.insert("size", -1); // -1 indicates an unknown number of items
         }


@@ -1062,136 +1079,95 @@ QHash<QByteArray, QVariant> KFileItemModelRolesUpdater::rolesData(const KFileIte
 
     data.insert("iconOverlays", item.overlays());
 
 
     data.insert("iconOverlays", item.overlays());
 

-#ifdef HAVE_NEPOMUK
-    if (m_nepomukResourceWatcher) {
-        const KNepomukRolesProvider& rolesProvider = KNepomukRolesProvider::instance();
-        Nepomuk2::Resource resource(item.nepomukUri());
-        QHashIterator<QByteArray, QVariant> it(rolesProvider.roleValues(resource, m_roles));
-        while (it.hasNext()) {
-            it.next();
-            data.insert(it.key(), it.value());
-        }
-
-        QUrl uri = resource.uri();
-        if (uri.isEmpty()) {
-            // TODO: Is there another way to explicitly create a resource?
-            // We need a resource to be able to track it for changes.
-            resource.setRating(0);
-            uri = resource.uri();
-        }
-        if (!uri.isEmpty() && !m_nepomukUriItems.contains(uri)) {
-            m_nepomukResourceWatcher->addResource(resource);
-
-            if (m_nepomukUriItems.isEmpty()) {
-                m_nepomukResourceWatcher->start();
-            }
-
-            m_nepomukUriItems.insert(uri, item.url());
-        }
+#ifdef HAVE_BALOO
+    if (m_balooFileMonitor) {
+        m_balooFileMonitor->addFile(item.localPath());
+        applyChangedBalooRoles(item.localPath());

     }
 #endif
     }
 #endif

-

     return data;
 }
 
     return data;
 }
 

-KFileItemList KFileItemModelRolesUpdater::sortedItems(const QSet<KFileItem>& items) const
+void KFileItemModelRolesUpdater::updateAllPreviews()

 {
 {

-    KFileItemList itemList;
-    if (items.isEmpty()) {
-        return itemList;
+    if (m_state == Paused) {
+        m_previewChangedDuringPausing = true;
+    } else {
+        m_finishedItems.clear();
+        startUpdating();

     }
     }

+}

 
 

-#ifdef KFILEITEMMODELROLESUPDATER_DEBUG
-    QElapsedTimer timer;
-    timer.start();
-#endif
+void KFileItemModelRolesUpdater::killPreviewJob()
+{
+    if (m_previewJob) {
+        disconnect(m_previewJob,  SIGNAL(gotPreview(KFileItem,QPixmap)),
+                   this, SLOT(slotGotPreview(KFileItem,QPixmap)));
+        disconnect(m_previewJob,  SIGNAL(failed(KFileItem)),
+                   this, SLOT(slotPreviewFailed(KFileItem)));
+        disconnect(m_previewJob,  SIGNAL(finished(KJob*)),
+                   this, SLOT(slotPreviewJobFinished()));
+        m_previewJob->kill();
+        m_previewJob = 0;
+        m_pendingPreviewItems.clear();
+    }
+}

 
 

-    QList<int> indexes;
-    indexes.reserve(items.count());
+QList<int> KFileItemModelRolesUpdater::indexesToResolve() const
+{
+    const int count = m_model->count();

 
 

-    QSetIterator<KFileItem> it(items);
-    while (it.hasNext()) {
-        const KFileItem item = it.next();
-        const int index = m_model->index(item);
-        if (index >= 0) {
-            indexes.append(index);
-        }
-    }
-    qSort(indexes);
+    QList<int> result;
+    result.reserve(ResolveAllItemsLimit);

 
 

-    itemList.reserve(items.count());
-    foreach (int index, indexes) {
-        itemList.append(m_model->fileItem(index));
+    // Add visible items.
+    for (int i = m_firstVisibleIndex; i <= m_lastVisibleIndex; ++i) {
+        result.append(i);

     }
 
     }
 

-#ifdef KFILEITEMMODELROLESUPDATER_DEBUG
-    kDebug() << "[TIME] Sorting of items:" << timer.elapsed();
-#endif
-    return itemList;
-}
+    // We need a reasonable upper limit for number of items to resolve after
+    // and before the visible range. m_maximumVisibleItems can be quite large
+    // when using Compace View.
+    const int readAheadItems = qMin(ReadAheadPages * m_maximumVisibleItems, ResolveAllItemsLimit / 2);

 
 

-int KFileItemModelRolesUpdater::subItemsCount(const QString& path) const
-{
-    const bool countHiddenFiles = m_model->showHiddenFiles();
-    const bool showFoldersOnly  = m_model->showDirectoriesOnly();
+    // Add items after the visible range.
+    const int endExtendedVisibleRange = qMin(m_lastVisibleIndex + readAheadItems, count - 1);
+    for (int i = m_lastVisibleIndex + 1; i <= endExtendedVisibleRange; ++i) {
+        result.append(i);
+    }

 
 

-#ifdef Q_WS_WIN
-    QDir dir(path);
-    QDir::Filters filters = QDir::NoDotAndDotDot | QDir::System;
-    if (countHiddenFiles) {
-        filters |= QDir::Hidden;
+    // Add items before the visible range in reverse order.
+    const int beginExtendedVisibleRange = qMax(0, m_firstVisibleIndex - readAheadItems);
+    for (int i = m_firstVisibleIndex - 1; i >= beginExtendedVisibleRange; --i) {
+        result.append(i);

     }
     }

-    if (showFoldersOnly) {
-        filters |= QDir::Dirs;
-    } else {
-        filters |= QDir::AllEntries;
+
+    // Add items on the last page.
+    const int beginLastPage = qMax(qMin(endExtendedVisibleRange + 1, count - 1), count - m_maximumVisibleItems);
+    for (int i = beginLastPage; i < count; ++i) {
+        result.append(i);

     }
     }

-    return dir.entryList(filters).count();
-#else
-    // Taken from kdelibs/kio/kio/kdirmodel.cpp
-    // Copyright (C) 2006 David Faure <faure@kde.org>

 
 

-    int count = -1;
-    DIR* dir = ::opendir(QFile::encodeName(path));
-    if (dir) {  // krazy:exclude=syscalls
-        count = 0;
-        struct dirent *dirEntry = 0;
-        while ((dirEntry = ::readdir(dir))) {
-            if (dirEntry->d_name[0] == '.') {
-                if (dirEntry->d_name[1] == '\0' || !countHiddenFiles) {
-                    // Skip "." or hidden files
-                    continue;
-                }
-                if (dirEntry->d_name[1] == '.' && dirEntry->d_name[2] == '\0') {
-                    // Skip ".."
-                    continue;
-                }
-            }
+    // Add items on the first page.
+    const int endFirstPage = qMin(qMax(beginExtendedVisibleRange - 1, 0), m_maximumVisibleItems);
+    for (int i = 0; i <= endFirstPage; ++i) {
+        result.append(i);
+    }

 
 

-            // If only directories are counted, consider an unknown file type and links also
-            // as directory instead of trying to do an expensive stat()
-            // (see bugs 292642 and 299997).
-            const bool countEntry = !showFoldersOnly ||
-                                    dirEntry->d_type == DT_DIR ||
-                                    dirEntry->d_type == DT_LNK ||
-                                    dirEntry->d_type == DT_UNKNOWN;
-            if (countEntry) {
-                ++count;
-            }
-        }
-        ::closedir(dir);
+    // Continue adding items until ResolveAllItemsLimit is reached.
+    int remainingItems = ResolveAllItemsLimit - result.count();
+
+    for (int i = endExtendedVisibleRange + 1; i < beginLastPage && remainingItems > 0; ++i) {
+        result.append(i);
+        --remainingItems;

     }
     }

-    return count;
-#endif
-}

 
 

-void KFileItemModelRolesUpdater::updateAllPreviews()
-{
-    if (m_paused) {
-        m_previewChangedDuringPausing = true;
-    } else {
-        sortAndResolveAllRoles();
+    for (int i = beginExtendedVisibleRange - 1; i > endFirstPage && remainingItems > 0; --i) {
+        result.append(i);
+        --remainingItems;

     }
     }

+
+    return result;

 }
 
 #include "kfileitemmodelrolesupdater.moc"
 }
 
 #include "kfileitemmodelrolesupdater.moc"