MediatorClient.hpp

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

#include <samchon/templates/parallel/MediatorSystem.hpp>
#include <samchon/protocol/ServerConnector.hpp>

namespace samchon
{
namespace templates
{
namespace parallel
{
    class MediatorClient
        : public MediatorSystem
    {
    private:
        typedef MediatorSystem super;

    protected:
        std::string ip_;
        int port_;

    public:
        /* ---------------------------------------------------------
            CONSTRUCTORS
        --------------------------------------------------------- */
        MediatorClient(external::base::ExternalSystemArrayBase *system_array_, const std::string &ip, int port)
            : super(system_array_)
        {
            this->ip_ = ip;
            this->port_ = port;
        };
        virtual ~MediatorClient() = default;

    protected:
        virtual auto createServerConnector() -> protocol::ServerConnector*
        {
            return new protocol::ServerConnector(this);
        };

    public:
        /* ---------------------------------------------------------
            METHOD OF CONNECTOR
        --------------------------------------------------------- */
        virtual void start() override
        {
            if (communicator_ != nullptr)
                return;

            protocol::ServerConnector *connector = createServerConnector();
            communicator_.reset(connector);
            
            connector->connect(ip_, port_);
        };
    };
};
};
};