rgw,osd: convert tracer to be a global var

since we are using batch span processor, the tracer does not send the
spans by himself. so a single tracer is good enough.
Signed-off-by: Omri Zeneva <ozeneva@redhat.com>

diff --git a/src/common/tracer.cc b/src/common/tracer.cc
index f908ffe3185261b2c050d3f8235af273c42e4533..1068bf5c2ccf0794645e01795ebc99e4037e5676 100644 (file)
--- a/src/common/tracer.cc
+++ b/src/common/tracer.cc
@@ -33,12 +33,6 @@ void Tracer::init(opentelemetry::nostd::string_view service_name) {
   }
 }
 
-void Tracer::shutdown() {
-  if (tracer) {
-    tracer->CloseWithMicroseconds(1);
-  }
-}
-
 jspan Tracer::start_trace(opentelemetry::nostd::string_view trace_name) {
   if (is_enabled()) {
     return tracer->StartSpan(trace_name);

diff --git a/src/common/tracer.h b/src/common/tracer.h
index 1ad57e91f56a10e27bb1475efc30117ba8e89a01..5d77a0dcf159c37e4a471f5bb8ab5bff6c255b73 100644 (file)
--- a/src/common/tracer.h
+++ b/src/common/tracer.h
@@ -25,7 +25,6 @@ class Tracer {
   Tracer(opentelemetry::nostd::string_view service_name);
 
   void init(opentelemetry::nostd::string_view service_name);
-  void shutdown();
 
   bool is_enabled() const;
   // creates and returns a new span with `trace_name`
@@ -95,7 +94,6 @@ struct Tracer {
   jspan add_span(std::string_view, const jspan&) { return {}; }
   jspan add_span(std::string_view span_name, const jspan_context& parent_ctx) { return {}; }
   void init(std::string_view service_name) {}
-  void shutdown() {}
 };
   inline void encode(const jspan_context& span, bufferlist& bl, uint64_t f=0) {}
   inline void decode(jspan_context& span_ctx, ceph::buffer::list::const_iterator& bl) {}

diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index 51c07df251160268c75ba04f320c3dd648ba8fee..dc58cb438827df34872174453556b30b3ce9ec14 100644 (file)
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -4521,7 +4521,6 @@ int OSD::shutdown()
   utime_t duration = ceph_clock_now() - start_time_func;
   dout(0) <<"Slow Shutdown duration:" << duration << " seconds" << dendl;
 
-  tracing::osd::tracer.shutdown();
 
   return r;
 }

diff --git a/src/rgw/rgw_main.cc b/src/rgw/rgw_main.cc
index f2fc502a70fb9ed6cbe7545d2ef8a41758785858..1189e3660b6b55a7ae4c507fff5f4ee9e8159284 100644 (file)
--- a/src/rgw/rgw_main.cc
+++ b/src/rgw/rgw_main.cc
@@ -334,7 +334,7 @@ int radosgw_Main(int argc, const char **argv)
     derr << "ERROR: unable to initialize rgw tools" << dendl;
     return -r;
   }
-
+  tracing::rgw::tracer.init("rgw");
   rgw_init_resolver();
   rgw::curl::setup_curl(fe_map);
   rgw_http_client_init(g_ceph_context);

diff --git a/src/rgw/rgw_tracer.cc b/src/rgw/rgw_tracer.cc
index 2d6720f591bac0c012a4441b1883a3d6938c76d8..7e12bb2e62dcc442946dafc889f58cdd913ca985 100644 (file)
--- a/src/rgw/rgw_tracer.cc
+++ b/src/rgw/rgw_tracer.cc
@@ -7,11 +7,7 @@
 namespace tracing {
 namespace rgw {
 
-#ifdef HAVE_JAEGER
-thread_local tracing::Tracer tracer("rgw");
-#else // !HAVE_JAEGER
 tracing::Tracer tracer;
-#endif
 
 } // namespace rgw
 } // namespace tracing

diff --git a/src/rgw/rgw_tracer.h b/src/rgw/rgw_tracer.h
index 77d4689d257e366bb5f2dd82dc3cb946d9aa902d..9cbae8b9c6792760fd5022dd2d7f6e636d37c181 100644 (file)
--- a/src/rgw/rgw_tracer.h
+++ b/src/rgw/rgw_tracer.h
@@ -18,11 +18,7 @@ const auto TYPE = "type";
 const auto REQUEST = "request";
 const auto MULTIPART = "multipart_upload ";
 
-#ifdef HAVE_JAEGER
-extern thread_local tracing::Tracer tracer;
-#else
 extern tracing::Tracer tracer;
-#endif
 
 } // namespace rgw
 } // namespace tracing