/* * Copyright (C) 2021, KylinSoft Co., Ltd. * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . * * Authors: zhangpengfei * */ #include "pending-file-queue.h" #include "file-utils.h" #include #include "index-status-recorder.h" #include "remote-file-event-helper.h" using namespace UkuiSearch; static PendingFileQueue *global_instance_pending_file_queue = nullptr; PendingFileQueue::PendingFileQueue(QObject *parent) : QThread(parent) { this->start(); m_cacheTimer = new QTimer; m_minProcessTimer = new QTimer; m_cacheTimer->setInterval(10*1000); m_cacheTimer->setSingleShot(true); m_minProcessTimer->setInterval(500); m_minProcessTimer->setSingleShot(true); m_cacheTimer->moveToThread(this); m_minProcessTimer->moveToThread(this); m_fileEventHelper = new RemoteFileEventHelper; m_fileEventHelper->moveToThread(this); // connect(this, &PendingFileQueue::cacheTimerStart, m_cacheTimer, f, Qt::DirectConnection); // connect(this, &PendingFileQueue::minProcessTimerStart, m_minProcessTimer, f,Qt::DirectConnection); connect(this, SIGNAL(cacheTimerStart()), m_cacheTimer, SLOT(start())); connect(this, SIGNAL(minProcessTimerStart()), m_minProcessTimer, SLOT(start())); connect(this, &PendingFileQueue::timerStop, m_cacheTimer, &QTimer::stop); connect(this, &PendingFileQueue::timerStop, m_minProcessTimer, &QTimer::stop); connect(m_cacheTimer, &QTimer::timeout, this, &PendingFileQueue::processCache, Qt::DirectConnection); connect(m_minProcessTimer, &QTimer::timeout, this, &PendingFileQueue::processCache, Qt::DirectConnection); connect(this, &PendingFileQueue::signalFileEvent, m_fileEventHelper, &RemoteFileEventHelper::handleFileEventRequest); } PendingFileQueue *PendingFileQueue::getInstance(QObject *parent) { if (!global_instance_pending_file_queue) { global_instance_pending_file_queue = new PendingFileQueue(parent); } return global_instance_pending_file_queue; } PendingFileQueue::~PendingFileQueue() { if(m_cacheTimer) { delete m_cacheTimer; m_cacheTimer = nullptr; } if(m_minProcessTimer) { delete m_minProcessTimer; m_minProcessTimer = nullptr; } if(m_fileEventHelper) { delete m_fileEventHelper; m_fileEventHelper = nullptr; } global_instance_pending_file_queue = nullptr; } void PendingFileQueue::forceFinish() { Q_EMIT timerStop(); this->quit(); this->wait(); processCache(); } void PendingFileQueue::enqueue(const PendingFile &file) { // qDebug() << "enqueuq file: " << file.path(); m_mutex.lock(); m_enqueuetimes++; // Remove all indexs of files under a dir which is to about be deleted,but keep delete signals. // Because our datebase need to delete those indexs one by one. if(file.shouldRemoveIndex() && file.isDir()) { const auto keepFile = [&file](const PendingFile& pending) { return (!FileUtils::isOrUnder(pending.path(), file.path()) || pending.shouldRemoveIndex()); }; const auto end = m_cache.end(); const auto droppedFilesBegin = std::stable_partition(m_cache.begin(), end, keepFile); m_cache.erase(droppedFilesBegin, end); } if(file.shouldRemoveIndex()) { m_cache.removeOne(file); } int i = m_cache.indexOf(file); if (i == -1) { // qDebug() << "insert file" << file.path() << file.shouldRemoveIndex(); m_cache << file; } else { // qDebug() << "merge file" << file.path() << file.shouldRemoveIndex(); m_cache[i].merge(file); } if(!m_cacheTimer->isActive()) { // qDebug()<<"m_cacheTimer-----start!!"; Q_EMIT cacheTimerStart(); } Q_EMIT minProcessTimerStart(); // m_minProcessTimer->start(); // qDebug()<<"m_minProcessTimer-----start!!"; m_mutex.unlock(); // qDebug() << "Current cache-------------"; // for(PendingFile i : m_cache) { // qDebug() << "|" << i.path(); // qDebug() << "|" < pendingFiles; m_mutex.lock(); m_cache.swap(pendingFiles); m_mutex.unlock(); qDebug() << pendingFiles.size() << "Events need be processed"; if(!pendingFiles.isEmpty()) { Q_EMIT filesUpdate(pendingFiles); } else { qDebug()<< "Empty, PendingFileQueue finish processCache!"; } return; }