1 /***************************************************************************
2 * Copyright (C) 2011 by Peter Penz <peter.penz19@gmail.com> *
4 * This program is free software; you can redistribute it and/or modify *
5 * it under the terms of the GNU General Public License as published by *
6 * the Free Software Foundation; either version 2 of the License, or *
7 * (at your option) any later version. *
9 * This program is distributed in the hope that it will be useful, *
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
12 * GNU General Public License for more details. *
14 * You should have received a copy of the GNU General Public License *
15 * along with this program; if not, write to the *
16 * Free Software Foundation, Inc., *
17 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA *
18 ***************************************************************************/
20 #include "kfileitemmodelrolesupdater.h"
22 #include "kfileitemmodel.h"
25 #include <KConfigGroup>
26 #include <KSharedConfig>
27 #include <KIconLoader>
28 #include <KJobWidgets>
29 #include <KIO/JobUiDelegate>
30 #include <KIO/PreviewJob>
31 #include <KPluginLoader>
32 #include <KOverlayIconPlugin>
34 #include "private/kpixmapmodifier.h"
35 #include "private/kdirectorycontentscounter.h"
37 #include <QApplication>
39 #include <QElapsedTimer>
43 #include "private/kbaloorolesprovider.h"
45 #include <Baloo/FileMonitor>
49 // #define KFILEITEMMODELROLESUPDATER_DEBUG
52 // Maximum time in ms that the KFileItemModelRolesUpdater
53 // may perform a blocking operation
54 const int MaxBlockTimeout
= 200;
56 // If the number of items is smaller than ResolveAllItemsLimit,
57 // the roles of all items will be resolved.
58 const int ResolveAllItemsLimit
= 500;
60 // Not only the visible area, but up to ReadAheadPages before and after
61 // this area will be resolved.
62 const int ReadAheadPages
= 5;
65 KFileItemModelRolesUpdater::KFileItemModelRolesUpdater(KFileItemModel
* model
, QObject
* parent
) :
68 m_previewChangedDuringPausing(false),
69 m_iconSizeChangedDuringPausing(false),
70 m_rolesChangedDuringPausing(false),
71 m_previewShown(false),
72 m_enlargeSmallPreviews(true),
73 m_clearPreviews(false),
77 m_firstVisibleIndex(0),
78 m_lastVisibleIndex(-1),
79 m_maximumVisibleItems(50),
83 m_pendingSortRoleItems(),
85 m_pendingPreviewItems(),
87 m_recentlyChangedItemsTimer(nullptr),
88 m_recentlyChangedItems(),
90 m_directoryContentsCounter(nullptr)
92 , m_balooFileMonitor(nullptr)
97 const KConfigGroup
globalConfig(KSharedConfig::openConfig(), "PreviewSettings");
98 m_enabledPlugins
= globalConfig
.readEntry("Plugins", KIO::PreviewJob::defaultPlugins());
100 connect(m_model
, &KFileItemModel::itemsInserted
,
101 this, &KFileItemModelRolesUpdater::slotItemsInserted
);
102 connect(m_model
, &KFileItemModel::itemsRemoved
,
103 this, &KFileItemModelRolesUpdater::slotItemsRemoved
);
104 connect(m_model
, &KFileItemModel::itemsChanged
,
105 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
106 connect(m_model
, &KFileItemModel::itemsMoved
,
107 this, &KFileItemModelRolesUpdater::slotItemsMoved
);
108 connect(m_model
, &KFileItemModel::sortRoleChanged
,
109 this, &KFileItemModelRolesUpdater::slotSortRoleChanged
);
111 // Use a timer to prevent that each call of slotItemsChanged() results in a synchronous
112 // resolving of the roles. Postpone the resolving until no update has been done for 1 second.
113 m_recentlyChangedItemsTimer
= new QTimer(this);
114 m_recentlyChangedItemsTimer
->setInterval(1000);
115 m_recentlyChangedItemsTimer
->setSingleShot(true);
116 connect(m_recentlyChangedItemsTimer
, &QTimer::timeout
, this, &KFileItemModelRolesUpdater::resolveRecentlyChangedItems
);
118 m_resolvableRoles
.insert("size");
119 m_resolvableRoles
.insert("type");
120 m_resolvableRoles
.insert("isExpandable");
122 m_resolvableRoles
+= KBalooRolesProvider::instance().roles();
125 m_directoryContentsCounter
= new KDirectoryContentsCounter(m_model
, this);
126 connect(m_directoryContentsCounter
, &KDirectoryContentsCounter::result
,
127 this, &KFileItemModelRolesUpdater::slotDirectoryContentsCountReceived
);
129 auto plugins
= KPluginLoader::instantiatePlugins(QStringLiteral("kf5/overlayicon"), nullptr, qApp
);
130 foreach (QObject
*it
, plugins
) {
131 auto plugin
= qobject_cast
<KOverlayIconPlugin
*>(it
);
133 m_overlayIconsPlugin
.append(plugin
);
134 connect(plugin
, &KOverlayIconPlugin::overlaysChanged
, this, &KFileItemModelRolesUpdater::slotOverlaysChanged
);
136 // not our/valid plugin, so delete the created object
142 KFileItemModelRolesUpdater::~KFileItemModelRolesUpdater()
147 void KFileItemModelRolesUpdater::setIconSize(const QSize
& size
)
149 if (size
!= m_iconSize
) {
151 if (m_state
== Paused
) {
152 m_iconSizeChangedDuringPausing
= true;
153 } else if (m_previewShown
) {
154 // An icon size change requires the regenerating of
156 m_finishedItems
.clear();
162 QSize
KFileItemModelRolesUpdater::iconSize() const
167 void KFileItemModelRolesUpdater::setVisibleIndexRange(int index
, int count
)
176 if (index
== m_firstVisibleIndex
&& count
== m_lastVisibleIndex
- m_firstVisibleIndex
+ 1) {
177 // The range has not been changed
181 m_firstVisibleIndex
= index
;
182 m_lastVisibleIndex
= qMin(index
+ count
- 1, m_model
->count() - 1);
187 void KFileItemModelRolesUpdater::setMaximumVisibleItems(int count
)
189 m_maximumVisibleItems
= count
;
192 void KFileItemModelRolesUpdater::setPreviewsShown(bool show
)
194 if (show
== m_previewShown
) {
198 m_previewShown
= show
;
200 m_clearPreviews
= true;
206 bool KFileItemModelRolesUpdater::previewsShown() const
208 return m_previewShown
;
211 void KFileItemModelRolesUpdater::setEnlargeSmallPreviews(bool enlarge
)
213 if (enlarge
!= m_enlargeSmallPreviews
) {
214 m_enlargeSmallPreviews
= enlarge
;
215 if (m_previewShown
) {
221 bool KFileItemModelRolesUpdater::enlargeSmallPreviews() const
223 return m_enlargeSmallPreviews
;
226 void KFileItemModelRolesUpdater::setEnabledPlugins(const QStringList
& list
)
228 if (m_enabledPlugins
!= list
) {
229 m_enabledPlugins
= list
;
230 if (m_previewShown
) {
236 void KFileItemModelRolesUpdater::setPaused(bool paused
)
238 if (paused
== (m_state
== Paused
)) {
246 const bool updatePreviews
= (m_iconSizeChangedDuringPausing
&& m_previewShown
) ||
247 m_previewChangedDuringPausing
;
248 const bool resolveAll
= updatePreviews
|| m_rolesChangedDuringPausing
;
250 m_finishedItems
.clear();
253 m_iconSizeChangedDuringPausing
= false;
254 m_previewChangedDuringPausing
= false;
255 m_rolesChangedDuringPausing
= false;
257 if (!m_pendingSortRoleItems
.isEmpty()) {
258 m_state
= ResolvingSortRole
;
259 resolveNextSortRole();
268 void KFileItemModelRolesUpdater::setRoles(const QSet
<QByteArray
>& roles
)
270 if (m_roles
!= roles
) {
274 // Check whether there is at least one role that must be resolved
275 // with the help of Baloo. If this is the case, a (quite expensive)
276 // resolving will be done in KFileItemModelRolesUpdater::rolesData() and
277 // the role gets watched for changes.
278 const KBalooRolesProvider
& rolesProvider
= KBalooRolesProvider::instance();
279 bool hasBalooRole
= false;
280 QSetIterator
<QByteArray
> it(roles
);
281 while (it
.hasNext()) {
282 const QByteArray
& role
= it
.next();
283 if (rolesProvider
.roles().contains(role
)) {
289 if (hasBalooRole
&& m_balooConfig
.fileIndexingEnabled() && !m_balooFileMonitor
) {
290 m_balooFileMonitor
= new Baloo::FileMonitor(this);
291 connect(m_balooFileMonitor
, &Baloo::FileMonitor::fileMetaDataChanged
,
292 this, &KFileItemModelRolesUpdater::applyChangedBalooRoles
);
293 } else if (!hasBalooRole
&& m_balooFileMonitor
) {
294 delete m_balooFileMonitor
;
295 m_balooFileMonitor
= nullptr;
299 if (m_state
== Paused
) {
300 m_rolesChangedDuringPausing
= true;
307 QSet
<QByteArray
> KFileItemModelRolesUpdater::roles() const
312 bool KFileItemModelRolesUpdater::isPaused() const
314 return m_state
== Paused
;
317 QStringList
KFileItemModelRolesUpdater::enabledPlugins() const
319 return m_enabledPlugins
;
322 void KFileItemModelRolesUpdater::slotItemsInserted(const KItemRangeList
& itemRanges
)
327 // Determine the sort role synchronously for as many items as possible.
328 if (m_resolvableRoles
.contains(m_model
->sortRole())) {
329 int insertedCount
= 0;
330 foreach (const KItemRange
& range
, itemRanges
) {
331 const int lastIndex
= insertedCount
+ range
.index
+ range
.count
- 1;
332 for (int i
= insertedCount
+ range
.index
; i
<= lastIndex
; ++i
) {
333 if (timer
.elapsed() < MaxBlockTimeout
) {
336 m_pendingSortRoleItems
.insert(m_model
->fileItem(i
));
339 insertedCount
+= range
.count
;
342 applySortProgressToModel();
344 // If there are still items whose sort role is unknown, check if the
345 // asynchronous determination of the sort role is already in progress,
346 // and start it if that is not the case.
347 if (!m_pendingSortRoleItems
.isEmpty() && m_state
!= ResolvingSortRole
) {
349 m_state
= ResolvingSortRole
;
350 resolveNextSortRole();
357 void KFileItemModelRolesUpdater::slotItemsRemoved(const KItemRangeList
& itemRanges
)
359 Q_UNUSED(itemRanges
);
361 const bool allItemsRemoved
= (m_model
->count() == 0);
364 if (m_balooFileMonitor
) {
365 // Don't let the FileWatcher watch for removed items
366 if (allItemsRemoved
) {
367 m_balooFileMonitor
->clear();
369 QStringList newFileList
;
370 foreach (const QString
& file
, m_balooFileMonitor
->files()) {
371 if (m_model
->index(QUrl::fromLocalFile(file
)) >= 0) {
372 newFileList
.append(file
);
375 m_balooFileMonitor
->setFiles(newFileList
);
380 if (allItemsRemoved
) {
383 m_finishedItems
.clear();
384 m_pendingSortRoleItems
.clear();
385 m_pendingIndexes
.clear();
386 m_pendingPreviewItems
.clear();
387 m_recentlyChangedItems
.clear();
388 m_recentlyChangedItemsTimer
->stop();
389 m_changedItems
.clear();
393 // Only remove the items from m_finishedItems. They will be removed
394 // from the other sets later on.
395 QSet
<KFileItem
>::iterator it
= m_finishedItems
.begin();
396 while (it
!= m_finishedItems
.end()) {
397 if (m_model
->index(*it
) < 0) {
398 it
= m_finishedItems
.erase(it
);
404 // The visible items might have changed.
409 void KFileItemModelRolesUpdater::slotItemsMoved(const KItemRange
& itemRange
, QList
<int> movedToIndexes
)
412 Q_UNUSED(movedToIndexes
);
414 // The visible items might have changed.
418 void KFileItemModelRolesUpdater::slotItemsChanged(const KItemRangeList
& itemRanges
,
419 const QSet
<QByteArray
>& roles
)
423 // Find out if slotItemsChanged() has been done recently. If that is the
424 // case, resolving the roles is postponed until a timer has exceeded
425 // to prevent expensive repeated updates if files are updated frequently.
426 const bool itemsChangedRecently
= m_recentlyChangedItemsTimer
->isActive();
428 QSet
<KFileItem
>& targetSet
= itemsChangedRecently
? m_recentlyChangedItems
: m_changedItems
;
430 foreach (const KItemRange
& itemRange
, itemRanges
) {
431 int index
= itemRange
.index
;
432 for (int count
= itemRange
.count
; count
> 0; --count
) {
433 const KFileItem item
= m_model
->fileItem(index
);
434 targetSet
.insert(item
);
439 m_recentlyChangedItemsTimer
->start();
441 if (!itemsChangedRecently
) {
442 updateChangedItems();
446 void KFileItemModelRolesUpdater::slotSortRoleChanged(const QByteArray
& current
,
447 const QByteArray
& previous
)
452 if (m_resolvableRoles
.contains(current
)) {
453 m_pendingSortRoleItems
.clear();
454 m_finishedItems
.clear();
456 const int count
= m_model
->count();
460 // Determine the sort role synchronously for as many items as possible.
461 for (int index
= 0; index
< count
; ++index
) {
462 if (timer
.elapsed() < MaxBlockTimeout
) {
463 applySortRole(index
);
465 m_pendingSortRoleItems
.insert(m_model
->fileItem(index
));
469 applySortProgressToModel();
471 if (!m_pendingSortRoleItems
.isEmpty()) {
472 // Trigger the asynchronous determination of the sort role.
474 m_state
= ResolvingSortRole
;
475 resolveNextSortRole();
479 m_pendingSortRoleItems
.clear();
480 applySortProgressToModel();
484 void KFileItemModelRolesUpdater::slotGotPreview(const KFileItem
& item
, const QPixmap
& pixmap
)
486 if (m_state
!= PreviewJobRunning
) {
490 m_changedItems
.remove(item
);
492 const int index
= m_model
->index(item
);
497 QPixmap scaledPixmap
= pixmap
;
499 const QString mimeType
= item
.mimetype();
500 const int slashIndex
= mimeType
.indexOf(QLatin1Char('/'));
501 const bool isFontPreview
= mimeType
.right(slashIndex
).contains(QLatin1String("font"));
502 const bool isFolderPreview
= item
.isDir();
503 const bool isWindowsExePreview
= mimeType
== QLatin1String("application/x-ms-dos-executable") ||
504 mimeType
== QLatin1String("application/x-msdownload");
506 if (!isFolderPreview
&& !isFontPreview
&& !isWindowsExePreview
) {
507 if (m_enlargeSmallPreviews
) {
508 KPixmapModifier::applyFrame(scaledPixmap
, m_iconSize
);
510 // Assure that small previews don't get enlarged. Instead they
511 // should be shown centered within the frame.
512 const QSize contentSize
= KPixmapModifier::sizeInsideFrame(m_iconSize
);
513 const bool enlargingRequired
= scaledPixmap
.width() < contentSize
.width() &&
514 scaledPixmap
.height() < contentSize
.height();
515 if (enlargingRequired
) {
516 QSize frameSize
= scaledPixmap
.size() / scaledPixmap
.devicePixelRatio();
517 frameSize
.scale(m_iconSize
, Qt::KeepAspectRatio
);
519 QPixmap
largeFrame(frameSize
);
520 largeFrame
.fill(Qt::transparent
);
522 KPixmapModifier::applyFrame(largeFrame
, frameSize
);
524 QPainter
painter(&largeFrame
);
525 painter
.drawPixmap((largeFrame
.width() - scaledPixmap
.width() / scaledPixmap
.devicePixelRatio()) / 2,
526 (largeFrame
.height() - scaledPixmap
.height() / scaledPixmap
.devicePixelRatio()) / 2,
528 scaledPixmap
= largeFrame
;
530 // The image must be shrinked as it is too large to fit into
531 // the available icon size
532 KPixmapModifier::applyFrame(scaledPixmap
, m_iconSize
);
536 KPixmapModifier::scale(scaledPixmap
, m_iconSize
);
539 QHash
<QByteArray
, QVariant
> data
= rolesData(item
);
541 const QStringList overlays
= data
["iconOverlays"].toStringList();
542 // Strangely KFileItem::overlays() returns empty string-values, so
543 // we need to check first whether an overlay must be drawn at all.
544 // It is more efficient to do it here, as KIconLoader::drawOverlays()
545 // assumes that an overlay will be drawn and has some additional
547 foreach (const QString
& overlay
, overlays
) {
548 if (!overlay
.isEmpty()) {
549 // There is at least one overlay, draw all overlays above m_pixmap
550 // and cancel the check
551 KIconLoader::global()->drawOverlays(overlays
, scaledPixmap
, KIconLoader::Desktop
);
556 data
.insert("iconPixmap", scaledPixmap
);
558 disconnect(m_model
, &KFileItemModel::itemsChanged
,
559 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
560 m_model
->setData(index
, data
);
561 connect(m_model
, &KFileItemModel::itemsChanged
,
562 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
564 m_finishedItems
.insert(item
);
567 void KFileItemModelRolesUpdater::slotPreviewFailed(const KFileItem
& item
)
569 if (m_state
!= PreviewJobRunning
) {
573 m_changedItems
.remove(item
);
575 const int index
= m_model
->index(item
);
577 QHash
<QByteArray
, QVariant
> data
;
578 data
.insert("iconPixmap", QPixmap());
580 disconnect(m_model
, &KFileItemModel::itemsChanged
,
581 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
582 m_model
->setData(index
, data
);
583 connect(m_model
, &KFileItemModel::itemsChanged
,
584 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
586 applyResolvedRoles(index
, ResolveAll
);
587 m_finishedItems
.insert(item
);
591 void KFileItemModelRolesUpdater::slotPreviewJobFinished()
593 m_previewJob
= nullptr;
595 if (m_state
!= PreviewJobRunning
) {
601 if (!m_pendingPreviewItems
.isEmpty()) {
604 if (!m_changedItems
.isEmpty()) {
605 updateChangedItems();
610 void KFileItemModelRolesUpdater::resolveNextSortRole()
612 if (m_state
!= ResolvingSortRole
) {
616 QSet
<KFileItem
>::iterator it
= m_pendingSortRoleItems
.begin();
617 while (it
!= m_pendingSortRoleItems
.end()) {
618 const KFileItem item
= *it
;
619 const int index
= m_model
->index(item
);
621 // Continue if the sort role has already been determined for the
622 // item, and the item has not been changed recently.
623 if (!m_changedItems
.contains(item
) && m_model
->data(index
).contains(m_model
->sortRole())) {
624 it
= m_pendingSortRoleItems
.erase(it
);
628 applySortRole(index
);
629 m_pendingSortRoleItems
.erase(it
);
633 if (!m_pendingSortRoleItems
.isEmpty()) {
634 applySortProgressToModel();
635 QTimer::singleShot(0, this, &KFileItemModelRolesUpdater::resolveNextSortRole
);
639 // Prevent that we try to update the items twice.
640 disconnect(m_model
, &KFileItemModel::itemsMoved
,
641 this, &KFileItemModelRolesUpdater::slotItemsMoved
);
642 applySortProgressToModel();
643 connect(m_model
, &KFileItemModel::itemsMoved
,
644 this, &KFileItemModelRolesUpdater::slotItemsMoved
);
649 void KFileItemModelRolesUpdater::resolveNextPendingRoles()
651 if (m_state
!= ResolvingAllRoles
) {
655 while (!m_pendingIndexes
.isEmpty()) {
656 const int index
= m_pendingIndexes
.takeFirst();
657 const KFileItem item
= m_model
->fileItem(index
);
659 if (m_finishedItems
.contains(item
)) {
663 applyResolvedRoles(index
, ResolveAll
);
664 m_finishedItems
.insert(item
);
665 m_changedItems
.remove(item
);
669 if (!m_pendingIndexes
.isEmpty()) {
670 QTimer::singleShot(0, this, &KFileItemModelRolesUpdater::resolveNextPendingRoles
);
674 if (m_clearPreviews
) {
675 // Only go through the list if there are items which might still have previews.
676 if (m_finishedItems
.count() != m_model
->count()) {
677 QHash
<QByteArray
, QVariant
> data
;
678 data
.insert("iconPixmap", QPixmap());
680 disconnect(m_model
, &KFileItemModel::itemsChanged
,
681 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
682 for (int index
= 0; index
<= m_model
->count(); ++index
) {
683 if (m_model
->data(index
).contains("iconPixmap")) {
684 m_model
->setData(index
, data
);
687 connect(m_model
, &KFileItemModel::itemsChanged
,
688 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
691 m_clearPreviews
= false;
694 if (!m_changedItems
.isEmpty()) {
695 updateChangedItems();
700 void KFileItemModelRolesUpdater::resolveRecentlyChangedItems()
702 m_changedItems
+= m_recentlyChangedItems
;
703 m_recentlyChangedItems
.clear();
704 updateChangedItems();
707 void KFileItemModelRolesUpdater::applyChangedBalooRoles(const QString
& file
)
710 const KFileItem item
= m_model
->fileItem(QUrl::fromLocalFile(file
));
713 // itemUrl is not in the model anymore, probably because
714 // the corresponding file has been deleted in the meantime.
717 applyChangedBalooRolesForItem(item
);
721 void KFileItemModelRolesUpdater::applyChangedBalooRolesForItem(const KFileItem
&item
)
724 Baloo::File
file(item
.localPath());
727 const KBalooRolesProvider
& rolesProvider
= KBalooRolesProvider::instance();
728 QHash
<QByteArray
, QVariant
> data
;
730 foreach (const QByteArray
& role
, rolesProvider
.roles()) {
731 // Overwrite all the role values with an empty QVariant, because the roles
732 // provider doesn't overwrite it when the property value list is empty.
734 data
.insert(role
, QVariant());
737 QHashIterator
<QByteArray
, QVariant
> it(rolesProvider
.roleValues(file
, m_roles
));
738 while (it
.hasNext()) {
740 data
.insert(it
.key(), it
.value());
743 disconnect(m_model
, &KFileItemModel::itemsChanged
,
744 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
745 const int index
= m_model
->index(item
);
746 m_model
->setData(index
, data
);
747 connect(m_model
, &KFileItemModel::itemsChanged
,
748 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
756 void KFileItemModelRolesUpdater::slotDirectoryContentsCountReceived(const QString
& path
, int count
)
758 const bool getSizeRole
= m_roles
.contains("size");
759 const bool getIsExpandableRole
= m_roles
.contains("isExpandable");
761 if (getSizeRole
|| getIsExpandableRole
) {
762 const int index
= m_model
->index(QUrl::fromLocalFile(path
));
764 QHash
<QByteArray
, QVariant
> data
;
767 data
.insert("size", count
);
769 if (getIsExpandableRole
) {
770 data
.insert("isExpandable", count
> 0);
773 disconnect(m_model
, &KFileItemModel::itemsChanged
,
774 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
775 m_model
->setData(index
, data
);
776 connect(m_model
, &KFileItemModel::itemsChanged
,
777 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
782 void KFileItemModelRolesUpdater::startUpdating()
784 if (m_state
== Paused
) {
788 if (m_finishedItems
.count() == m_model
->count()) {
789 // All roles have been resolved already.
794 // Terminate all updates that are currently active.
796 m_pendingIndexes
.clear();
801 // Determine the icons for the visible items synchronously.
802 updateVisibleIcons();
804 // A detailed update of the items in and near the visible area
805 // only makes sense if sorting is finished.
806 if (m_state
== ResolvingSortRole
) {
810 // Start the preview job or the asynchronous resolving of all roles.
811 QList
<int> indexes
= indexesToResolve();
813 if (m_previewShown
) {
814 m_pendingPreviewItems
.clear();
815 m_pendingPreviewItems
.reserve(indexes
.count());
817 foreach (int index
, indexes
) {
818 const KFileItem item
= m_model
->fileItem(index
);
819 if (!m_finishedItems
.contains(item
)) {
820 m_pendingPreviewItems
.append(item
);
826 m_pendingIndexes
= indexes
;
827 // Trigger the asynchronous resolving of all roles.
828 m_state
= ResolvingAllRoles
;
829 QTimer::singleShot(0, this, &KFileItemModelRolesUpdater::resolveNextPendingRoles
);
833 void KFileItemModelRolesUpdater::updateVisibleIcons()
835 int lastVisibleIndex
= m_lastVisibleIndex
;
836 if (lastVisibleIndex
<= 0) {
837 // Guess a reasonable value for the last visible index if the view
838 // has not told us about the real value yet.
839 lastVisibleIndex
= qMin(m_firstVisibleIndex
+ m_maximumVisibleItems
, m_model
->count() - 1);
840 if (lastVisibleIndex
<= 0) {
841 lastVisibleIndex
= qMin(200, m_model
->count() - 1);
848 // Try to determine the final icons for all visible items.
850 for (index
= m_firstVisibleIndex
; index
<= lastVisibleIndex
&& timer
.elapsed() < MaxBlockTimeout
; ++index
) {
851 applyResolvedRoles(index
, ResolveFast
);
854 // KFileItemListView::initializeItemListWidget(KItemListWidget*) will load
855 // preliminary icons (i.e., without mime type determination) for the
859 void KFileItemModelRolesUpdater::startPreviewJob()
861 m_state
= PreviewJobRunning
;
863 if (m_pendingPreviewItems
.isEmpty()) {
864 QTimer::singleShot(0, this, &KFileItemModelRolesUpdater::slotPreviewJobFinished
);
868 // PreviewJob internally caches items always with the size of
869 // 128 x 128 pixels or 256 x 256 pixels. A (slow) downscaling is done
870 // by PreviewJob if a smaller size is requested. For images KFileItemModelRolesUpdater must
871 // do a downscaling anyhow because of the frame, so in this case only the provided
872 // cache sizes are requested.
873 const QSize cacheSize
= (m_iconSize
.width() > 128) || (m_iconSize
.height() > 128)
874 ? QSize(256, 256) : QSize(128, 128);
876 // KIO::filePreview() will request the MIME-type of all passed items, which (in the
877 // worst case) might block the application for several seconds. To prevent such
878 // a blocking, we only pass items with known mime type to the preview job.
879 const int count
= m_pendingPreviewItems
.count();
880 KFileItemList itemSubSet
;
881 itemSubSet
.reserve(count
);
883 if (m_pendingPreviewItems
.first().isMimeTypeKnown()) {
884 // Some mime types are known already, probably because they were
885 // determined when loading the icons for the visible items. Start
886 // a preview job for all items at the beginning of the list which
887 // have a known mime type.
889 itemSubSet
.append(m_pendingPreviewItems
.takeFirst());
890 } while (!m_pendingPreviewItems
.isEmpty() && m_pendingPreviewItems
.first().isMimeTypeKnown());
892 // Determine mime types for MaxBlockTimeout ms, and start a preview
893 // job for the corresponding items.
898 const KFileItem item
= m_pendingPreviewItems
.takeFirst();
899 item
.determineMimeType();
900 itemSubSet
.append(item
);
901 } while (!m_pendingPreviewItems
.isEmpty() && timer
.elapsed() < MaxBlockTimeout
);
904 KIO::PreviewJob
* job
= new KIO::PreviewJob(itemSubSet
, cacheSize
, &m_enabledPlugins
);
906 job
->setIgnoreMaximumSize(itemSubSet
.first().isLocalFile());
907 if (job
->uiDelegate()) {
908 KJobWidgets::setWindow(job
, qApp
->activeWindow());
911 connect(job
, &KIO::PreviewJob::gotPreview
,
912 this, &KFileItemModelRolesUpdater::slotGotPreview
);
913 connect(job
, &KIO::PreviewJob::failed
,
914 this, &KFileItemModelRolesUpdater::slotPreviewFailed
);
915 connect(job
, &KIO::PreviewJob::finished
,
916 this, &KFileItemModelRolesUpdater::slotPreviewJobFinished
);
921 void KFileItemModelRolesUpdater::updateChangedItems()
923 if (m_state
== Paused
) {
927 if (m_changedItems
.isEmpty()) {
931 m_finishedItems
-= m_changedItems
;
933 if (m_resolvableRoles
.contains(m_model
->sortRole())) {
934 m_pendingSortRoleItems
+= m_changedItems
;
936 if (m_state
!= ResolvingSortRole
) {
937 // Stop the preview job if necessary, and trigger the
938 // asynchronous determination of the sort role.
940 m_state
= ResolvingSortRole
;
941 QTimer::singleShot(0, this, &KFileItemModelRolesUpdater::resolveNextSortRole
);
947 QList
<int> visibleChangedIndexes
;
948 QList
<int> invisibleChangedIndexes
;
950 foreach (const KFileItem
& item
, m_changedItems
) {
951 const int index
= m_model
->index(item
);
954 m_changedItems
.remove(item
);
958 if (index
>= m_firstVisibleIndex
&& index
<= m_lastVisibleIndex
) {
959 visibleChangedIndexes
.append(index
);
961 invisibleChangedIndexes
.append(index
);
965 std::sort(visibleChangedIndexes
.begin(), visibleChangedIndexes
.end());
967 if (m_previewShown
) {
968 foreach (int index
, visibleChangedIndexes
) {
969 m_pendingPreviewItems
.append(m_model
->fileItem(index
));
972 foreach (int index
, invisibleChangedIndexes
) {
973 m_pendingPreviewItems
.append(m_model
->fileItem(index
));
980 const bool resolvingInProgress
= !m_pendingIndexes
.isEmpty();
981 m_pendingIndexes
= visibleChangedIndexes
+ m_pendingIndexes
+ invisibleChangedIndexes
;
982 if (!resolvingInProgress
) {
983 // Trigger the asynchronous resolving of the changed roles.
984 m_state
= ResolvingAllRoles
;
985 QTimer::singleShot(0, this, &KFileItemModelRolesUpdater::resolveNextPendingRoles
);
990 void KFileItemModelRolesUpdater::applySortRole(int index
)
992 QHash
<QByteArray
, QVariant
> data
;
993 const KFileItem item
= m_model
->fileItem(index
);
995 if (m_model
->sortRole() == "type") {
996 if (!item
.isMimeTypeKnown()) {
997 item
.determineMimeType();
1000 data
.insert("type", item
.mimeComment());
1001 } else if (m_model
->sortRole() == "size" && item
.isLocalFile() && item
.isDir()) {
1002 const QString path
= item
.localPath();
1003 data
.insert("size", m_directoryContentsCounter
->countDirectoryContentsSynchronously(path
));
1005 // Probably the sort role is a baloo role - just determine all roles.
1006 data
= rolesData(item
);
1009 disconnect(m_model
, &KFileItemModel::itemsChanged
,
1010 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
1011 m_model
->setData(index
, data
);
1012 connect(m_model
, &KFileItemModel::itemsChanged
,
1013 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
1016 void KFileItemModelRolesUpdater::applySortProgressToModel()
1018 // Inform the model about the progress of the resolved items,
1019 // so that it can give an indication when the sorting has been finished.
1020 const int resolvedCount
= m_model
->count() - m_pendingSortRoleItems
.count();
1021 m_model
->emitSortProgress(resolvedCount
);
1024 bool KFileItemModelRolesUpdater::applyResolvedRoles(int index
, ResolveHint hint
)
1026 const KFileItem item
= m_model
->fileItem(index
);
1027 const bool resolveAll
= (hint
== ResolveAll
);
1029 bool iconChanged
= false;
1030 if (!item
.isMimeTypeKnown() || !item
.isFinalIconKnown()) {
1031 item
.determineMimeType();
1033 } else if (!m_model
->data(index
).contains("iconName")) {
1037 if (iconChanged
|| resolveAll
|| m_clearPreviews
) {
1042 QHash
<QByteArray
, QVariant
> data
;
1044 data
= rolesData(item
);
1047 data
.insert("iconName", item
.iconName());
1049 if (m_clearPreviews
) {
1050 data
.insert("iconPixmap", QPixmap());
1053 disconnect(m_model
, &KFileItemModel::itemsChanged
,
1054 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
1055 m_model
->setData(index
, data
);
1056 connect(m_model
, &KFileItemModel::itemsChanged
,
1057 this, &KFileItemModelRolesUpdater::slotItemsChanged
);
1064 QHash
<QByteArray
, QVariant
> KFileItemModelRolesUpdater::rolesData(const KFileItem
& item
)
1066 QHash
<QByteArray
, QVariant
> data
;
1068 const bool getSizeRole
= m_roles
.contains("size");
1069 const bool getIsExpandableRole
= m_roles
.contains("isExpandable");
1071 if ((getSizeRole
|| getIsExpandableRole
) && item
.isDir()) {
1072 if (item
.isLocalFile()) {
1073 // Tell m_directoryContentsCounter that we want to count the items
1074 // inside the directory. The result will be received in slotDirectoryContentsCountReceived.
1075 const QString path
= item
.localPath();
1076 m_directoryContentsCounter
->addDirectory(path
);
1077 } else if (getSizeRole
) {
1078 data
.insert("size", -1); // -1 indicates an unknown number of items
1082 if (m_roles
.contains("type")) {
1083 data
.insert("type", item
.mimeComment());
1086 QStringList overlays
= item
.overlays();
1087 foreach(KOverlayIconPlugin
*it
, m_overlayIconsPlugin
) {
1088 overlays
.append(it
->getOverlays(item
.url()));
1090 data
.insert("iconOverlays", overlays
);
1093 if (m_balooFileMonitor
) {
1094 m_balooFileMonitor
->addFile(item
.localPath());
1095 applyChangedBalooRolesForItem(item
);
1101 void KFileItemModelRolesUpdater::slotOverlaysChanged(const QUrl
& url
, const QStringList
&)
1103 const KFileItem item
= m_model
->fileItem(url
);
1104 if (item
.isNull()) {
1107 const int index
= m_model
->index(item
);
1108 QHash
<QByteArray
, QVariant
> data
= m_model
->data(index
);
1109 QStringList overlays
= item
.overlays();
1110 foreach (KOverlayIconPlugin
*it
, m_overlayIconsPlugin
) {
1111 overlays
.append(it
->getOverlays(url
));
1113 data
.insert("iconOverlays", overlays
);
1114 m_model
->setData(index
, data
);
1117 void KFileItemModelRolesUpdater::updateAllPreviews()
1119 if (m_state
== Paused
) {
1120 m_previewChangedDuringPausing
= true;
1122 m_finishedItems
.clear();
1127 void KFileItemModelRolesUpdater::killPreviewJob()
1130 disconnect(m_previewJob
, &KIO::PreviewJob::gotPreview
,
1131 this, &KFileItemModelRolesUpdater::slotGotPreview
);
1132 disconnect(m_previewJob
, &KIO::PreviewJob::failed
,
1133 this, &KFileItemModelRolesUpdater::slotPreviewFailed
);
1134 disconnect(m_previewJob
, &KIO::PreviewJob::finished
,
1135 this, &KFileItemModelRolesUpdater::slotPreviewJobFinished
);
1136 m_previewJob
->kill();
1137 m_previewJob
= nullptr;
1138 m_pendingPreviewItems
.clear();
1142 QList
<int> KFileItemModelRolesUpdater::indexesToResolve() const
1144 const int count
= m_model
->count();
1147 result
.reserve(ResolveAllItemsLimit
);
1149 // Add visible items.
1150 for (int i
= m_firstVisibleIndex
; i
<= m_lastVisibleIndex
; ++i
) {
1154 // We need a reasonable upper limit for number of items to resolve after
1155 // and before the visible range. m_maximumVisibleItems can be quite large
1156 // when using Compace View.
1157 const int readAheadItems
= qMin(ReadAheadPages
* m_maximumVisibleItems
, ResolveAllItemsLimit
/ 2);
1159 // Add items after the visible range.
1160 const int endExtendedVisibleRange
= qMin(m_lastVisibleIndex
+ readAheadItems
, count
- 1);
1161 for (int i
= m_lastVisibleIndex
+ 1; i
<= endExtendedVisibleRange
; ++i
) {
1165 // Add items before the visible range in reverse order.
1166 const int beginExtendedVisibleRange
= qMax(0, m_firstVisibleIndex
- readAheadItems
);
1167 for (int i
= m_firstVisibleIndex
- 1; i
>= beginExtendedVisibleRange
; --i
) {
1171 // Add items on the last page.
1172 const int beginLastPage
= qMax(qMin(endExtendedVisibleRange
+ 1, count
- 1), count
- m_maximumVisibleItems
);
1173 for (int i
= beginLastPage
; i
< count
; ++i
) {
1177 // Add items on the first page.
1178 const int endFirstPage
= qMin(qMax(beginExtendedVisibleRange
- 1, 0), m_maximumVisibleItems
);
1179 for (int i
= 0; i
<= endFirstPage
; ++i
) {
1183 // Continue adding items until ResolveAllItemsLimit is reached.
1184 int remainingItems
= ResolveAllItemsLimit
- result
.count();
1186 for (int i
= endExtendedVisibleRange
+ 1; i
< beginLastPage
&& remainingItems
> 0; ++i
) {
1191 for (int i
= beginExtendedVisibleRange
- 1; i
> endFirstPage
&& remainingItems
> 0; --i
) {