node.hpp

Go to the documentation of this file.

// Copyright (c) 2021 MIT Digital Currency Initiative,
//                    Federal Reserve Bank of Boston
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
#ifndef OPENCBDC_TX_SRC_RAFT_NODE_H_
#define OPENCBDC_TX_SRC_RAFT_NODE_H_
 
#include "console_logger.hpp"
#include "state_manager.hpp"
#include "util/common/config.hpp"
#include "util/network/connection_manager.hpp"
 
#include <libnuraft/nuraft.hxx>
 
namespace cbdc::raft {
    using result_type = nuraft::cmd_result<nuraft::ptr<nuraft::buffer>>;
 
    using callback_type
        = std::function<void(result_type& r,
                             nuraft::ptr<std::exception>& err)>;
 
    class node {
      public:
        node() = delete;
        node(const node&) = delete;
        auto operator=(const node&) -> node& = delete;
        node(node&&) = delete;
        auto operator=(node&&) -> node& = delete;
 
        node(int node_id,
             std::vector<network::endpoint_t> raft_endpoints,
             const std::string& node_type,
             bool blocking,
             nuraft::ptr<nuraft::state_machine> sm,
             size_t asio_thread_pool_size,
             std::shared_ptr<logging::log> logger,
             nuraft::cb_func::func_type raft_cb);
 
        ~node();
 
        auto init(const nuraft::raft_params& raft_params) -> bool;
 
        [[nodiscard]] auto is_leader() const -> bool;
 
        [[nodiscard]] auto replicate(nuraft::ptr<nuraft::buffer> new_log,
                                     const callback_type& result_fn) const
            -> bool;
 
        [[nodiscard]] auto
        replicate_sync(const nuraft::ptr<nuraft::buffer>& new_log) const
            -> std::optional<nuraft::ptr<nuraft::buffer>>;
 
        [[nodiscard]] auto last_log_idx() const -> uint64_t;
 
        [[nodiscard]] auto get_sm() const -> nuraft::state_machine*;
 
        void stop();
 
      private:
        uint32_t m_node_id;
        bool m_blocking;
        int m_port;
 
        nuraft::ptr<nuraft::logger> m_raft_logger;
        nuraft::ptr<state_manager> m_smgr;
        nuraft::ptr<nuraft::state_machine> m_sm;
        nuraft::raft_launcher m_launcher;
        nuraft::ptr<nuraft::raft_server> m_raft_instance;
 
        nuraft::asio_service::options m_asio_opt;
        nuraft::raft_server::init_options m_init_opts;
 
        std::shared_ptr<logging::log> m_log;
    };
}
 
#endif // OPENCBDC_TX_SRC_RAFT_NODE_H_