|
104 | 104 | #include "src/core/telemetry/call_tracer.h" |
105 | 105 | #include "src/core/telemetry/stats.h" |
106 | 106 | #include "src/core/telemetry/stats_data.h" |
107 | | -#include "src/core/telemetry/tcp_tracer.h" |
108 | 107 | #include "src/core/util/bitset.h" |
109 | 108 | #include "src/core/util/crash.h" |
110 | 109 | #include "src/core/util/debug_location.h" |
@@ -237,16 +236,6 @@ grpc_core::CallTracerAnnotationInterface* ParentCallTracerIfSampled( |
237 | 236 | return parent_call_tracer; |
238 | 237 | } |
239 | 238 |
|
240 | | -std::shared_ptr<grpc_core::TcpTracerInterface> TcpTracerIfSampled( |
241 | | - grpc_chttp2_stream* s) { |
242 | | - auto* call_attempt_tracer = |
243 | | - s->arena->GetContext<grpc_core::CallTracerInterface>(); |
244 | | - if (call_attempt_tracer == nullptr || !call_attempt_tracer->IsSampled()) { |
245 | | - return nullptr; |
246 | | - } |
247 | | - return call_attempt_tracer->StartNewTcpTrace(); |
248 | | -} |
249 | | - |
250 | 239 | grpc_core::WriteTimestampsCallback g_write_timestamps_callback = nullptr; |
251 | 240 | grpc_core::CopyContextFn g_get_copied_context_fn = nullptr; |
252 | 241 | } // namespace |
@@ -856,8 +845,7 @@ grpc_chttp2_stream::grpc_chttp2_stream(grpc_chttp2_transport* t, |
856 | 845 | }()), |
857 | 846 | arena(arena), |
858 | 847 | flow_control(&t->flow_control), |
859 | | - call_tracer_wrapper(this), |
860 | | - tcp_tracer(TcpTracerIfSampled(this)) { |
| 848 | + call_tracer_wrapper(this) { |
861 | 849 | t->streams_allocated.fetch_add(1, std::memory_order_relaxed); |
862 | 850 | if (server_data) { |
863 | 851 | id = static_cast<uint32_t>(reinterpret_cast<uintptr_t>(server_data)); |
|
0 commit comments