uhs/twophase/locking_shard/client.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_LOCKING_SHARD_CLIENT_H_
#define OPENCBDC_TX_SRC_LOCKING_SHARD_CLIENT_H_
 
#include "interface.hpp"
#include "messages.hpp"
#include "util/common/logging.hpp"
#include "util/rpc/tcp_client.hpp"
 
namespace cbdc::locking_shard::rpc {
    class client final : public interface {
      public:
        client(std::vector<network::endpoint_t> endpoints,
               const std::pair<uint8_t, uint8_t>& output_range,
               logging::log& logger);
 
        client() = delete;
        ~client() override;
        client(const client&) = delete;
        auto operator=(const client&) -> client& = delete;
        client(client&&) = delete;
        auto operator=(client&&) -> client& = delete;
 
        auto init() -> bool;
 
        auto lock_outputs(std::vector<tx>&& txs, const hash_t& dtx_id)
            -> std::optional<std::vector<bool>> override;
 
        auto apply_outputs(std::vector<bool>&& complete_txs,
                           const hash_t& dtx_id) -> bool override;
 
        auto discard_dtx(const hash_t& dtx_id) -> bool override;
 
        void stop() override;
 
      private:
        auto send_request(const request& req) -> std::optional<response>;
 
        std::atomic_bool m_running{true};
 
        std::unique_ptr<cbdc::rpc::tcp_client<request, response>> m_client;
 
        logging::log& m_log;
    };
}
 
#endif // OPENCBDC_TX_SRC_LOCKING_SHARD_CLIENT_H_