From de3e823cec6ec12d551f568b73d2ad1061944222 Mon Sep 17 00:00:00 2001
From: Ivan Topolnjak <ivantopo@gmail.com>
Date: Fri, 9 Jun 2017 14:21:01 +0200
Subject: only report sampled spans

---
 kamon-core/src/main/scala/kamon/trace/Span.scala | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

(limited to 'kamon-core/src/main/scala/kamon/trace/Span.scala')

diff --git a/kamon-core/src/main/scala/kamon/trace/Span.scala b/kamon-core/src/main/scala/kamon/trace/Span.scala
index e012d46a..a23c1f49 100644
--- a/kamon-core/src/main/scala/kamon/trace/Span.scala
+++ b/kamon-core/src/main/scala/kamon/trace/Span.scala
@@ -136,13 +136,16 @@ class Span(spanContext: SpanContext, initialOperationName: String, initialTags:
   override def finish(): Unit =
     finish(Clock.microTimestamp())
 
-  override def finish(finishMicros: Long): Unit =
-    if(isOpen) {
+  override def finish(finishMicros: Long): Unit = synchronized {
+    if (isOpen) {
       isOpen = false
       endTimestampMicros = finishMicros
       recordSpanMetrics()
-      reporterRegistry.reportSpan(completedSpan)
+
+      if(sampled)
+        reporterRegistry.reportSpan(completedSpan)
     }
+  }
 
   private def completedSpan: Span.CompletedSpan =
     Span.CompletedSpan(spanContext, operationName, startTimestampMicros, endTimestampMicros, tags, logs)
-- 
cgit v1.2.3