42 #ifndef INCLUDED_p2p_connection_basic_hpp 43 #define INCLUDED_p2p_connection_basic_hpp 50 #include <boost/asio.hpp> 51 #include <boost/asio/ssl.hpp> 91 class connection_basic_pimpl;
103 const boost::shared_ptr<connection_basic_shared_state> m_state;
106 std::unique_ptr< connection_basic_pimpl >
mI;
117 boost::asio::ssl::stream<boost::asio::ip::tcp::socket>
socket_;
135 bool handshake(boost::asio::ssl::stream_base::handshake_type type)
138 return m_state->ssl_options().handshake(
socket_, type);
141 template<
typename MutableBufferSequence,
typename ReadHandler>
145 socket_.async_read_some(buffers, std::forward<ReadHandler>(handler));
147 socket().async_read_some(buffers, std::forward<ReadHandler>(handler));
150 template<
typename ConstBufferSequence,
typename WriteHandler>
154 socket_.async_write_some(buffers, std::forward<WriteHandler>(handler));
156 socket().async_write_some(buffers, std::forward<WriteHandler>(handler));
159 template<
typename ConstBufferSequence,
typename WriteHandler>
160 void async_write(
const ConstBufferSequence &buffers, WriteHandler &&handler)
163 boost::asio::async_write(
socket_, buffers, std::forward<WriteHandler>(handler));
165 boost::asio::async_write(
socket(), buffers, std::forward<WriteHandler>(handler));
void logger_handle_net_write(size_t size)
const ssl_options_t & ssl_options() const noexcept
static uint64_t get_rate_down_limit()
critical_section m_send_que_lock
std::unique_ptr< connection_basic_pimpl > mI
connection_basic_shared_state()
static void set_tos_flag(int tos)
std::atomic< long > sock_count
std::unique_ptr< void, close > socket
Unique ZMQ socket handle, calls zmq_close on destruction.
std::atomic< long > sock_number
connection_basic_shared_state & get_state() noexcept
void sleep_before_packet(size_t packet_size, int phase, int q_len)
void do_send_handler_write(const void *ptr, size_t cb)
void async_write(const ConstBufferSequence &buffers, WriteHandler &&handler)
static void set_save_graph(bool save_graph)
static void save_limit_to_file(int limit)
for dr-electroneum
boost::asio::ip::tcp::socket & socket()
volatile uint32_t m_want_close_connection
static void set_rate_up_limit(uint64_t limit)
void do_send_handler_write_from_queue(const boost::system::error_code &e, size_t cb, int q_len)
unsigned __int64 uint64_t
bool handshake(boost::asio::ssl::stream_base::handshake_type type)
void configure_ssl(ssl_options_t src)
volatile bool m_is_multithreaded
std::unique_ptr< void, terminate > context
Unique ZMQ context handle, calls zmq_term on destruction.
std::list< std::string > m_send_que
connection_basic(boost::asio::ip::tcp::socket &&socket, boost::shared_ptr< connection_basic_shared_state > state, ssl_support_t ssl_support)
void logger_handle_net_read(size_t size)
ssl_support_t get_ssl_support() const
boost::asio::io_service::strand strand_
Strand to ensure the connection's handlers are not called concurrently.
static int get_tos_flag()
void async_write_some(const ConstBufferSequence &buffers, WriteHandler &&handler)
virtual ~connection_basic() noexcept(false)
boost::asio::ssl::stream< boost::asio::ip::tcp::socket > socket_
Socket for the connection.
const T & move(const T &t)
boost::asio::ssl::context ssl_context
static void set_rate_down_limit(uint64_t limit)
ssl_support_t m_ssl_support
void async_read_some(const MutableBufferSequence &buffers, ReadHandler &&handler)
std::string to_string(t_connection_type type)
boost::asio::ssl::context create_context() const
std::atomic< bool > m_was_shutdown
static double get_sleep_time(size_t cb)
static uint64_t get_rate_up_limit()