ParallelSystemArray.hpp

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

#include <samchon/protocol/ExternalSystemArray.hpp>

#include <atomic>

namespace samchon
{
namespace protocol
{
namespace master
{
    class ParallelSystem;

    class PRMasterHistoryArray;
    class PRMasterHistory;

    class SAMCHON_FRAMEWORK_API ParallelSystemArray
        : public virtual ExternalSystemArray
    {
        friend class ParallelSystem;
        friend class PRMasterHistory;

    private:
        typedef ExternalSystemArray super;

        std::atomic<size_t> uid;

        PRMasterHistoryArray *historyArray;

        PRMasterHistoryArray *progressArray;

    public:
        /* ------------------------------------------------------------------
            CONSTRUCTORS
        ------------------------------------------------------------------ */
        ParallelSystemArray();
        virtual ~ParallelSystemArray();

        /* ------------------------------------------------------------------
            GETTERS
        ------------------------------------------------------------------ */
        SHARED_ENTITY_ARRAY_ELEMENT_ACCESSOR_HEADER(ParallelSystem)

            /* ------------------------------------------------------------------
                CHAIN OF INVOKE MESSAGE
            ------------------------------------------------------------------ */
            using super::sendData;

        void sendSegmentData(std::shared_ptr<Invoke>, size_t);

        virtual void sendPieceData(std::shared_ptr<Invoke>, size_t, size_t);

    protected:
        virtual void notifyEnd(PRMasterHistory*);
    };
};
};
};