preprocessormanager.h

/******************************************************************************
 *
 *  File : preprocessormanager.h
 *  Creation date : Sat 18 Jul 2009 01:58:50
 *
 *  SPDX-FileCopyrightText: 2009 Szymon Stefanek <s.stefanek at gmail dot com>
 *
 *  SPDX-License-Identifier: LGPL-2.0-or-later
 *
 *****************************************************************************/

#ifndef AKONADI_PREPROCESSORMANAGER_H
#define AKONADI_PREPROCESSORMANAGER_H

#include <QObject>
#include <QList>
#include <QHash>
#include <QMutex>

#include <deque>

class QTimer;

#include "preprocessorinstance.h"

namespace Akonadi
{
namespace Server
{

class PimItem;
class DataStore;
class Tracer;

class PreprocessorManager : public QObject
{
    friend class PreprocessorInstance;

    Q_OBJECT
    Q_CLASSINFO("D-Bus Interface", "org.freedesktop.Akonadi.PreprocessorManager")

protected:
    QHash< const DataStore *, std::deque< qint64 > *> mTransactionWaitQueueHash;

    QList< PreprocessorInstance *> mPreprocessorChain;

    bool mEnabled = false;

    QMutex mMutex;

    QTimer *mHeartbeatTimer = nullptr;


    Tracer &mTracer;
public:
    explicit PreprocessorManager(Tracer &tracer);

    ~PreprocessorManager();

    bool isActive();

    bool isEnabled() const
    {
        return mEnabled;
    }

    void setEnabled(bool enabled)
    {
        mEnabled = enabled;
    }

    void beginHandleItem(const PimItem &item, const DataStore *dataStore);

    void registerInstance(const QString &id);

    void unregisterInstance(const QString &id);

protected:

    void preProcessorFinishedHandlingItem(PreprocessorInstance *preProcessor, qint64 itemId);

private:

    PreprocessorInstance *lockedFindInstance(const QString &id);

    void lockedActivateFirstPreprocessor(qint64 itemId);

    void lockedEndHandleItem(qint64 itemId);

    void lockedUnregisterInstance(const QString &id);

    void lockedKillWaitQueue(const DataStore *dataStore, bool disconnectSlots);

private Q_SLOTS:

    void heartbeat();

    void dataStoreDestroyed();

    void dataStoreTransactionCommitted();

    void dataStoreTransactionRolledBack();

}; // class PreprocessorManager

} // namespace Server
} // namespace Akonadi

#endif