Slave.hpp

#pragma once
#include <samchon/protocol/slave/ParallelClient.hpp>

#include <samchon/protocol/Invoke.hpp>
#include <iostream>

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

    using namespace library;
    using namespace protocol;

    class Slave
        : public protocol::slave::ParallelClient
    {
    private:
        typedef protocol::slave::ParallelClient super;

    public:
        /* ------------------------------------------------------------
            CONSTRUCTORS
        ------------------------------------------------------------ */
        Slave(const string &ip, int port)
            : super()
        {
            this->ip = ip;
            this->port = port;
        };
        virtual ~Slave() = default;

        /* ------------------------------------------------------------
            INVOKE MESSAGE CHAIN
        ------------------------------------------------------------ */
        virtual void replyPieceData(shared_ptr<Invoke> invoke, size_t index, size_t size) override
        {
            if (invoke->getListener() == "optimize")
                optimize
                (
                    invoke->at(0)->getValueAsXML(),
                    index,
                    size
                );
        };

    protected:
        virtual void optimize(shared_ptr<XML> xml, size_t index, size_t size)
        {
            cout << "----------------------------------------------------------------------------" << endl;
            cout << "   OPTIMIZE FROM " << index << ", SIZE: " << size << endl;
            cout << "----------------------------------------------------------------------------" << endl;
        };

        void sendOptimization(shared_ptr<XML> xml)
        {
            sendData( make_shared<Invoke>("replyOptimization", xml) );
        };
    };          
};
};
};