parsec/runtime_locking_shard/controller.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_PARSEC_RUNTIME_LOCKING_SHARD_CONTROLLER_H_
#define OPENCBDC_TX_SRC_PARSEC_RUNTIME_LOCKING_SHARD_CONTROLLER_H_
 
#include "impl.hpp"
#include "replicated_shard_client.hpp"
#include "server.hpp"
#include "state_machine.hpp"
#include "util/raft/node.hpp"
#include "util/rpc/tcp_server.hpp"
 
namespace cbdc::parsec::runtime_locking_shard {
    class controller {
      public:
        controller(size_t component_id,
                   size_t node_id,
                   network::endpoint_t server_endpoint,
                   std::vector<network::endpoint_t> raft_endpoints,
                   std::shared_ptr<logging::log> logger);
        ~controller() = default;
 
        controller() = delete;
        controller(const controller&) = delete;
        auto operator=(const controller&) -> controller& = delete;
        controller(controller&&) = delete;
        auto operator=(controller&&) -> controller& = delete;
 
        auto init() -> bool;
 
      private:
        auto raft_callback(nuraft::cb_func::Type type,
                           nuraft::cb_func::Param* param)
            -> nuraft::cb_func::ReturnCode;
 
        void do_recovery();
 
        void handle_get_tickets(
            replicated_shard_interface::get_tickets_return_type res);
 
        std::shared_ptr<logging::log> m_logger;
 
        std::shared_ptr<state_machine> m_state_machine;
        std::shared_ptr<raft::node> m_raft_serv;
        std::shared_ptr<replicated_shard_client> m_raft_client;
        std::unique_ptr<rpc::server> m_server;
        std::shared_ptr<impl> m_shard;
 
        std::vector<network::endpoint_t> m_raft_endpoints;
        network::endpoint_t m_server_endpoint;
    };
}
 
#endif