diff options
author | Diego <diegolparra@gmail.com> | 2014-12-03 23:44:38 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2014-12-03 23:44:38 -0300 |
commit | 8bfecac1aa92c98935bda395924c8fab74564229 (patch) | |
tree | 6d17d2f837388c465519fcdf5d7cdd7f3db40d22 /kamon-core/src/main/scala/kamon/trace | |
parent | fcbde8b48a539b649cb5c1237824cdaf6badb370 (diff) | |
download | Kamon-8bfecac1aa92c98935bda395924c8fab74564229.tar.gz Kamon-8bfecac1aa92c98935bda395924c8fab74564229.tar.bz2 Kamon-8bfecac1aa92c98935bda395924c8fab74564229.zip |
= core: use Sequencer instead of AtomicLong
Diffstat (limited to 'kamon-core/src/main/scala/kamon/trace')
-rw-r--r-- | kamon-core/src/main/scala/kamon/trace/Sampler.scala | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/Sampler.scala b/kamon-core/src/main/scala/kamon/trace/Sampler.scala index 650592a5..5e6bef89 100644 --- a/kamon-core/src/main/scala/kamon/trace/Sampler.scala +++ b/kamon-core/src/main/scala/kamon/trace/Sampler.scala @@ -3,6 +3,7 @@ package kamon.trace import java.util.concurrent.atomic.AtomicLong import kamon.NanoInterval +import kamon.util.Sequencer import scala.concurrent.forkjoin.ThreadLocalRandom trait Sampler { @@ -31,9 +32,9 @@ class RandomSampler(chance: Int) extends Sampler { class OrderedSampler(interval: Int) extends Sampler { require(interval > 0, "kamon.trace.ordered-sampler.interval cannot be <= 0") - private val counter = new AtomicLong(0L) - def shouldTrace: Boolean = counter.incrementAndGet() % interval == 0 - // TODO: find a more efficient way to do this, protect from long overflow. + private val sequencer = Sequencer() + + def shouldTrace: Boolean = sequencer.next() % interval == 0 def shouldReport(traceElapsedTime: NanoInterval): Boolean = true } |