SyncServer.hpp

Go to the documentation of this file.

#ifndef _IDENTT_HRPC_SYNC_SERVER_HPP_
#define _IDENTT_HRPC_SYNC_SERVER_HPP_

#include <store/StoreBase.hpp>
#include <utils/ServerBase.hpp>
#include "http/HttpServer.hpp"


namespace identt {
namespace hrpc {

class SyncServer :
    virtual public identt::utils::ServerBase,
    virtual public std::enable_shared_from_this<SyncServer> {

public:
    using pointer=std::shared_ptr<SyncServer>;
    using HttpServerT=identt::http::HttpServer<identt::http::HTTP>;

    SyncServer() = delete;
    SyncServer(const SyncServer&) = delete;
    SyncServer& operator=(const SyncServer&) = delete;


    static pointer create(std::shared_ptr<::identt::http::io_whatever> io_whatever_, identt::utils::SharedTable::pointer stptr)
    {
        pointer p(new SyncServer(io_whatever_,stptr));
        return p;
    }

    pointer share()
    {
        return shared_from_this();
    }


    virtual ~SyncServer ();

    const static std::string GetSection();

    const static identt::utils::ServerBase::ParamsListT GetRequire();

    void init(identt::utils::ServerBase::ParamsListT params);

    void stop();

protected:
    std::shared_ptr<HttpServerT> server;
    std::shared_ptr<::identt::http::io_whatever> io_whatever;

private:
    bool is_init;
    ::identt::utils::SharedTable::SharedBool to_stop_sync;

    SyncServer(std::shared_ptr<::identt::http::io_whatever> io_whatever_, identt::utils::SharedTable::pointer stptr);

    void SyncFirst();

    void SyncFromMaster();

    bool CompareLog(std::string address);

    void MasterLoop();

};
} // namespace hrpc
} // namespace identt
#endif /* _IDENTT_HRPC_SYNC_SERVER_HPP_ */