From aa49be65a12685041b5c235a4c8f1bba6924ae54 Mon Sep 17 00:00:00 2001 From: Crypto Brad Garlinghouse Date: Sat, 22 Sep 2018 20:58:50 +0000 Subject: [PATCH] Remove conditional check for feature introduced in 0.28.1-b7 --- src/ripple/overlay/impl/OverlayImpl.cpp | 57 ++++++++++--------------- src/ripple/overlay/impl/OverlayImpl.h | 6 +-- src/ripple/overlay/impl/PeerImp.cpp | 14 ------ src/ripple/overlay/impl/PeerImp.h | 7 --- 4 files changed, 25 insertions(+), 59 deletions(-) diff --git a/src/ripple/overlay/impl/OverlayImpl.cpp b/src/ripple/overlay/impl/OverlayImpl.cpp index f948cc3de..70c6b1f9f 100644 --- a/src/ripple/overlay/impl/OverlayImpl.cpp +++ b/src/ripple/overlay/impl/OverlayImpl.cpp @@ -1088,12 +1088,10 @@ OverlayImpl::send (protocol::TMProposeSet& m) { if (setup_.expire) m.set_hops(0); - auto const sm = std::make_shared( - m, protocol::mtPROPOSE_LEDGER); + auto const sm = std::make_shared(m, protocol::mtPROPOSE_LEDGER); for_each([&](std::shared_ptr&& p) { - if (! m.has_hops() || p->hopsAware()) - p->send(sm); + p->send(sm); }); } void @@ -1101,12 +1099,10 @@ OverlayImpl::send (protocol::TMValidation& m) { if (setup_.expire) m.set_hops(0); - auto const sm = std::make_shared( - m, protocol::mtVALIDATION); + auto const sm = std::make_shared(m, protocol::mtVALIDATION); for_each([&](std::shared_ptr&& p) { - if (! m.has_hops() || p->hopsAware()) - p->send(sm); + p->send(sm); }); SerialIter sit (m.validation().data(), m.validation().size()); @@ -1120,43 +1116,35 @@ OverlayImpl::send (protocol::TMValidation& m) } void -OverlayImpl::relay (protocol::TMProposeSet& m, - uint256 const& uid) +OverlayImpl::relay (protocol::TMProposeSet& m, uint256 const& uid) { if (m.has_hops() && m.hops() >= maxTTL) return; - auto const toSkip = app_.getHashRouter().shouldRelay(uid); - if (!toSkip) - return; - auto const sm = std::make_shared( - m, protocol::mtPROPOSE_LEDGER); - for_each([&](std::shared_ptr&& p) + if (auto const toSkip = app_.getHashRouter().shouldRelay(uid)) { - if (toSkip->find(p->id()) != toSkip->end()) - return; - if (! m.has_hops() || p->hopsAware()) - p->send(sm); - }); + auto const sm = std::make_shared(m, protocol::mtPROPOSE_LEDGER); + for_each([&](std::shared_ptr&& p) + { + if (toSkip->find(p->id()) == toSkip->end()) + p->send(sm); + }); + } } void -OverlayImpl::relay (protocol::TMValidation& m, - uint256 const& uid) +OverlayImpl::relay (protocol::TMValidation& m, uint256 const& uid) { if (m.has_hops() && m.hops() >= maxTTL) return; - auto const toSkip = app_.getHashRouter().shouldRelay(uid); - if (! toSkip) - return; - auto const sm = std::make_shared( - m, protocol::mtVALIDATION); - for_each([&](std::shared_ptr&& p) + if (auto const toSkip = app_.getHashRouter().shouldRelay(uid)) { - if (toSkip->find(p->id()) != toSkip->end()) - return; - if (! m.has_hops() || p->hopsAware()) - p->send(sm); - }); + auto const sm = std::make_shared(m, protocol::mtVALIDATION); + for_each([&](std::shared_ptr&& p) + { + if (toSkip->find(p->id()) == toSkip->end()) + p->send(sm); + }); + } } //------------------------------------------------------------------------------ @@ -1248,6 +1236,7 @@ Overlay::Setup setup_Overlay (BasicConfig const& config) { Overlay::Setup setup; + { auto const& section = config.section("overlay"); setup.context = make_SSLContext(""); diff --git a/src/ripple/overlay/impl/OverlayImpl.h b/src/ripple/overlay/impl/OverlayImpl.h index 4c81807f9..c936f5b62 100644 --- a/src/ripple/overlay/impl/OverlayImpl.h +++ b/src/ripple/overlay/impl/OverlayImpl.h @@ -41,6 +41,7 @@ #include #include #include +#include #include #include #include @@ -50,10 +51,7 @@ namespace ripple { class PeerImp; class BasicConfig; -enum -{ - maxTTL = 2 -}; +constexpr std::uint32_t maxTTL = 2; class OverlayImpl : public Overlay { diff --git a/src/ripple/overlay/impl/PeerImp.cpp b/src/ripple/overlay/impl/PeerImp.cpp index e2ecefb72..ab48bdfd8 100644 --- a/src/ripple/overlay/impl/PeerImp.cpp +++ b/src/ripple/overlay/impl/PeerImp.cpp @@ -104,20 +104,6 @@ PeerImp::run() if(! strand_.running_in_this_thread()) return strand_.post(std::bind ( &PeerImp::run, shared_from_this())); - { - auto s = getVersion(); - if (boost::starts_with(s, "rippled-")) - { - s.erase(s.begin(), s.begin() + 8); - beast::SemanticVersion v; - if (v.parse(s)) - { - beast::SemanticVersion av; - av.parse("0.28.1-b7"); - hopsAware_ = v >= av; - } - } - } if (m_inbound) { doAccept(); diff --git a/src/ripple/overlay/impl/PeerImp.h b/src/ripple/overlay/impl/PeerImp.h index f7885cee5..dc5a5aeec 100644 --- a/src/ripple/overlay/impl/PeerImp.h +++ b/src/ripple/overlay/impl/PeerImp.h @@ -160,7 +160,6 @@ private: int large_sendq_ = 0; int no_ping_ = 0; std::unique_ptr load_event_; - bool hopsAware_ = false; std::mutex mutable shardInfoMutex_; hash_map shardInfo_; @@ -255,12 +254,6 @@ public: return slot_->cluster(); } - bool - hopsAware() const - { - return hopsAware_; - } - void check();