MediatorServer.hpp

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

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

#include <samchon/protocol/ClientDriver.hpp>

namespace samchon
{
namespace templates
{
namespace parallel
{
    class MediatorServer
        : public MediatorSystem,
        public virtual protocol::Server
    {
    private:
        typedef MediatorSystem super;

        int port_;

    public:
        MediatorServer(external::base::ExternalSystemArrayBase *system_array, int port)
            : super(system_array),
            protocol::Server()
        {
            this->port_ = port;
        };
        virtual ~MediatorServer() = default;

        virtual void start() override
        {
            open(port_);
        };

    protected:
        virtual void addClient(std::shared_ptr<protocol::ClientDriver> driver) override
        {
            this->communicator_ = driver;
            driver->listen(this);
        };
    };
};
};
};