Add ForceFlush to TracerProvider in SDK

CHANGELOG.md

@@ -15,6 +15,8 @@ Increment the:
 
 ## [Unreleased]
 
+* Added `ForceFlush` to `TracerProvider` in SDK. ([#588](https://github.com/open-telemetry/opentelemetry-cpp/pull/588)).
+
 ## [0.0.1] 2020-12-16
 
 ### Added

sdk/include/opentelemetry/sdk/trace/tracer_provider.h

@@ -66,6 +66,11 @@ class TracerProvider final : public opentelemetry::trace::TracerProvider
    */
   bool Shutdown() noexcept;
 
+  /**
+   * Force flush the span processor associated with this tracer provider.
+   */
+  bool ForceFlush(std::chrono::microseconds timeout = (std::chrono::microseconds::max)()) noexcept;
+
 private:
   opentelemetry::sdk::AtomicSharedPtr<SpanProcessor> processor_;
   std::shared_ptr<opentelemetry::trace::Tracer> tracer_;

sdk/src/logs/logger.cc

@@ -89,7 +89,7 @@ void Logger::Log(opentelemetry::logs::Severity severity,
   // Leave these fields in the recordable empty if neither the passed in values
   // nor the context values are valid (e.g. the application is not using traces)
 
-  // Traceid
+  // TraceId
   if (trace_id.IsValid())
   {
     recordable->SetTraceId(trace_id);
@@ -99,7 +99,7 @@ void Logger::Log(opentelemetry::logs::Severity severity,
     recordable->SetTraceId(span_context.trace_id());
   }
 
-  // Spanid
+  // SpanId
   if (span_id.IsValid())
   {
     recordable->SetSpanId(span_id);
@@ -109,7 +109,7 @@ void Logger::Log(opentelemetry::logs::Severity severity,
     recordable->SetSpanId(span_id);
   }
 
-  // Traceflags
+  // TraceFlags
   if (trace_flags.IsSampled())
   {
     recordable->SetTraceFlags(trace_flags);

sdk/src/trace/tracer_provider.cc

@@ -48,6 +48,11 @@ bool TracerProvider::Shutdown() noexcept
 {
   return GetProcessor()->Shutdown();
 }
+
+bool TracerProvider::ForceFlush(std::chrono::microseconds timeout) noexcept
+{
+  return GetProcessor()->ForceFlush(timeout);
+}
 }  // namespace trace
 }  // namespace sdk
 OPENTELEMETRY_END_NAMESPACE

sdk/test/trace/tracer_provider_test.cc

@@ -70,3 +70,12 @@ TEST(TracerProvider, Shutdown)
 
   EXPECT_TRUE(tp1.Shutdown());
 }
+
+TEST(TracerProvider, ForceFlush)
+{
+  std::shared_ptr<SpanProcessor> processor1(new SimpleSpanProcessor(nullptr));
+
+  TracerProvider tp1(processor1);
+
+  EXPECT_TRUE(tp1.ForceFlush());
+}