diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2017-07-30 11:25:11 +0200 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2017-07-30 11:25:11 +0200 |
commit | 18b9fc25d556fef50c5033f8880fab2594783caa (patch) | |
tree | f9357c04000adb4ee06efb1cc2d3418f7a8d9310 /kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala | |
parent | 0930e36def6ce62c55d30d744b41ef475374a541 (diff) | |
download | Kamon-18b9fc25d556fef50c5033f8880fab2594783caa.tar.gz Kamon-18b9fc25d556fef50c5033f8880fab2594783caa.tar.bz2 Kamon-18b9fc25d556fef50c5033f8880fab2594783caa.zip |
rename ActiveSpanSource into ActiveSpanStorage
Diffstat (limited to 'kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala | 46 |
1 files changed, 0 insertions, 46 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala b/kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala deleted file mode 100644 index f4a363a6..00000000 --- a/kamon-core/src/main/scala/kamon/trace/ActiveSpanSource.scala +++ /dev/null @@ -1,46 +0,0 @@ -package kamon.trace - - -trait Scope extends AutoCloseable { - def close(): Unit -} - -trait ActiveSpanSource { - def activeSpan(): Span - - def activate(span: Span): Scope - def activate(span: Span, finishOnClose: Boolean): Scope -} - -object ActiveSpanSource { - - final class ThreadLocalBased extends ActiveSpanSource { - private val emptySpan = Span.Empty(this) - private val storage: ThreadLocal[Span] = new ThreadLocal[Span] { - override def initialValue(): Span = emptySpan - } - - override def activeSpan(): Span = - storage.get() - - override def activate(span: Span): Scope = - activate(span, finishOnClose = false) - - override def activate(span: Span, finishOnClose: Boolean): Scope = { - val previouslyActiveSpan = storage.get() - storage.set(span) - - new Scope { - override def close(): Unit = { - storage.set(previouslyActiveSpan) - if (finishOnClose && span != null) - span.finish() - } - } - } - } - - object ThreadLocalBased { - def apply(): ThreadLocalBased = new ThreadLocalBased() - } -}
\ No newline at end of file |