error_cache.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_WATCHTOWER_ERROR_CACHE_H_
#define OPENCBDC_TX_SRC_WATCHTOWER_ERROR_CACHE_H_
 
#include "tx_error_messages.hpp"
#include "util/common/hashmap.hpp"
 
#include <memory>
#include <mutex>
#include <queue>
#include <shared_mutex>
#include <unordered_map>
 
namespace cbdc::watchtower {
 
    class error_cache {
      public:
        error_cache() = delete;
 
        explicit error_cache(size_t k);
 
        void push_errors(std::vector<tx_error>&& errs);
 
        auto check_tx_id(const hash_t& tx_id) const -> std::optional<tx_error>;
 
        auto check_uhs_id(const hash_t& uhs_id) const
            -> std::optional<tx_error>;
 
      private:
        size_t m_k_errs;
        std::queue<std::shared_ptr<tx_error>> m_errs;
        std::unordered_map<hash_t,
                           std::shared_ptr<tx_error>,
                           hashing::const_sip_hash<hash_t>>
            m_uhs_errs;
        std::unordered_map<hash_t,
                           std::shared_ptr<tx_error>,
                           hashing::const_sip_hash<hash_t>>
            m_tx_id_errs;
    };
}
 
#endif // OPENCBDC_TX_SRC_WATCHTOWER_ERROR_CACHE_H_