Signed-off-by: JCW <a1q123456@users.noreply.github.com>
This commit is contained in:
JCW
2025-09-14 09:11:29 +01:00
parent e32793ef8a
commit 8b2080d655
5 changed files with 14 additions and 15 deletions

View File

@@ -111,17 +111,17 @@ flow(
ammContext.setMultiPath(strands.size() > 1);
if (j.trace())
if (auto stream = j.trace())
{
j.trace() << "\nsrc: " << src << "\ndst: " << dst
stream << "\nsrc: " << src << "\ndst: " << dst
<< "\nsrcIssue: " << srcIssue << "\ndstIssue: " << dstIssue;
j.trace() << "\nNumStrands: " << strands.size();
stream << "\nNumStrands: " << strands.size();
for (auto const& curStrand : strands)
{
j.trace() << "NumSteps: " << curStrand.size();
stream << "NumSteps: " << curStrand.size();
for (auto const& step : curStrand)
{
j.trace() << '\n' << *step << '\n';
stream << '\n' << *step << '\n';
}
}
}

View File

@@ -565,8 +565,7 @@ getHashesByIndex(
if (!lhO || !phO)
{
auto stream = j.trace();
JLOG(stream) << "Don't have ledger " << ledgerIndex;
JLOG(j.trace()) << "Don't have ledger " << ledgerIndex;
return {};
}

View File

@@ -406,7 +406,7 @@ Slot<clock_type>::update(
v.state = PeerState::Selected;
else if (v.state != PeerState::Squelched)
{
if (journal_.trace())
if (journal_.active(beast::severities::kTrace))
str << k << " ";
v.state = PeerState::Squelched;
std::chrono::seconds duration =

View File

@@ -903,9 +903,9 @@ PeerImp::onReadMessage(error_code ec, std::size_t bytes_transferred)
if (auto stream = journal_.trace())
{
if (bytes_transferred > 0)
stream << "onReadMessage: " << bytes_transferred << " bytes";
std::move(stream) << "onReadMessage: " << bytes_transferred << " bytes";
else
stream << "onReadMessage";
std::move(stream) << "onReadMessage";
}
metrics_.recv.add_message(bytes_transferred);
@@ -962,9 +962,9 @@ PeerImp::onWriteMessage(error_code ec, std::size_t bytes_transferred)
if (auto stream = journal_.trace())
{
if (bytes_transferred > 0)
stream << "onWriteMessage: " << bytes_transferred << " bytes";
std::move(stream) << "onWriteMessage: " << bytes_transferred << " bytes";
else
stream << "onWriteMessage";
std::move(stream) << "onWriteMessage";
}
metrics_.sent.add_message(bytes_transferred);

View File

@@ -950,15 +950,15 @@ SHAMap::fetchRoot(SHAMapHash const& hash, SHAMapSyncFilter* filter)
{
if (type_ == SHAMapType::TRANSACTION)
{
stream << "Fetch root TXN node " << hash;
std::move(stream) << "Fetch root TXN node " << hash;
}
else if (type_ == SHAMapType::STATE)
{
stream << "Fetch root STATE node " << hash;
std::move(stream) << "Fetch root STATE node " << hash;
}
else
{
stream << "Fetch root SHAMap node " << hash;
std::move(stream) << "Fetch root SHAMap node " << hash;
}
}