File indexing completed on 2024-04-28 03:51:40

 /*
     This file is part of the KDE Baloo Project
     SPDX-FileCopyrightText: 2023 Stefan Brüns <stefan.bruens@rwth-aachen.de>
 
     SPDX-License-Identifier: LGPL-2.1-only OR LGPL-3.0-only OR LicenseRef-KDE-Accepted-LGPL
 */
 
 #include <KCrash>
 #include <QCoreApplication>
 #include <QFile>
 #include <QSocketNotifier>
 #include <QTimer>
 
 #include "baloodebug.h"
 #include "extractor/commandpipe.h"
 
 #include <signal.h>
 #include <sys/resource.h>
 #include <unistd.h> //for STDIN_FILENO
 
 int main(int argc, char* argv[])
 {
     using Baloo::Private::WorkerPipe;
 
     // Disable writing core dumps, we may crash on purpose
     struct rlimit corelimit{0, 0};
     setrlimit(RLIMIT_CORE, &corelimit);
     // DrKonqi blocks the signal and causes timeout of the QSignalSpy
     KCrash::setDrKonqiEnabled(false);
     QCoreApplication app(argc, argv);
 
     QFile input;
     input.open(STDIN_FILENO, QIODevice::ReadOnly | QIODevice::Unbuffered);
     QSocketNotifier inputNotifier(STDIN_FILENO, QSocketNotifier::Read);
 
     QFile output;
     output.open(STDOUT_FILENO, QIODevice::WriteOnly | QIODevice::Unbuffered);
 
     WorkerPipe worker(&input, &output);
     QObject::connect(&inputNotifier, &QSocketNotifier::activated,
                      &worker, &WorkerPipe::processIdData);
 
     QObject::connect(&worker, &WorkerPipe::inputEnd, &QCoreApplication::quit);
     QObject::connect(&worker, &WorkerPipe::newDocumentIds,
         [&worker](const QVector<quint64>& ids) {
             QTimer::singleShot(0, [&worker, ids]() {
                 qCInfo(BALOO) << "Processing ...";
 
                 for(auto id : ids) {
                     worker.urlStarted(QString::number(id));
 
             if (id == 0) {
               raise(SIGSEGV);
             } else if (id == 1) {
               exit(1);
             } else if (id == 2) {
               exit(2);
             } else if (id < 100) {
                         worker.urlFailed(QString::number(id));
             } else {
                         worker.urlFinished(QString::number(id));
             }
                 }
                 worker.batchFinished();
                 qCInfo(BALOO) << "Processing done";
             });
         });
 
     return app.exec();
 }