File indexing completed on 2024-04-28 17:06:21

 /*
     SPDX-FileCopyrightText: 2009 Jan Lepper <krusader@users.sourceforge.net>
     SPDX-FileCopyrightText: 2009-2022 Krusader Krew <https://krusader.org>
 
     SPDX-License-Identifier: GPL-2.0-or-later
 */
 
 #include "krpreviewjob.h"
 
 #include "../FileSystem/fileitem.h"
 #include "../defaults.h"
 #include "PanelView/krview.h"
 #include "PanelView/krviewitem.h"
 #include "krpreviews.h"
 
 #include <stdio.h>
 
 // QtWidgets
 #include <QWidget>
 
 #define ASSERT(what)                                                                                                                                           \
     if (!(what))                                                                                                                                               \
         abort();
 
 // how much items to process by a single job
 // view becomes unresponsive during load if set too high
 #define MAX_CHUNK_SIZE 50
 
 KrPreviewJob::KrPreviewJob(KrPreviews *parent)
     : _job(nullptr)
     , _parent(parent)
 {
     _timer.setSingleShot(true);
     _timer.setInterval(0);
     connect(&_timer, &QTimer::timeout, this, &KrPreviewJob::slotStartJob);
 }
 
 KrPreviewJob::~KrPreviewJob()
 {
     doKill();
 }
 
 void KrPreviewJob::scheduleItem(KrViewItem *item)
 {
     if (!_scheduled.contains(item)) {
         _scheduled.append(item);
         setTotalAmount(KJob::Files, totalAmount(KJob::Files) + 1);
     }
     if (!_job)
         _timer.start();
 }
 
 void KrPreviewJob::removeItem(KrViewItem *item)
 {
     setTotalAmount(KJob::Files, totalAmount(KJob::Files) - _scheduled.removeAll(item));
     if (_job) {
         doKill();
         if (!_scheduled.isEmpty())
             _timer.start();
     }
     if (_scheduled.isEmpty())
         emitResult();
 }
 
 void KrPreviewJob::slotFailed(const KFileItem &item)
 {
     slotGotPreview(item, QPixmap());
 }
 
 void KrPreviewJob::slotGotPreview(const KFileItem &item, const QPixmap &preview)
 {
     KrViewItem *vi = _hash[item];
     ASSERT(vi);
 
     _scheduled.removeOne(vi);
 
     const FileItem *file = vi->getFileItem();
     _parent->addPreview(file, preview);
     vi->redraw();
 
     setProcessedAmount(KJob::Files, processedAmount(KJob::Files) + 1);
     emitPercent(processedAmount(KJob::Files), totalAmount(KJob::Files));
 }
 
 void KrPreviewJob::slotStartJob()
 {
     ASSERT(_job == nullptr);
     ASSERT(!_scheduled.isEmpty());
 
     _hash.clear();
     sort();
 
     int size = _parent->_view->fileIconSize();
 
     KFileItemList list;
     for (int i = 0; i < _scheduled.count() && i < MAX_CHUNK_SIZE; i++) {
         KFileItem fi(_scheduled[i]->getFileItem()->getUrl(), nullptr, 0);
         list.append(fi);
         _hash.insert(fi, _scheduled[i]);
     }
     QStringList allPlugins = KIO::PreviewJob::availablePlugins();
     _job = new KIO::PreviewJob(list, QSize(size, size), &allPlugins);
     _job->setOverlayIconAlpha(0);
     _job->setOverlayIconSize(0);
     _job->setScaleType(KIO::PreviewJob::ScaledAndCached);
     connect(_job, &KIO::PreviewJob::gotPreview, this, &KrPreviewJob::slotGotPreview);
     connect(_job, &KIO::PreviewJob::failed, this, &KrPreviewJob::slotFailed);
     connect(_job, &KIO::PreviewJob::result, this, &KrPreviewJob::slotJobResult);
 }
 
 void KrPreviewJob::slotJobResult(KJob *job)
 {
     (void)job;
 
     if (!disconnect(_job, nullptr, this, nullptr))
         abort();
 
     _job = nullptr;
     _hash.clear();
 
     if (_scheduled.isEmpty())
         emitResult();
     else
         _timer.start();
 }
 
 // move currently visible items to beginning of the list
 void KrPreviewJob::sort()
 {
     for (int i = 0, visible_end = 0; i < _scheduled.count(); i++) {
         KrViewItem *item = _scheduled[i];
         if (_parent->_view->widget()->rect().intersects(item->itemRect())) {
             if (i != visible_end)
                 _scheduled.move(i, visible_end);
             visible_end++;
         }
     }
 }
 
 bool KrPreviewJob::doKill()
 {
     _timer.stop();
     if (_job) {
         if (!disconnect(_job, nullptr, this, nullptr))
             abort();
         if (!_job->kill())
             abort();
         _job = nullptr;
     }
     _hash.clear();
     return true;
 }