aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/metric/Counter.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/Counter.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/metric/Counter.scala12
1 files changed, 4 insertions, 8 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/Counter.scala b/kamon-core/src/main/scala/kamon/metric/Counter.scala
index bbcce858..b5f8353c 100644
--- a/kamon-core/src/main/scala/kamon/metric/Counter.scala
+++ b/kamon-core/src/main/scala/kamon/metric/Counter.scala
@@ -15,9 +15,8 @@
package kamon.metric
-import java.util.concurrent.atomic.LongAdder
-
import com.typesafe.scalalogging.StrictLogging
+import kamon.jsr166.LongAdder
import kamon.util.MeasurementUnit
trait Counter {
@@ -36,12 +35,9 @@ class LongAdderCounter(name: String, tags: Map[String, String], val measurementU
adder.increment()
def increment(times: Long): Unit = {
- if (times >= 0)
- adder.add(times)
- else
- logger.warn(s"Ignored attempt to decrement counter [$name]")
+ if (times >= 0) adder.add(times)
+ else logger.warn(s"Ignored attempt to decrement counter [$name]")
}
- def snapshot(): MetricValue =
- MetricValue(name, tags, measurementUnit, adder.sumThenReset())
+ def snapshot(): MetricValue = MetricValue(name, tags, measurementUnit, adder.sumAndReset())
}