shard.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_SHARD_H_
#define OPENCBDC_TX_SRC_SHARD_SHARD_H_
 
#include "uhs/atomizer/atomizer/atomizer_raft.hpp"
#include "uhs/atomizer/atomizer/block.hpp"
#include "uhs/atomizer/atomizer/format.hpp"
#include "uhs/atomizer/watchtower/tx_error_messages.hpp"
#include "uhs/transaction/transaction.hpp"
#include "util/common/config.hpp"
#include "util/common/logging.hpp"
#include "util/network/connection_manager.hpp"
#include "util/serialization/format.hpp"
 
#include <atomic>
#include <leveldb/db.h>
#include <leveldb/write_batch.h>
#include <memory>
#include <mutex>
#include <thread>
#include <unordered_set>
 
namespace cbdc::shard {
    class shard {
      public:
        explicit shard(config::shard_range_t prefix_range);
 
        auto open_db(const std::string& db_dir) -> std::optional<std::string>;
 
        auto digest_transaction(transaction::compact_tx tx)
            -> std::variant<atomizer::tx_notify_request, watchtower::tx_error>;
 
        auto digest_block(const cbdc::atomizer::block& blk) -> bool;
 
        [[nodiscard]] auto best_block_height() const -> uint64_t;
 
      private:
        [[nodiscard]] auto is_output_on_shard(const hash_t& uhs_hash) const
            -> bool;
 
        void update_snapshot();
 
        std::unique_ptr<leveldb::DB> m_db;
        leveldb::ReadOptions m_read_options;
        leveldb::WriteOptions m_write_options;
 
        uint64_t m_best_block_height{};
 
        std::shared_ptr<const leveldb::Snapshot> m_snp;
        uint64_t m_snp_height{};
        std::shared_mutex m_snp_mut;
 
        const std::string m_best_block_height_key = "bestBlockHeight";
 
        std::pair<uint8_t, uint8_t> m_prefix_range;
    };
}
 
#endif // OPENCBDC_TX_SRC_SHARD_SHARD_H_