mna_graph_executor.h

Go to the documentation of this file.

//=============================================================================================================
 
#ifndef MNA_GRAPH_EXECUTOR_H
#define MNA_GRAPH_EXECUTOR_H
 
//=============================================================================================================
// INCLUDES
//=============================================================================================================
 
#include "mna_global.h"
#include "mna_node.h"
 
//=============================================================================================================
// QT INCLUDES
//=============================================================================================================
 
#include <QString>
#include <QMap>
#include <QVariant>
#include <QVariantMap>
#include <QObject>
#include <functional>
 
//=============================================================================================================
// FORWARD DECLARATIONS
//=============================================================================================================
 
namespace MNALIB
{
class MnaGraph;
}
 
//=============================================================================================================
// DEFINE NAMESPACE MNALIB
//=============================================================================================================
 
namespace MNALIB
{
 
//=============================================================================================================
class MNASHARED_EXPORT MnaGraphExecutor
{
public:
    struct Context
    {
        QMap<QString, QVariant> results;

        QVariantMap graphInputs;
    };
 
    //=========================================================================================================
    struct StreamContext
    {
        MnaGraph*                  graph = nullptr;         
        QMap<QString, QObject*>    livePlugins;             
        bool                       running = false;         
        QStringList                executionOrder;          
    };

    static Context execute(MnaGraph& graph, const QVariantMap& graphInputs);

    static Context executeIncremental(MnaGraph& graph, Context& existing);

    static QVariantMap executeNode(const MnaNode& node,
                                    const QVariantMap& inputs);

    using ProgressCallback = std::function<void(const QString& nodeId,
                                                 int current, int total)>;

    static void setProgressCallback(ProgressCallback cb);
 
    //=========================================================================================================
    // Stream-mode execution
    //=========================================================================================================

    using PluginFactory = std::function<QObject*(const QString& opType)>;

    static StreamContext startStream(MnaGraph& graph, PluginFactory factory);

    static void stopStream(StreamContext& ctx);
 
private:
    static ProgressCallback s_progressCallback;
};
 
} // namespace MNALIB
 
#endif // MNA_GRAPH_EXECUTOR_H