ParallelSystemArrayMediator.hpp

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

#include <samchon/templates/parallel/ParallelSystemArray.hpp>
#include <samchon/templates/parallel/MediatorSystem.hpp>

namespace samchon
{
namespace templates
{
namespace parallel
{
    template <class System = ParallelSystem>
    class ParallelSystemArrayMediator
        : public virtual ParallelSystemArray<System>
    {
    private:
        typedef ParallelSystemArray<System> super;

        std::unique_ptr<MediatorSystem> mediator_;

    public:
        /* ---------------------------------------------------------
            CONSTRUCTORS
        --------------------------------------------------------- */
        ParallelSystemArrayMediator()
            : super()
        {
        };
        virtual ~ParallelSystemArrayMediator() = default;

    protected:
        virtual auto createMediator() -> MediatorSystem* = 0;

        virtual void startMediator()
        {
            if (mediator_ != nullptr)
                return;

            mediator_.reset(createMediator());
            mediator_->start();
        };

    public:
        /* ---------------------------------------------------------
            ACCESSORS
        --------------------------------------------------------- */
        auto getMediator() const -> MediatorSystem*
        {
            return mediator_.get();
        };

    protected:
        /* ---------------------------------------------------------
            HISTORY HANDLER
        --------------------------------------------------------- */
        virtual auto _Complete_history(std::shared_ptr<slave::InvokeHistory> history) -> bool override
        {
            bool ret = super::_Complete_history(history);
            if (ret == true)
                mediator_->_Complete_history(history->getUID());

            return ret;
        };
    };
};
};
};