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

 /*
     This file is part of the KDE Baloo Project
     SPDX-FileCopyrightText: 2021 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
 */
 
 #ifndef COMMANDPIPE_H
 #define COMMANDPIPE_H
 
 #include <QDataStream>
 #include <QObject>
 
 class QIODevice;
 
 namespace Baloo {
 namespace Private {
 
 /**
  * Bidirectional communication pipe
  *
  */
 class ControllerPipe : public QObject
 {
     Q_OBJECT
 
 public:
     ControllerPipe(QIODevice* commandPipe, QIODevice* statusPipe);
 
     void processIds(const QVector<quint64>& ids);
 
 Q_SIGNALS:
     void urlStarted(const QString& url);
     void urlFinished(const QString& url);
     void urlFailed(const QString& url);
     void batchFinished();
 
 public Q_SLOTS:
     void processStatusData();
 
 private:
     QDataStream m_commandStream;
     QDataStream m_statusStream;
 };
 
 class WorkerPipe : public QObject
 {
     Q_OBJECT
 
 public:
     WorkerPipe(QIODevice* commandPipe, QIODevice* statusPipe);
 
     void urlStarted(const QString& url);
     void urlFinished(const QString& url);
     void urlFailed(const QString& url);
     void batchFinished();
 
 public Q_SLOTS:
     void processIdData();
 
 Q_SIGNALS:
     void newDocumentIds(const QVector<quint64>& ids);
     void inputEnd();
 
 private:
     QDataStream m_commandStream;
     QDataStream m_statusStream;
 };
 
 } // namespace Private
 } // namespace Baloo
 #endif