Merge branch 'pratik/otel-phase3-tx-tracing' into pratik/otel-phase4-consensus-tracing

# Conflicts:
#	src/xrpld/app/consensus/RCLConsensus.cpp
This commit is contained in:
Pratik Mankawde
2026-04-29 19:58:45 +01:00
7 changed files with 12 additions and 26 deletions

View File

@@ -66,7 +66,7 @@
#include <xrpl/telemetry/SpanGuard.h>
#include <xrpl/telemetry/SpanNames.h>
#include <xrpl/telemetry/Telemetry.h>
#include <xrpl/telemetry/TraceContextPropagator.h>
#include <xrpl/telemetry/TraceContextPropagator.h> // IWYU pragma: keep
#include <boost/smart_ptr/intrusive_ptr.hpp>

View File

@@ -17,9 +17,7 @@
#include <xrpl/telemetry/SpanNames.h>
namespace xrpl {
namespace telemetry {
namespace tx_span {
namespace xrpl::telemetry::tx_span {
// ===== Span prefixes =======================================================
@@ -72,6 +70,4 @@ inline constexpr auto async = makeStr("async");
inline constexpr auto knownBad = makeStr("known_bad");
} // namespace val
} // namespace tx_span
} // namespace telemetry
} // namespace xrpl
} // namespace xrpl::telemetry::tx_span

View File

@@ -6,6 +6,7 @@
#include <xrpl/basics/BasicConfig.h>
#include <xrpl/basics/Log.h>
#include <xrpl/basics/base_uint.h>
#include <xrpl/basics/contract.h>
#include <xrpl/basics/mulDiv.h>
#include <xrpl/beast/utility/Zero.h>
@@ -30,7 +31,6 @@
#include <xrpl/protocol/Units.h>
#include <xrpl/protocol/XRPAmount.h>
#include <xrpl/protocol/jss.h>
#include <xrpl/protocol/st.h>
#include <xrpl/telemetry/SpanGuard.h>
#include <xrpl/tx/apply.h>
#include <xrpl/tx/applySteps.h>

View File

@@ -48,9 +48,7 @@
#include <xrpl/telemetry/SpanNames.h>
namespace xrpl {
namespace telemetry {
namespace txq_span {
namespace xrpl::telemetry::txq_span {
// ===== Span prefixes =======================================================
@@ -110,6 +108,4 @@ inline constexpr auto failed = makeStr("failed");
inline constexpr auto retried = makeStr("retried");
} // namespace val
} // namespace txq_span
} // namespace telemetry
} // namespace xrpl
} // namespace xrpl::telemetry::txq_span

View File

@@ -39,8 +39,7 @@
#include <xrpl/proto/xrpl.pb.h>
#include <xrpl/telemetry/SpanGuard.h>
namespace xrpl {
namespace telemetry {
namespace xrpl::telemetry {
// Inline span name constants for consensus receive spans.
// Phase 4 will provide these via ConsensusSpanNames.h; these are
@@ -123,5 +122,4 @@ validationReceiveSpan([[maybe_unused]] protocol::TMValidation const& msg)
return SpanGuard::span(TraceCategory::Consensus, "consensus", "validation.receive");
}
} // namespace telemetry
} // namespace xrpl
} // namespace xrpl::telemetry

View File

@@ -32,8 +32,7 @@
#include <xrpl/proto/xrpl.pb.h>
#include <xrpl/telemetry/SpanGuard.h>
namespace xrpl {
namespace telemetry {
namespace xrpl::telemetry {
/** Inject trace context from an active SpanGuard into a protobuf
* TraceContext message for cross-node propagation.
@@ -58,5 +57,4 @@ injectSpanContext(SpanGuard const& span, protocol::TraceContext& proto)
proto.set_trace_flags(bytes.traceFlags);
}
} // namespace telemetry
} // namespace xrpl
} // namespace xrpl::telemetry

View File

@@ -16,8 +16,7 @@
#include <xrpl/proto/xrpl.pb.h>
#include <xrpl/telemetry/SpanGuard.h>
namespace xrpl {
namespace telemetry {
namespace xrpl::telemetry {
/** Create a "tx.receive" span for a transaction received from a peer.
* trace_id is derived from txID[0:16]. If the incoming message carries
@@ -59,5 +58,4 @@ txProcessSpan(uint256 const& txID)
TraceCategory::Transactions, tx_span::process, txID.data(), txID.bytes);
}
} // namespace telemetry
} // namespace xrpl
} // namespace xrpl::telemetry