mirror of
https://github.com/XRPLF/rippled.git
synced 2026-06-07 18:56:47 +00:00
Compare commits
2 Commits
ximinez/nu
...
bthomee/mo
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e51d6680a1 | ||
|
|
34de214d3e |
@@ -95,13 +95,7 @@ strUnHex(std::size_t strSize, Iterator begin, Iterator end)
|
||||
}
|
||||
|
||||
inline std::optional<Blob>
|
||||
strUnHex(std::string const& strSrc)
|
||||
{
|
||||
return strUnHex(strSrc.size(), strSrc.cbegin(), strSrc.cend());
|
||||
}
|
||||
|
||||
inline std::optional<Blob>
|
||||
strViewUnHex(std::string_view strSrc)
|
||||
strUnHex(std::string_view strSrc)
|
||||
{
|
||||
return strUnHex(strSrc.size(), strSrc.cbegin(), strSrc.cend());
|
||||
}
|
||||
|
||||
@@ -43,7 +43,7 @@ std::string
|
||||
base64Encode(std::uint8_t const* data, std::size_t len);
|
||||
|
||||
inline std::string
|
||||
base64Encode(std::string const& s)
|
||||
base64Encode(std::string_view s)
|
||||
{
|
||||
return base64Encode(reinterpret_cast<std::uint8_t const*>(s.data()), s.size());
|
||||
}
|
||||
|
||||
@@ -1,12 +1,13 @@
|
||||
#pragma once
|
||||
|
||||
#include <string>
|
||||
#include <string_view>
|
||||
|
||||
namespace xrpl {
|
||||
|
||||
template <class Stream, class Iter>
|
||||
Stream&
|
||||
join(Stream& s, Iter iter, Iter end, std::string const& delimiter)
|
||||
join(Stream& s, Iter iter, Iter end, std::string_view delimiter)
|
||||
{
|
||||
if (iter == end)
|
||||
return s;
|
||||
|
||||
@@ -29,7 +29,7 @@ public:
|
||||
factory function in the Collector interface.
|
||||
@see Collector.
|
||||
*/
|
||||
explicit Counter(std::shared_ptr<CounterImpl> const& impl) : impl_(impl)
|
||||
explicit Counter(std::shared_ptr<CounterImpl> impl) : impl_(std::move(impl))
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -31,7 +31,7 @@ public:
|
||||
factory function in the Collector interface.
|
||||
@see Collector.
|
||||
*/
|
||||
explicit Event(std::shared_ptr<EventImpl> const& impl) : impl_(impl)
|
||||
explicit Event(std::shared_ptr<EventImpl> impl) : impl_(std::move(impl))
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -31,7 +31,7 @@ public:
|
||||
factory function in the Collector interface.
|
||||
@see Collector.
|
||||
*/
|
||||
explicit Gauge(std::shared_ptr<GaugeImpl> const& impl) : impl_(impl)
|
||||
explicit Gauge(std::shared_ptr<GaugeImpl> impl) : impl_(std::move(impl))
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -20,7 +20,7 @@ public:
|
||||
factory function in the Collector interface.
|
||||
@see Collector.
|
||||
*/
|
||||
explicit Hook(std::shared_ptr<HookImpl> const& impl) : impl_(impl)
|
||||
explicit Hook(std::shared_ptr<HookImpl> impl) : impl_(std::move(impl))
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -28,7 +28,7 @@ public:
|
||||
factory function in the Collector interface.
|
||||
@see Collector.
|
||||
*/
|
||||
explicit Meter(std::shared_ptr<MeterImpl> const& impl) : impl_(impl)
|
||||
explicit Meter(std::shared_ptr<MeterImpl> impl) : impl_(std::move(impl))
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -41,7 +41,7 @@ private:
|
||||
|
||||
public:
|
||||
template <class = void>
|
||||
explicit Selector(ModeT mode, std::string const& pattern = "");
|
||||
explicit Selector(ModeT mode, std::string pattern = "");
|
||||
|
||||
template <class = void>
|
||||
bool
|
||||
@@ -51,7 +51,7 @@ public:
|
||||
//------------------------------------------------------------------------------
|
||||
|
||||
template <class>
|
||||
Selector::Selector(ModeT mode, std::string const& pattern) : mode_(mode), pat_(pattern)
|
||||
Selector::Selector(ModeT mode, std::string pattern) : mode_(mode), pat_(std::move(pattern))
|
||||
{
|
||||
if (mode_ == ModeT::Automatch && pattern.empty())
|
||||
mode_ = ModeT::All;
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
#pragma once
|
||||
|
||||
#include <string>
|
||||
#include <string_view>
|
||||
#include <vector>
|
||||
|
||||
namespace xrpl {
|
||||
@@ -34,7 +35,7 @@ private:
|
||||
static void
|
||||
standard(std::string& strWord);
|
||||
static int
|
||||
wsrch(std::string const& strWord, int iMin, int iMax);
|
||||
wsrch(std::string_view strWord, int iMin, int iMax);
|
||||
static int
|
||||
etob(std::string& strData, std::vector<std::string> vsHuman);
|
||||
|
||||
|
||||
@@ -93,7 +93,7 @@ public:
|
||||
}
|
||||
|
||||
void
|
||||
insert(std::shared_ptr<STTx const> const& txn);
|
||||
insert(std::shared_ptr<STTx const> txn);
|
||||
|
||||
// Pops the next transaction on account that follows seqProx in the
|
||||
// sort order. Normally called when a transaction is successfully
|
||||
|
||||
@@ -53,7 +53,7 @@ public:
|
||||
boost::system::error_code const& ecResult,
|
||||
int iStatus,
|
||||
std::string const& strData)> complete,
|
||||
beast::Journal& j);
|
||||
beast::Journal const& j);
|
||||
|
||||
static void
|
||||
get(bool bSSL,
|
||||
@@ -67,7 +67,7 @@ public:
|
||||
boost::system::error_code const& ecResult,
|
||||
int iStatus,
|
||||
std::string const& strData)> complete,
|
||||
beast::Journal& j);
|
||||
beast::Journal const& j);
|
||||
|
||||
static void
|
||||
request(
|
||||
@@ -82,7 +82,7 @@ public:
|
||||
boost::system::error_code const& ecResult,
|
||||
int iStatus,
|
||||
std::string const& strData)> complete,
|
||||
beast::Journal& j);
|
||||
beast::Journal const& j);
|
||||
};
|
||||
|
||||
} // namespace xrpl
|
||||
|
||||
@@ -17,8 +17,8 @@ public:
|
||||
STVector256() = default;
|
||||
|
||||
explicit STVector256(SField const& n);
|
||||
explicit STVector256(std::vector<uint256> const& vector);
|
||||
STVector256(SField const& n, std::vector<uint256> const& vector);
|
||||
explicit STVector256(std::vector<uint256> vector);
|
||||
STVector256(SField const& n, std::vector<uint256> vector);
|
||||
STVector256(SerialIter& sit, SField const& name);
|
||||
|
||||
[[nodiscard]] SerializedTypeID
|
||||
@@ -103,12 +103,12 @@ inline STVector256::STVector256(SField const& n) : STBase(n)
|
||||
{
|
||||
}
|
||||
|
||||
inline STVector256::STVector256(std::vector<uint256> const& vector) : value_(vector)
|
||||
inline STVector256::STVector256(std::vector<uint256> vector) : value_(std::move(vector))
|
||||
{
|
||||
}
|
||||
|
||||
inline STVector256::STVector256(SField const& n, std::vector<uint256> const& vector)
|
||||
: STBase(n), value_(vector)
|
||||
inline STVector256::STVector256(SField const& n, std::vector<uint256> vector)
|
||||
: STBase(n), value_(std::move(vector))
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -10,6 +10,7 @@
|
||||
#include <functional>
|
||||
#include <memory>
|
||||
#include <ostream>
|
||||
#include <string_view>
|
||||
#include <vector>
|
||||
|
||||
namespace xrpl {
|
||||
@@ -53,10 +54,10 @@ public:
|
||||
/** Send a copy of data asynchronously. */
|
||||
/** @{ */
|
||||
void
|
||||
write(std::string const& s)
|
||||
write(std::string_view s)
|
||||
{
|
||||
if (!s.empty())
|
||||
write(&s[0], std::distance(s.begin(), s.end()));
|
||||
write(s.data(), s.size());
|
||||
}
|
||||
|
||||
template <typename BufferSequence>
|
||||
|
||||
@@ -161,7 +161,7 @@ public:
|
||||
setLedgerSeq(std::uint32_t lseq);
|
||||
|
||||
bool
|
||||
fetchRoot(SHAMapHash const& hash, SHAMapSyncFilter* filter);
|
||||
fetchRoot(SHAMapHash const& hash, SHAMapSyncFilter const* filter);
|
||||
|
||||
// normal hash access functions
|
||||
|
||||
@@ -248,7 +248,7 @@ public:
|
||||
@param return The nodes known to be missing
|
||||
*/
|
||||
std::vector<std::pair<SHAMapNodeID, uint256>>
|
||||
getMissingNodes(int maxNodes, SHAMapSyncFilter* filter);
|
||||
getMissingNodes(int maxNodes, SHAMapSyncFilter const* filter);
|
||||
|
||||
bool
|
||||
getNodeFat(
|
||||
@@ -281,9 +281,9 @@ public:
|
||||
serializeRoot(Serializer& s) const;
|
||||
|
||||
SHAMapAddNode
|
||||
addRootNode(SHAMapHash const& hash, Slice const& rootNode, SHAMapSyncFilter* filter);
|
||||
addRootNode(SHAMapHash const& hash, Slice const& rootNode, SHAMapSyncFilter const* filter);
|
||||
SHAMapAddNode
|
||||
addKnownNode(SHAMapNodeID const& nodeID, Slice const& rawNode, SHAMapSyncFilter* filter);
|
||||
addKnownNode(SHAMapNodeID const& nodeID, Slice const& rawNode, SHAMapSyncFilter const* filter);
|
||||
|
||||
// status functions
|
||||
void
|
||||
@@ -343,11 +343,11 @@ private:
|
||||
SHAMapTreeNodePtr
|
||||
fetchNodeNT(SHAMapHash const& hash) const;
|
||||
SHAMapTreeNodePtr
|
||||
fetchNodeNT(SHAMapHash const& hash, SHAMapSyncFilter* filter) const;
|
||||
fetchNodeNT(SHAMapHash const& hash, SHAMapSyncFilter const* filter) const;
|
||||
SHAMapTreeNodePtr
|
||||
fetchNode(SHAMapHash const& hash) const;
|
||||
SHAMapTreeNodePtr
|
||||
checkFilter(SHAMapHash const& hash, SHAMapSyncFilter* filter) const;
|
||||
checkFilter(SHAMapHash const& hash, SHAMapSyncFilter const* filter) const;
|
||||
|
||||
/** Update hashes up to the root */
|
||||
void
|
||||
@@ -411,7 +411,7 @@ private:
|
||||
descendAsync(
|
||||
SHAMapInnerNode* parent,
|
||||
int branch,
|
||||
SHAMapSyncFilter* filter,
|
||||
SHAMapSyncFilter const* filter,
|
||||
bool& pending,
|
||||
descendCallback&&) const;
|
||||
|
||||
@@ -420,7 +420,7 @@ private:
|
||||
SHAMapInnerNode* parent,
|
||||
SHAMapNodeID const& parentID,
|
||||
int branch,
|
||||
SHAMapSyncFilter* filter) const;
|
||||
SHAMapSyncFilter const* filter) const;
|
||||
|
||||
// Non-storing
|
||||
// Does not hook the returned node to its parent
|
||||
@@ -461,7 +461,7 @@ private:
|
||||
|
||||
// basic parameters
|
||||
int max;
|
||||
SHAMapSyncFilter* filter;
|
||||
SHAMapSyncFilter const* filter;
|
||||
int const maxDefer;
|
||||
std::uint32_t generation;
|
||||
|
||||
@@ -500,7 +500,11 @@ private:
|
||||
// reads
|
||||
std::map<SHAMapInnerNode*, SHAMapNodeID> resumes;
|
||||
|
||||
MissingNodes(int max, SHAMapSyncFilter* filter, int maxDefer, std::uint32_t generation)
|
||||
MissingNodes(
|
||||
int max,
|
||||
SHAMapSyncFilter const* filter,
|
||||
int maxDefer,
|
||||
std::uint32_t generation)
|
||||
: max(max), filter(filter), maxDefer(maxDefer), generation(generation), deferred(0)
|
||||
{
|
||||
missingNodes.reserve(max);
|
||||
|
||||
@@ -127,7 +127,7 @@ operator<<(std::ostream& out, SHAMapNodeID const& node)
|
||||
deserializeSHAMapNodeID(void const* data, std::size_t size);
|
||||
|
||||
[[nodiscard]] inline std::optional<SHAMapNodeID>
|
||||
deserializeSHAMapNodeID(std::string const& s)
|
||||
deserializeSHAMapNodeID(std::string_view s)
|
||||
{
|
||||
return deserializeSHAMapNodeID(s.data(), s.size());
|
||||
}
|
||||
|
||||
@@ -66,7 +66,7 @@ public:
|
||||
class StatsDHookImpl : public HookImpl, public StatsDMetricBase
|
||||
{
|
||||
public:
|
||||
StatsDHookImpl(HandlerType handler, std::shared_ptr<StatsDCollectorImp> const& impl);
|
||||
StatsDHookImpl(HandlerType handler, std::shared_ptr<StatsDCollectorImp> impl);
|
||||
|
||||
~StatsDHookImpl() override;
|
||||
|
||||
@@ -86,7 +86,7 @@ private:
|
||||
class StatsDCounterImpl : public CounterImpl, public StatsDMetricBase
|
||||
{
|
||||
public:
|
||||
StatsDCounterImpl(std::string name, std::shared_ptr<StatsDCollectorImp> const& impl);
|
||||
StatsDCounterImpl(std::string name, std::shared_ptr<StatsDCollectorImp> impl);
|
||||
|
||||
~StatsDCounterImpl() override;
|
||||
|
||||
@@ -115,7 +115,7 @@ private:
|
||||
class StatsDEventImpl : public EventImpl
|
||||
{
|
||||
public:
|
||||
StatsDEventImpl(std::string name, std::shared_ptr<StatsDCollectorImp> const& impl);
|
||||
StatsDEventImpl(std::string name, std::shared_ptr<StatsDCollectorImp> impl);
|
||||
|
||||
~StatsDEventImpl() override = default;
|
||||
|
||||
@@ -140,7 +140,7 @@ private:
|
||||
class StatsDGaugeImpl : public GaugeImpl, public StatsDMetricBase
|
||||
{
|
||||
public:
|
||||
StatsDGaugeImpl(std::string name, std::shared_ptr<StatsDCollectorImp> const& impl);
|
||||
StatsDGaugeImpl(std::string name, std::shared_ptr<StatsDCollectorImp> impl);
|
||||
|
||||
~StatsDGaugeImpl() override;
|
||||
|
||||
@@ -174,7 +174,7 @@ private:
|
||||
class StatsDMeterImpl : public MeterImpl, public StatsDMetricBase
|
||||
{
|
||||
public:
|
||||
explicit StatsDMeterImpl(std::string name, std::shared_ptr<StatsDCollectorImp> const& impl);
|
||||
explicit StatsDMeterImpl(std::string name, std::shared_ptr<StatsDCollectorImp> impl);
|
||||
|
||||
~StatsDMeterImpl() override;
|
||||
|
||||
@@ -478,8 +478,8 @@ public:
|
||||
|
||||
//------------------------------------------------------------------------------
|
||||
|
||||
StatsDHookImpl::StatsDHookImpl(HandlerType handler, std::shared_ptr<StatsDCollectorImp> const& impl)
|
||||
: impl_(impl), handler_(std::move(handler))
|
||||
StatsDHookImpl::StatsDHookImpl(HandlerType handler, std::shared_ptr<StatsDCollectorImp> impl)
|
||||
: impl_(std::move(impl)), handler_(std::move(handler))
|
||||
{
|
||||
impl_->add(*this);
|
||||
}
|
||||
@@ -497,10 +497,8 @@ StatsDHookImpl::doProcess()
|
||||
|
||||
//------------------------------------------------------------------------------
|
||||
|
||||
StatsDCounterImpl::StatsDCounterImpl(
|
||||
std::string name,
|
||||
std::shared_ptr<StatsDCollectorImp> const& impl)
|
||||
: impl_(impl), name_(std::move(name))
|
||||
StatsDCounterImpl::StatsDCounterImpl(std::string name, std::shared_ptr<StatsDCollectorImp> impl)
|
||||
: impl_(std::move(impl)), name_(std::move(name))
|
||||
{
|
||||
impl_->add(*this);
|
||||
}
|
||||
@@ -550,8 +548,8 @@ StatsDCounterImpl::doProcess()
|
||||
|
||||
//------------------------------------------------------------------------------
|
||||
|
||||
StatsDEventImpl::StatsDEventImpl(std::string name, std::shared_ptr<StatsDCollectorImp> const& impl)
|
||||
: impl_(impl), name_(std::move(name))
|
||||
StatsDEventImpl::StatsDEventImpl(std::string name, std::shared_ptr<StatsDCollectorImp> impl)
|
||||
: impl_(std::move(impl)), name_(std::move(name))
|
||||
{
|
||||
}
|
||||
|
||||
@@ -577,8 +575,8 @@ StatsDEventImpl::doNotify(EventImpl::value_type const& value)
|
||||
|
||||
//------------------------------------------------------------------------------
|
||||
|
||||
StatsDGaugeImpl::StatsDGaugeImpl(std::string name, std::shared_ptr<StatsDCollectorImp> const& impl)
|
||||
: impl_(impl), name_(std::move(name))
|
||||
StatsDGaugeImpl::StatsDGaugeImpl(std::string name, std::shared_ptr<StatsDCollectorImp> impl)
|
||||
: impl_(std::move(impl)), name_(std::move(name))
|
||||
{
|
||||
impl_->add(*this);
|
||||
}
|
||||
@@ -664,8 +662,8 @@ StatsDGaugeImpl::doProcess()
|
||||
|
||||
//------------------------------------------------------------------------------
|
||||
|
||||
StatsDMeterImpl::StatsDMeterImpl(std::string name, std::shared_ptr<StatsDCollectorImp> const& impl)
|
||||
: impl_(impl), name_(std::move(name))
|
||||
StatsDMeterImpl::StatsDMeterImpl(std::string name, std::shared_ptr<StatsDCollectorImp> impl)
|
||||
: impl_(std::move(impl)), name_(std::move(name))
|
||||
{
|
||||
impl_->add(*this);
|
||||
}
|
||||
|
||||
@@ -306,7 +306,7 @@ RFC1751::standard(std::string& strWord)
|
||||
|
||||
// Binary search of dictionary.
|
||||
int
|
||||
RFC1751::wsrch(std::string const& strWord, int iMin, int iMax)
|
||||
RFC1751::wsrch(std::string_view strWord, int iMin, int iMax)
|
||||
{
|
||||
int iResult = -1;
|
||||
|
||||
|
||||
@@ -40,14 +40,11 @@ CanonicalTXSet::accountKey(AccountID const& account)
|
||||
}
|
||||
|
||||
void
|
||||
CanonicalTXSet::insert(std::shared_ptr<STTx const> const& txn)
|
||||
CanonicalTXSet::insert(std::shared_ptr<STTx const> txn)
|
||||
{
|
||||
map_.insert(
|
||||
std::make_pair(
|
||||
Key(accountKey(txn->getAccountID(sfAccount)),
|
||||
txn->getSeqProxy(),
|
||||
txn->getTransactionID()),
|
||||
txn));
|
||||
Key const key(
|
||||
accountKey(txn->getAccountID(sfAccount)), txn->getSeqProxy(), txn->getTransactionID());
|
||||
map_.insert(std::make_pair(key, std::move(txn)));
|
||||
}
|
||||
|
||||
std::shared_ptr<STTx const>
|
||||
|
||||
@@ -64,7 +64,7 @@ public:
|
||||
boost::asio::io_context& ioContext,
|
||||
unsigned short const port,
|
||||
std::size_t maxResponseSize,
|
||||
beast::Journal& j)
|
||||
beast::Journal const& j)
|
||||
: socket_(
|
||||
ioContext,
|
||||
gHttpClientSslContext->context()) // NOLINT(bugprone-unchecked-optional-access)
|
||||
@@ -552,7 +552,7 @@ HTTPClient::get(
|
||||
std::function<
|
||||
bool(boost::system::error_code const& ecResult, int iStatus, std::string const& strData)>
|
||||
complete,
|
||||
beast::Journal& j)
|
||||
beast::Journal const& j)
|
||||
{
|
||||
auto client = std::make_shared<HTTPClientImp>(ioContext, port, responseMax, j);
|
||||
client->get(bSSL, deqSites, strPath, timeout, complete);
|
||||
@@ -570,7 +570,7 @@ HTTPClient::get(
|
||||
std::function<
|
||||
bool(boost::system::error_code const& ecResult, int iStatus, std::string const& strData)>
|
||||
complete,
|
||||
beast::Journal& j)
|
||||
beast::Journal const& j)
|
||||
{
|
||||
std::deque<std::string> const deqSites(1, strSite);
|
||||
|
||||
@@ -590,7 +590,7 @@ HTTPClient::request(
|
||||
std::function<
|
||||
bool(boost::system::error_code const& ecResult, int iStatus, std::string const& strData)>
|
||||
complete,
|
||||
beast::Journal& j)
|
||||
beast::Journal const& j)
|
||||
{
|
||||
std::deque<std::string> const deqSites(1, strSite);
|
||||
|
||||
|
||||
@@ -206,7 +206,7 @@ SHAMap::finishFetch(SHAMapHash const& hash, std::shared_ptr<NodeObject> const& o
|
||||
|
||||
// See if a sync filter has a node
|
||||
SHAMapTreeNodePtr
|
||||
SHAMap::checkFilter(SHAMapHash const& hash, SHAMapSyncFilter* filter) const
|
||||
SHAMap::checkFilter(SHAMapHash const& hash, SHAMapSyncFilter const* filter) const
|
||||
{
|
||||
if (auto nodeData = filter->getNode(hash))
|
||||
{
|
||||
@@ -232,7 +232,7 @@ SHAMap::checkFilter(SHAMapHash const& hash, SHAMapSyncFilter* filter) const
|
||||
// Get a node without throwing
|
||||
// Used on maps where missing nodes are expected
|
||||
SHAMapTreeNodePtr
|
||||
SHAMap::fetchNodeNT(SHAMapHash const& hash, SHAMapSyncFilter* filter) const
|
||||
SHAMap::fetchNodeNT(SHAMapHash const& hash, SHAMapSyncFilter const* filter) const
|
||||
{
|
||||
auto node = cacheLookup(hash);
|
||||
if (node)
|
||||
@@ -345,7 +345,7 @@ SHAMap::descend(
|
||||
SHAMapInnerNode* parent,
|
||||
SHAMapNodeID const& parentID,
|
||||
int branch,
|
||||
SHAMapSyncFilter* filter) const
|
||||
SHAMapSyncFilter const* filter) const
|
||||
{
|
||||
XRPL_ASSERT(parent->isInner(), "xrpl::SHAMap::descend : valid parent input");
|
||||
XRPL_ASSERT(
|
||||
@@ -374,7 +374,7 @@ SHAMapTreeNode*
|
||||
SHAMap::descendAsync(
|
||||
SHAMapInnerNode* parent,
|
||||
int branch,
|
||||
SHAMapSyncFilter* filter,
|
||||
SHAMapSyncFilter const* filter,
|
||||
bool& pending,
|
||||
descendCallback&& callback) const
|
||||
{
|
||||
@@ -885,7 +885,7 @@ SHAMap::updateGiveItem(SHAMapNodeType type, boost::intrusive_ptr<SHAMapItem cons
|
||||
}
|
||||
|
||||
bool
|
||||
SHAMap::fetchRoot(SHAMapHash const& hash, SHAMapSyncFilter* filter)
|
||||
SHAMap::fetchRoot(SHAMapHash const& hash, SHAMapSyncFilter const* filter)
|
||||
{
|
||||
if (hash == root_->getHash())
|
||||
return true;
|
||||
|
||||
@@ -305,7 +305,7 @@ SHAMap::gmnProcessDeferredReads(MissingNodes& mn)
|
||||
nodes that are not permanently stored locally
|
||||
*/
|
||||
std::vector<std::pair<SHAMapNodeID, uint256>>
|
||||
SHAMap::getMissingNodes(int max, SHAMapSyncFilter* filter)
|
||||
SHAMap::getMissingNodes(int max, SHAMapSyncFilter const* filter)
|
||||
{
|
||||
XRPL_ASSERT(root_->getHash().isNonZero(), "xrpl::SHAMap::getMissingNodes : nonzero root hash");
|
||||
XRPL_ASSERT(max > 0, "xrpl::SHAMap::getMissingNodes : valid max input");
|
||||
@@ -507,7 +507,7 @@ SHAMap::serializeRoot(Serializer& s) const
|
||||
}
|
||||
|
||||
SHAMapAddNode
|
||||
SHAMap::addRootNode(SHAMapHash const& hash, Slice const& rootNode, SHAMapSyncFilter* filter)
|
||||
SHAMap::addRootNode(SHAMapHash const& hash, Slice const& rootNode, SHAMapSyncFilter const* filter)
|
||||
{
|
||||
// we already have a root_ node
|
||||
if (root_->getHash().isNonZero())
|
||||
@@ -542,7 +542,7 @@ SHAMap::addRootNode(SHAMapHash const& hash, Slice const& rootNode, SHAMapSyncFil
|
||||
}
|
||||
|
||||
SHAMapAddNode
|
||||
SHAMap::addKnownNode(SHAMapNodeID const& node, Slice const& rawNode, SHAMapSyncFilter* filter)
|
||||
SHAMap::addKnownNode(SHAMapNodeID const& node, Slice const& rawNode, SHAMapSyncFilter const* filter)
|
||||
{
|
||||
XRPL_ASSERT(!node.isRoot(), "xrpl::SHAMap::addKnownNode : valid node input");
|
||||
|
||||
|
||||
@@ -40,7 +40,7 @@ private:
|
||||
std::vector<std::string> const credentials_;
|
||||
|
||||
public:
|
||||
explicit Ids(std::vector<std::string> const& creds) : credentials_(creds)
|
||||
explicit Ids(std::vector<std::string> creds) : credentials_(std::move(creds))
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -133,7 +133,7 @@ public:
|
||||
static void
|
||||
onRequest(Session& session)
|
||||
{
|
||||
session.write(std::string("Hello, world!\n"));
|
||||
session.write(std::string_view("Hello, world!\n"));
|
||||
if (beast::rfc2616::isKeepAlive(session.request()))
|
||||
{
|
||||
session.complete();
|
||||
|
||||
@@ -32,7 +32,7 @@ public:
|
||||
|
||||
@param l The ledger to wrap.
|
||||
*/
|
||||
RCLCxLedger(std::shared_ptr<Ledger const> const& l) : ledger{l}
|
||||
RCLCxLedger(std::shared_ptr<Ledger const> l) : ledger{std::move(l)}
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -32,7 +32,7 @@ public:
|
||||
|
||||
@param v The validation to wrap.
|
||||
*/
|
||||
RCLValidation(std::shared_ptr<STValidation> const& v) : val_{v}
|
||||
RCLValidation(std::shared_ptr<STValidation> v) : val_{std::move(v)}
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -8,7 +8,7 @@
|
||||
|
||||
namespace xrpl {
|
||||
|
||||
AcceptedLedger::AcceptedLedger(std::shared_ptr<ReadView const> const& ledger) : ledger_(ledger)
|
||||
AcceptedLedger::AcceptedLedger(std::shared_ptr<ReadView const> ledger) : ledger_(std::move(ledger))
|
||||
{
|
||||
transactions_.reserve(256);
|
||||
|
||||
@@ -16,12 +16,12 @@ AcceptedLedger::AcceptedLedger(std::shared_ptr<ReadView const> const& ledger) :
|
||||
for (auto const& item : txns)
|
||||
{
|
||||
transactions_.emplace_back(
|
||||
std::make_unique<AcceptedLedgerTx>(ledger, item.first, item.second));
|
||||
std::make_unique<AcceptedLedgerTx>(ledger_, item.first, item.second));
|
||||
}
|
||||
};
|
||||
|
||||
transactions_.reserve(256);
|
||||
insertAll(ledger->txs);
|
||||
insertAll(ledger_->txs);
|
||||
|
||||
std::ranges::sort(transactions_, [](auto const& a, auto const& b) {
|
||||
return a->getTxnSeq() < b->getTxnSeq();
|
||||
|
||||
@@ -25,7 +25,7 @@ namespace xrpl {
|
||||
class AcceptedLedger : public CountedObject<AcceptedLedger>
|
||||
{
|
||||
public:
|
||||
AcceptedLedger(std::shared_ptr<ReadView const> const& ledger);
|
||||
AcceptedLedger(std::shared_ptr<ReadView const> ledger);
|
||||
|
||||
[[nodiscard]] std::shared_ptr<ReadView const> const&
|
||||
getLedger() const
|
||||
|
||||
@@ -128,13 +128,13 @@ private:
|
||||
pmDowncast() override;
|
||||
|
||||
int
|
||||
processData(std::shared_ptr<Peer> peer, protocol::TMLedgerData& data);
|
||||
processData(std::shared_ptr<Peer> peer, protocol::TMLedgerData const& data);
|
||||
|
||||
bool
|
||||
takeHeader(std::string const& data);
|
||||
|
||||
void
|
||||
receiveNode(protocol::TMLedgerData& packet, SHAMapAddNode&);
|
||||
receiveNode(protocol::TMLedgerData const& packet, SHAMapAddNode&);
|
||||
|
||||
bool
|
||||
takeTxRootNode(Slice const& data, SHAMapAddNode&);
|
||||
@@ -143,10 +143,10 @@ private:
|
||||
takeAsRootNode(Slice const& data, SHAMapAddNode&);
|
||||
|
||||
std::vector<uint256>
|
||||
neededTxHashes(int max, SHAMapSyncFilter* filter) const;
|
||||
neededTxHashes(int max, SHAMapSyncFilter const* filter) const;
|
||||
|
||||
std::vector<uint256>
|
||||
neededStateHashes(int max, SHAMapSyncFilter* filter) const;
|
||||
neededStateHashes(int max, SHAMapSyncFilter const* filter) const;
|
||||
|
||||
clock_type& clock_;
|
||||
clock_type::time_point lastAction_;
|
||||
|
||||
@@ -12,6 +12,7 @@
|
||||
#include <xrpl/ledger/OpenView.h>
|
||||
|
||||
#include <mutex>
|
||||
#include <string_view>
|
||||
|
||||
namespace xrpl {
|
||||
|
||||
@@ -149,7 +150,7 @@ public:
|
||||
bool retriesFirst,
|
||||
OrderedTxs& retries,
|
||||
ApplyFlags flags,
|
||||
std::string const& suffix = "",
|
||||
std::string_view suffix = "",
|
||||
modify_type const& f = {});
|
||||
|
||||
private:
|
||||
|
||||
@@ -188,7 +188,7 @@ InboundLedger::~InboundLedger()
|
||||
}
|
||||
|
||||
static std::vector<uint256>
|
||||
neededHashes(uint256 const& root, SHAMap& map, int max, SHAMapSyncFilter* filter)
|
||||
neededHashes(uint256 const& root, SHAMap& map, int max, SHAMapSyncFilter const* filter)
|
||||
{
|
||||
std::vector<uint256> ret;
|
||||
|
||||
@@ -211,13 +211,13 @@ neededHashes(uint256 const& root, SHAMap& map, int max, SHAMapSyncFilter* filter
|
||||
}
|
||||
|
||||
std::vector<uint256>
|
||||
InboundLedger::neededTxHashes(int max, SHAMapSyncFilter* filter) const
|
||||
InboundLedger::neededTxHashes(int max, SHAMapSyncFilter const* filter) const
|
||||
{
|
||||
return neededHashes(ledger_->header().txHash, ledger_->txMap(), max, filter);
|
||||
}
|
||||
|
||||
std::vector<uint256>
|
||||
InboundLedger::neededStateHashes(int max, SHAMapSyncFilter* filter) const
|
||||
InboundLedger::neededStateHashes(int max, SHAMapSyncFilter const* filter) const
|
||||
{
|
||||
return neededHashes(ledger_->header().accountHash, ledger_->stateMap(), max, filter);
|
||||
}
|
||||
@@ -820,7 +820,7 @@ InboundLedger::takeHeader(std::string const& data)
|
||||
Call with a lock
|
||||
*/
|
||||
void
|
||||
InboundLedger::receiveNode(protocol::TMLedgerData& packet, SHAMapAddNode& san)
|
||||
InboundLedger::receiveNode(protocol::TMLedgerData const& packet, SHAMapAddNode& san)
|
||||
{
|
||||
if (!haveHeader_)
|
||||
{
|
||||
@@ -1026,7 +1026,7 @@ InboundLedger::gotData(
|
||||
// TODO Change peer to Consumer
|
||||
//
|
||||
int
|
||||
InboundLedger::processData(std::shared_ptr<Peer> peer, protocol::TMLedgerData& packet)
|
||||
InboundLedger::processData(std::shared_ptr<Peer> peer, protocol::TMLedgerData const& packet)
|
||||
{
|
||||
if (packet.type() == protocol::liBASE)
|
||||
{
|
||||
|
||||
@@ -82,7 +82,7 @@ OpenLedger::accept(
|
||||
bool retriesFirst,
|
||||
OrderedTxs& retries,
|
||||
ApplyFlags flags,
|
||||
std::string const& suffix,
|
||||
std::string_view suffix,
|
||||
modify_type const& f)
|
||||
{
|
||||
JLOG(j_.trace()) << "accept ledger " << ledger->seq() << " " << suffix;
|
||||
|
||||
@@ -35,8 +35,8 @@ public:
|
||||
std::uint32_t const ledgerSeq;
|
||||
std::vector<xrpl::uint256> const skipList;
|
||||
|
||||
SkipListData(std::uint32_t const ledgerSeq, std::vector<xrpl::uint256> const& skipList)
|
||||
: ledgerSeq(ledgerSeq), skipList(skipList)
|
||||
SkipListData(std::uint32_t const ledgerSeq, std::vector<xrpl::uint256> skipList)
|
||||
: ledgerSeq(ledgerSeq), skipList(std::move(skipList))
|
||||
{
|
||||
}
|
||||
};
|
||||
|
||||
@@ -492,7 +492,7 @@ public:
|
||||
void
|
||||
run() override;
|
||||
void
|
||||
signalStop(std::string msg) override;
|
||||
signalStop(std::string const& msg) override;
|
||||
bool
|
||||
checkSigs() const override;
|
||||
void
|
||||
@@ -1602,7 +1602,7 @@ ApplicationImp::run()
|
||||
}
|
||||
|
||||
void
|
||||
ApplicationImp::signalStop(std::string msg)
|
||||
ApplicationImp::signalStop(std::string const& msg)
|
||||
{
|
||||
if (!isTimeToStop.test_and_set(std::memory_order_acquire))
|
||||
{
|
||||
|
||||
@@ -111,7 +111,7 @@ public:
|
||||
virtual void
|
||||
run() = 0;
|
||||
virtual void
|
||||
signalStop(std::string msg) = 0;
|
||||
signalStop(std::string const& msg) = 0;
|
||||
[[nodiscard]] virtual bool
|
||||
checkSigs() const = 0;
|
||||
virtual void
|
||||
|
||||
@@ -1777,7 +1777,7 @@ ValidatorList::getAvailable(
|
||||
{
|
||||
std::shared_lock const readLock{mutex_};
|
||||
|
||||
auto const keyBlob = strViewUnHex(pubKey);
|
||||
auto const keyBlob = strUnHex(pubKey);
|
||||
|
||||
if (!keyBlob || !publicKeyType(makeSlice(*keyBlob)))
|
||||
{
|
||||
|
||||
@@ -693,7 +693,7 @@ public:
|
||||
validationSET_EXPIRES ago and were not asked to keep.
|
||||
*/
|
||||
void
|
||||
expire(beast::Journal& j)
|
||||
expire(beast::Journal const& j)
|
||||
{
|
||||
auto const start = std::chrono::steady_clock::now();
|
||||
{
|
||||
|
||||
@@ -117,11 +117,11 @@ public:
|
||||
|
||||
/** Broadcast a proposal. */
|
||||
virtual void
|
||||
broadcast(protocol::TMProposeSet& m) = 0;
|
||||
broadcast(protocol::TMProposeSet const& m) = 0;
|
||||
|
||||
/** Broadcast a validation. */
|
||||
virtual void
|
||||
broadcast(protocol::TMValidation& m) = 0;
|
||||
broadcast(protocol::TMValidation const& m) = 0;
|
||||
|
||||
/** Relay a proposal.
|
||||
* @param m the serialized proposal
|
||||
@@ -130,7 +130,7 @@ public:
|
||||
* @return the set of peers which have already sent us this proposal
|
||||
*/
|
||||
virtual std::set<Peer::id_t>
|
||||
relay(protocol::TMProposeSet& m, uint256 const& uid, PublicKey const& validator) = 0;
|
||||
relay(protocol::TMProposeSet const& m, uint256 const& uid, PublicKey const& validator) = 0;
|
||||
|
||||
/** Relay a validation.
|
||||
* @param m the serialized validation
|
||||
@@ -139,7 +139,7 @@ public:
|
||||
* @return the set of peers which have already sent us this validation
|
||||
*/
|
||||
virtual std::set<Peer::id_t>
|
||||
relay(protocol::TMValidation& m, uint256 const& uid, PublicKey const& validator) = 0;
|
||||
relay(protocol::TMValidation const& m, uint256 const& uid, PublicKey const& validator) = 0;
|
||||
|
||||
/** Relay a transaction. If the tx reduce-relay feature is enabled then
|
||||
* randomly select peers to relay to and queue transaction's hash
|
||||
|
||||
@@ -67,7 +67,7 @@ Cluster::update(
|
||||
iter = nodes_.erase(iter);
|
||||
}
|
||||
|
||||
nodes_.emplace_hint(iter, identity, name, loadFee, reportTime);
|
||||
nodes_.emplace_hint(iter, identity, std::move(name), loadFee, reportTime);
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
@@ -407,7 +407,7 @@ OverlayImpl::makeErrorResponse(
|
||||
std::shared_ptr<PeerFinder::Slot> const& slot,
|
||||
http_request_type const& request,
|
||||
address_type remoteAddress,
|
||||
std::string text)
|
||||
std::string const& text)
|
||||
{
|
||||
boost::beast::http::response<boost::beast::http::empty_body> msg;
|
||||
msg.version(request.version());
|
||||
@@ -1157,14 +1157,14 @@ OverlayImpl::findPeerByPublicKey(PublicKey const& pubKey)
|
||||
}
|
||||
|
||||
void
|
||||
OverlayImpl::broadcast(protocol::TMProposeSet& m)
|
||||
OverlayImpl::broadcast(protocol::TMProposeSet const& m)
|
||||
{
|
||||
auto const sm = std::make_shared<Message>(m, protocol::mtPROPOSE_LEDGER);
|
||||
forEach([&](std::shared_ptr<PeerImp> const& p) { p->send(sm); });
|
||||
}
|
||||
|
||||
std::set<Peer::id_t>
|
||||
OverlayImpl::relay(protocol::TMProposeSet& m, uint256 const& uid, PublicKey const& validator)
|
||||
OverlayImpl::relay(protocol::TMProposeSet const& m, uint256 const& uid, PublicKey const& validator)
|
||||
{
|
||||
if (auto const toSkip = app_.getHashRouter().shouldRelay(uid))
|
||||
{
|
||||
@@ -1179,14 +1179,14 @@ OverlayImpl::relay(protocol::TMProposeSet& m, uint256 const& uid, PublicKey cons
|
||||
}
|
||||
|
||||
void
|
||||
OverlayImpl::broadcast(protocol::TMValidation& m)
|
||||
OverlayImpl::broadcast(protocol::TMValidation const& m)
|
||||
{
|
||||
auto const sm = std::make_shared<Message>(m, protocol::mtVALIDATION);
|
||||
forEach([sm](std::shared_ptr<PeerImp> const& p) { p->send(sm); });
|
||||
}
|
||||
|
||||
std::set<Peer::id_t>
|
||||
OverlayImpl::relay(protocol::TMValidation& m, uint256 const& uid, PublicKey const& validator)
|
||||
OverlayImpl::relay(protocol::TMValidation const& m, uint256 const& uid, PublicKey const& validator)
|
||||
{
|
||||
if (auto const toSkip = app_.getHashRouter().shouldRelay(uid))
|
||||
{
|
||||
|
||||
@@ -202,16 +202,16 @@ public:
|
||||
findPeerByPublicKey(PublicKey const& pubKey) override;
|
||||
|
||||
void
|
||||
broadcast(protocol::TMProposeSet& m) override;
|
||||
broadcast(protocol::TMProposeSet const& m) override;
|
||||
|
||||
void
|
||||
broadcast(protocol::TMValidation& m) override;
|
||||
broadcast(protocol::TMValidation const& m) override;
|
||||
|
||||
std::set<Peer::id_t>
|
||||
relay(protocol::TMProposeSet& m, uint256 const& uid, PublicKey const& validator) override;
|
||||
relay(protocol::TMProposeSet const& m, uint256 const& uid, PublicKey const& validator) override;
|
||||
|
||||
std::set<Peer::id_t>
|
||||
relay(protocol::TMValidation& m, uint256 const& uid, PublicKey const& validator) override;
|
||||
relay(protocol::TMValidation const& m, uint256 const& uid, PublicKey const& validator) override;
|
||||
|
||||
void
|
||||
relay(
|
||||
@@ -433,7 +433,7 @@ private:
|
||||
std::shared_ptr<PeerFinder::Slot> const& slot,
|
||||
http_request_type const& request,
|
||||
address_type remoteAddress,
|
||||
std::string msg);
|
||||
std::string const& msg);
|
||||
|
||||
/** Handles crawl requests. Crawl returns information about the
|
||||
node and its peers so crawlers can map the network.
|
||||
|
||||
@@ -201,7 +201,7 @@ public:
|
||||
file, along with the set of corresponding IP addresses.
|
||||
*/
|
||||
virtual void
|
||||
addFixedPeer(std::string const& name, std::vector<beast::IP::Endpoint> const& addresses) = 0;
|
||||
addFixedPeer(std::string_view name, std::vector<beast::IP::Endpoint> const& addresses) = 0;
|
||||
|
||||
/** Add a set of strings as fallback IP::Endpoint sources.
|
||||
@param name A label used for diagnostics.
|
||||
|
||||
@@ -148,13 +148,13 @@ public:
|
||||
}
|
||||
|
||||
void
|
||||
addFixedPeer(std::string const& name, beast::IP::Endpoint const& ep)
|
||||
addFixedPeer(std::string_view name, beast::IP::Endpoint const& ep)
|
||||
{
|
||||
addFixedPeer(name, std::vector<beast::IP::Endpoint>{ep});
|
||||
}
|
||||
|
||||
void
|
||||
addFixedPeer(std::string const& name, std::vector<beast::IP::Endpoint> const& addresses)
|
||||
addFixedPeer(std::string_view name, std::vector<beast::IP::Endpoint> const& addresses)
|
||||
{
|
||||
std::scoped_lock const _(lock);
|
||||
|
||||
|
||||
@@ -99,8 +99,7 @@ public:
|
||||
}
|
||||
|
||||
void
|
||||
addFixedPeer(std::string const& name, std::vector<beast::IP::Endpoint> const& addresses)
|
||||
override
|
||||
addFixedPeer(std::string_view name, std::vector<beast::IP::Endpoint> const& addresses) override
|
||||
{
|
||||
logic_.addFixedPeer(name, addresses);
|
||||
}
|
||||
|
||||
@@ -42,7 +42,8 @@ public:
|
||||
{
|
||||
}
|
||||
|
||||
Status(ErrorCodeI e, std::string const& s) : type_(Type::ErrorCodeI), code_(e), messages_({s})
|
||||
Status(ErrorCodeI e, std::string s)
|
||||
: type_(Type::ErrorCodeI), code_(e), messages_({std::move(s)})
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
@@ -22,8 +22,8 @@
|
||||
|
||||
namespace xrpl {
|
||||
|
||||
AssetCache::AssetCache(std::shared_ptr<ReadView const> const& ledger, beast::Journal j)
|
||||
: ledger_(ledger), journal_(j)
|
||||
AssetCache::AssetCache(std::shared_ptr<ReadView const> ledger, beast::Journal j)
|
||||
: ledger_(std::move(ledger)), journal_(j)
|
||||
{
|
||||
JLOG(journal_.debug()) << "created for ledger " << ledger_->header().seq;
|
||||
}
|
||||
|
||||
@@ -17,7 +17,7 @@ namespace xrpl {
|
||||
class AssetCache final : public CountedObject<AssetCache>
|
||||
{
|
||||
public:
|
||||
explicit AssetCache(std::shared_ptr<ReadView const> const& l, beast::Journal j);
|
||||
explicit AssetCache(std::shared_ptr<ReadView const> l, beast::Journal j);
|
||||
~AssetCache();
|
||||
|
||||
[[nodiscard]] std::shared_ptr<ReadView const> const&
|
||||
|
||||
@@ -72,7 +72,7 @@ PathRequest::PathRequest(
|
||||
|
||||
PathRequest::PathRequest(
|
||||
Application& app,
|
||||
std::function<void(void)> const& completion,
|
||||
std::function<void(void)> completion,
|
||||
Resource::Consumer& consumer,
|
||||
int id,
|
||||
PathRequestManager& owner,
|
||||
@@ -80,7 +80,7 @@ PathRequest::PathRequest(
|
||||
: app_(app)
|
||||
, journal_(journal)
|
||||
, owner_(owner)
|
||||
, fCompletion_(completion)
|
||||
, fCompletion_(std::move(completion))
|
||||
, consumer_(consumer)
|
||||
, jvStatus_(json::ValueType::Object)
|
||||
, lastIndex_(0)
|
||||
|
||||
@@ -51,7 +51,7 @@ public:
|
||||
// Completion function is called after path update is complete
|
||||
PathRequest(
|
||||
Application& app,
|
||||
std::function<void(void)> const& completion,
|
||||
std::function<void(void)> completion,
|
||||
Resource::Consumer& consumer,
|
||||
int id,
|
||||
PathRequestManager&,
|
||||
|
||||
Reference in New Issue
Block a user