uhs/atomizer/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_SHARD_CONTROLLER_H_
#define OPENCBDC_TX_SRC_SHARD_CONTROLLER_H_
 
#include "shard.hpp"
#include "uhs/atomizer/archiver/client.hpp"
#include "uhs/atomizer/atomizer/block.hpp"
#include "util/common/config.hpp"
#include "util/network/connection_manager.hpp"
 
#include <memory>
#include <secp256k1.h>
 
namespace cbdc::shard {
    class controller {
      public:
        controller() = delete;
        controller(const controller&) = delete;
        auto operator=(const controller&) -> controller& = delete;
        controller(controller&&) = delete;
        auto operator=(controller&&) -> controller& = delete;
 
        controller(uint32_t shard_id,
                   config::options opts,
                   std::shared_ptr<logging::log> logger);
 
        ~controller();
 
        auto init() -> bool;
 
      private:
        uint32_t m_shard_id;
        cbdc::config::options m_opts;
        std::shared_ptr<logging::log> m_logger;
        shard m_shard;
 
        cbdc::network::connection_manager m_watchtower_network;
        cbdc::network::connection_manager m_atomizer_network;
        cbdc::network::connection_manager m_shard_network;
 
        std::thread m_shard_server;
        std::thread m_atomizer_client;
 
        cbdc::archiver::client m_archiver_client;
 
        blocking_queue<network::message_t> m_request_queue;
        std::vector<std::thread> m_handler_threads;
 
        auto server_handler(cbdc::network::message_t&& pkt)
            -> std::optional<cbdc::buffer>;
        auto atomizer_handler(cbdc::network::message_t&& pkt)
            -> std::optional<cbdc::buffer>;
        void request_consumer();
    };
}
 
#endif // OPENCBDC_TX_SRC_SHARD_CONTROLLER_H_