ChiefDriver.hpp

#pragma once
#include <samchon/protocol/IServer.hpp>
#include <samchon/protocol/IClient.hpp>

#include <samchon/protocol/Invoke.hpp>

#include <mutex>

namespace samchon
{
namespace example
{
namespace interaction
{
    using namespace std;

    using namespace library;
    using namespace protocol;

    class ChiefDriver
        : public IServer,
        public IClient
    {
    private:
        typedef IServer super;

    protected:
        IProtocol *master;

        int port;

        mutex mtx;

    public:
        ChiefDriver(IProtocol *master, int port)
            : super(),
            IClient()
        {
            this->master = master;
            this->port = port;
        };
        virtual ~ChiefDriver() = default;

        virtual void addClient(Socket *socket) override
        {
            unique_lock<mutex> uk(mtx);

            this->socket = socket;
            listen();
        };

        virtual void replyData(shared_ptr<Invoke> invoke) override
        {
            master->replyData(invoke);
        };

    protected:
        virtual auto PORT() const -> int override
        {
            return port;
        };
    };          
};
};
};