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

Actually, I think this code is okay.

Browse Source
This commit is contained in:
JoelKatz
2012-01-19 18:24:55 -08:00
parent 95a74ee904
commit 7049d036d9
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Peer.cpp
View File

@@ -83,7 +83,7 @@ void Peer::sendPacket(PackedMessage::pointer packet)
void Peer::start_read_header() void Peer::start_read_header()
{ {
mReadbuf.resize(HEADER_SIZE); mReadbuf.resize(HEADER_SIZE);
asio::async_read(mSocket, asio::buffer(mReadbuf, HEADER_SIZE), asio::async_read(mSocket, asio::buffer(mReadbuf),
boost::bind(&Peer::handle_read_header, shared_from_this(), asio::placeholders::error)); boost::bind(&Peer::handle_read_header, shared_from_this(), asio::placeholders::error));
} }
@@ -94,16 +94,14 @@ void Peer::start_read_body(unsigned msg_len)
// read into the body. // read into the body.
// //
mReadbuf.resize(HEADER_SIZE + msg_len); mReadbuf.resize(HEADER_SIZE + msg_len);
asio::mutable_buffers_1 buf = asio::buffer(&mReadbuf[HEADER_SIZE], msg_len); asio::async_read(mSocket, asio::buffer(&mReadbuf[HEADER_SIZE], msg_len),
asio::async_read(mSocket, buf,
boost::bind(&Peer::handle_read_body, shared_from_this(), asio::placeholders::error)); boost::bind(&Peer::handle_read_body, shared_from_this(), asio::placeholders::error));
} }
void Peer::handle_read_header(const boost::system::error_code& error) void Peer::handle_read_header(const boost::system::error_code& error)
{ {
if(!error) if(!error)
{ // FIXME: This assumes we have read the entire header {
// start_read_header has no completion condition, so this is a broken assumption
unsigned msg_len = PackedMessage::getLength(mReadbuf); unsigned msg_len = PackedMessage::getLength(mReadbuf);
start_read_body(msg_len); start_read_body(msg_len);
} }