ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-12-06 17:27:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Crawl handshake header parsing in Overlay

Browse Source
This commit is contained in:
Vinnie Falco
2015-04-16 18:20:54 -07:00
parent 47a5bf6aa5
commit 6d74f36449
2 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/ripple/overlay/impl/ConnectAttempt.cpp
View File

@@ -423,8 +423,8 @@ ConnectAttempt::processResponse (beast::http::message const& m,
auto const peer = std::make_shared<PeerImp>(
std::move(ssl_bundle_), read_buf_.data(),
std::move(slot_), usage_, std::move(hello),
publicKey, id_, overlay_);
std::move(slot_), std::move(response_),
usage_, std::move(hello), publicKey, id_, overlay_);
overlay_.add_active (peer);
}

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

@@ -173,9 +173,10 @@ public:
template <class Buffers>
PeerImp (std::unique_ptr<beast::asio::ssl_bundle>&& ssl_bundle,
Buffers const& buffers, PeerFinder::Slot::ptr&& slot,
Resource::Consumer usage, protocol::TMHello&& hello,
RippleAddress const& legacyPublicKey, id_t id,
OverlayImpl& overlay);
beast::http::message&& response, Resource::Consumer usage,
protocol::TMHello&& hello,
RippleAddress const& legacyPublicKey, id_t id,
OverlayImpl& overlay);
virtual
~PeerImp();
@@ -448,9 +449,10 @@ private:
template <class Buffers>
PeerImp::PeerImp (std::unique_ptr<beast::asio::ssl_bundle>&& ssl_bundle,
Buffers const& buffers, PeerFinder::Slot::ptr&& slot,
Resource::Consumer usage, protocol::TMHello&& hello,
RippleAddress const& legacyPublicKey, id_t id,
OverlayImpl& overlay)
beast::http::message&& response, Resource::Consumer usage,
protocol::TMHello&& hello,
RippleAddress const& legacyPublicKey, id_t id,
OverlayImpl& overlay)
: Child (overlay)
, id_ (id)
, sink_ (deprecatedLogs().journal("Peer"), makePrefix(id))
@@ -473,6 +475,7 @@ PeerImp::PeerImp (std::unique_ptr<beast::asio::ssl_bundle>&& ssl_bundle,
, usage_ (usage)
, fee_ (Resource::feeLightPeer)
, slot_ (std::move(slot))
, http_message_(std::move(response))
, validatorsConnection_(getApp().getValidators().newConnection(id))
{
read_buffer_.commit (boost::asio::buffer_copy(read_buffer_.prepare(