ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use beast::asio::streambuf in Overlay

Browse Source
This commit is contained in:
Vinnie Falco
2014-10-28 19:53:48 -07:00
parent 74b99014d2
commit c1a5e88752
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/ripple/overlay/impl/PeerImp.cpp
View File

@@ -706,7 +706,7 @@ PeerImp::on_read_protocol (error_code ec, std::size_t bytes_transferred)
if (! ec)
{
read_buffer_.commit (bytes_transferred);
ec = message_stream_.write_one (read_buffer_.data());
ec = message_stream_.write (read_buffer_.data());
read_buffer_.consume (read_buffer_.size());
}

5
src/ripple/overlay/impl/PeerImp.h
View File

@@ -39,6 +39,7 @@
#include <beast/asio/IPAddressConversion.h>
#include <beast/asio/placeholders.h>
#include <beast/asio/streambuf.h>
#include <beast/http/message.h>
#include <beast/http/parser.h>
@@ -169,12 +170,12 @@ private:
// The slot assigned to us by PeerFinder
PeerFinder::Slot::ptr slot_;
boost::asio::streambuf read_buffer_;
beast::asio::streambuf read_buffer_;
boost::optional <beast::http::message> http_message_;
boost::optional <beast::http::parser> http_parser_;
message_stream message_stream_;
boost::asio::streambuf write_buffer_;
beast::asio::streambuf write_buffer_;
std::unique_ptr <LoadEvent> load_event_;