diff options
author | alexvru <alexvru@ydb.tech> | 2022-08-19 10:27:11 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2022-08-19 10:27:11 +0300 |
commit | e1dcf8f2a1ac55ca08605859d925559cabe89e6f (patch) | |
tree | 2ec57565e13cefe22b97489c887d8d8eba1592c7 /library/cpp/actors/interconnect | |
parent | 29d668fad4b1b4ebcc8b4935be04ccb616ba81a7 (diff) | |
download | ydb-e1dcf8f2a1ac55ca08605859d925559cabe89e6f.tar.gz |
Fix Wilson verbosity and PipeCache TraceId forwarding
Diffstat (limited to 'library/cpp/actors/interconnect')
-rw-r--r-- | library/cpp/actors/interconnect/interconnect_channel.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/library/cpp/actors/interconnect/interconnect_channel.h b/library/cpp/actors/interconnect/interconnect_channel.h index 8849d19b92..58783d3c8d 100644 --- a/library/cpp/actors/interconnect/interconnect_channel.h +++ b/library/cpp/actors/interconnect/interconnect_channel.h @@ -59,10 +59,10 @@ namespace NActors { TEventHolder& event = Pool.Allocate(Queue); const ui32 bytes = event.Fill(ev) + (Params.UseExtendedTraceFmt ? sizeof(TEventDescr2) : sizeof(TEventDescr1)); OutputQueueSize += bytes; - if (auto span = NWilson::TSpan(15 /*max verbosity*/, NWilson::TTraceId(ev.TraceId), "Interconnect.Queue")) { - event.Span = std::move(span + if (event.Span = NWilson::TSpan(15 /*max verbosity*/, NWilson::TTraceId(ev.TraceId), "Interconnect.Queue")) { + event.Span .Attribute("OutputQueueItems", static_cast<i64>(Queue.size())) - .Attribute("OutputQueueSize", static_cast<i64>(OutputQueueSize))); + .Attribute("OutputQueueSize", static_cast<i64>(OutputQueueSize)); } return std::make_pair(bytes, &event); } |