diff options
Diffstat (limited to 'libcmix-network')
| -rw-r--r-- | libcmix-network/client.cpp | 10 | ||||
| -rw-r--r-- | libcmix-network/client.hpp | 12 |
2 files changed, 16 insertions, 6 deletions
diff --git a/libcmix-network/client.cpp b/libcmix-network/client.cpp index 7c95234..9293bd1 100644 --- a/libcmix-network/client.cpp +++ b/libcmix-network/client.cpp @@ -16,7 +16,7 @@ using namespace boost::system; Client::Client(tcp::socket &&socket) : socket(std::move(socket)) -, buffer() +, buffer(new boost::asio::streambuf()) , done() {} @@ -61,8 +61,8 @@ void Client::send(std::string message) { std::vector<uint8_t> Client::received_bytes_to_vector(size_t read_bytes) { - buffer.commit(read_bytes); - std::istream is(&buffer); + buffer->commit(read_bytes); + std::istream is(buffer.get()); is.unsetf(std::ios::skipws); return std::vector<uint8_t>(std::istream_iterator<uint8_t>(is), {}); @@ -92,7 +92,7 @@ void Client::handle_receive_size(Client::MessageHandler message_handler, const e size = ntohl(size); socket.async_receive( - buffer.prepare(size), + buffer->prepare(size), boost::bind(&Client::handle_receive_message, this, message_handler, error(), bytes_transferred()) ); } else { @@ -107,7 +107,7 @@ void Client::receive(MessageHandler message_handler) { using namespace boost::asio::placeholders; socket.async_receive( - buffer.prepare(4), + buffer->prepare(4), boost::bind(&Client::handle_receive_size, this, message_handler, error(), bytes_transferred()) ); } diff --git a/libcmix-network/client.hpp b/libcmix-network/client.hpp index 51dfa6f..dc3787d 100644 --- a/libcmix-network/client.hpp +++ b/libcmix-network/client.hpp @@ -31,7 +31,7 @@ protected: boost::asio::ip::tcp::socket socket; private: - boost::asio::streambuf buffer; + std::unique_ptr<boost::asio::streambuf> buffer; OnDoneFT done; @@ -52,6 +52,16 @@ public: ~Client(); /*! + * \brief Move constructor for Client. + */ + Client(Client&&) = default; + + /*! + * \brief Move assignment for Client. + */ + Client& operator=(Client&&) = default; + + /*! * \brief async_connect Asynchronously connects to next_host:port and calls on_connect * \param next_host The host to connect to * \param next_port The port to connect to |
