4 #include <boost/asio.hpp>
6 #include <boost/circular_buffer.hpp>
25 const boost::asio::ip::tcp::endpoint& endpoint,
36 LOG_ERROR <<
"Connection to " << m_endpoint <<
" failed";
90 boost::system::error_code ec;
95 boost::asio::socket_base::send_buffer_size option(67108864);
98 boost::system::error_code ec;
99 m_sock.shutdown(boost::asio::ip::tcp::socket::shutdown_receive, ec);
105 boost::system::error_code ec;
106 m_sock.shutdown(boost::asio::ip::tcp::socket::shutdown_send, ec);
118 boost::system::error_code ec;
129 #endif // RECIPIENT_HH
boost::circular_buffer< Frame > CircularBuffer
Recipient(boost::asio::io_service &service, const boost::asio::ip::tcp::endpoint &endpoint, size_t circbuff_size)
boost::asio::ip::tcp::socket m_sock
bool send(const Frame &data)
Send data.
bool sendIfPossible(const Frame &data)
boost::asio::ip::tcp::endpoint m_endpoint
unsigned int getFrameLength() const
bool write(const Vec &v, std::ostream &os)
Write a Vec(tor) to a stream.
Template Frame for ARS data.