ParallelSystem.hpp

#pragma once
#include <samchon/API.hpp>

#include <samchon/protocol/ExternalSystem.hpp>
#include <mutex>

namespace samchon
{
namespace protocol
{
namespace master
{
    class ParallelSystemArray;

    class PRInvokeHistoryArray;
    class PRMasterHistory;

    class SAMCHON_FRAMEWORK_API ParallelSystem
        : public virtual ExternalSystem
    {
        friend class ParallelSystemArray;
        friend class PRMasterHistory;

    protected:
        typedef ExternalSystem super;

        ParallelSystemArray *systemArray;

        PRInvokeHistoryArray *historyArray;

        PRInvokeHistoryArray *progressArray;

        double performance;

    public:
        /* ------------------------------------------------------------------
            CONSTRUCTORS
        ------------------------------------------------------------------ */
        ParallelSystem();
        virtual ~ParallelSystem();

        virtual void construct(std::shared_ptr<library::XML>) override;


    protected:
        virtual auto createChild(std::shared_ptr<library::XML>)->ExternalSystemRole* override;

        /* ------------------------------------------------------------------
            CHAIN OF INVOKE MESSAGE
        ------------------------------------------------------------------ */
        virtual void _replyData(std::shared_ptr<Invoke>) override;

    private:
        void sendPieceData(PRMasterHistory*, std::shared_ptr<Invoke>, size_t, size_t);

        /* ------------------------------------------------------------------
            EXPORTERS
        ------------------------------------------------------------------ */
    public:
        virtual auto toXML() const->std::shared_ptr<library::XML> override;
    };
};
};
};