preprocessormanager.h

/******************************************************************************
 *
 *  File : preprocessormanager.h
 *  Creation date : Sat 18 Jul 2009 01:58:50
 *
 *  Copyright (c) 2009 Szymon Stefanek <s.stefanek at gmail dot com>
 *
 *  This library is free software; you can redistribute it and/or modify it
 *  under the terms of the GNU Library General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or (at your
 *  option) any later version.
 *
 *  This library 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 Library General Public
 *  License for more details.
 *
 *  You should have received a copy of the GNU Library General Public License
 *  along with this library; see the file COPYING.LIB.  If not, write to the
 *  Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
 *  MA, 02110-1301, USA.
 *
 *****************************************************************************/

#ifndef AKONADI_PREPROCESSORMANAGER_H
#define AKONADI_PREPROCESSORMANAGER_H

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

#include <deque>

class QTimer;
class QMutex;

#include "preprocessorinstance.h"

namespace Akonadi
{
namespace Server
{

class PimItem;
class DataStore;

class PreprocessorManager : public QObject
{
    friend class PreprocessorInstance;

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

protected:

    PreprocessorManager();

    ~PreprocessorManager();

protected:

    static PreprocessorManager *mSelf;

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

    QList< PreprocessorInstance *> mPreprocessorChain;

    bool mEnabled;

    QMutex *mMutex = nullptr;

    QTimer *mHeartbeatTimer = nullptr;

public:

    static PreprocessorManager *instance()
    {
        return mSelf;
    }

    static bool init();

    static void done();

    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