tcp_socket.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_NETWORK_TCP_SOCKET_H_
#define OPENCBDC_TX_SRC_NETWORK_TCP_SOCKET_H_
 
#include "socket.hpp"
#include "util/common/buffer.hpp"
#include "util/serialization/buffer_serializer.hpp"
#include "util/serialization/util.hpp"
 
#include <atomic>
 
namespace cbdc::network {
    class tcp_socket : public socket {
      public:
        tcp_socket() = default;
        ~tcp_socket() override;
 
        tcp_socket(const tcp_socket&) = delete;
        auto operator=(const tcp_socket&) -> tcp_socket& = delete;
 
        tcp_socket(tcp_socket&&) = delete;
        auto operator=(tcp_socket&&) -> tcp_socket& = delete;
 
        auto connect(const endpoint_t& ep) -> bool;
 
        auto connect(const ip_address& remote_address,
                     port_number_t remote_port) -> bool;
 
        [[nodiscard]] auto send(const buffer& pkt) const -> bool;
 
        template<typename T>
        [[nodiscard]] auto send(const T& data) const -> bool {
            auto pkt = make_buffer(data);
            return send(pkt);
        }
 
        [[nodiscard]] auto receive(buffer& pkt) const -> bool;
 
        void disconnect();
 
        auto reconnect() -> bool;
 
        [[nodiscard]] auto connected() const -> bool;
 
      private:
        std::optional<ip_address> m_addr{};
        port_number_t m_port{};
        std::atomic_bool m_connected{false};
    };
}
 
#endif