From 63321f6467f173dc8ca16ed9e7b048b484d681e9 Mon Sep 17 00:00:00 2001
From: Ivan Topolnjak <ivantopo@gmail.com>
Date: Fri, 1 Apr 2016 13:20:20 +0200
Subject: core: catch any exception being thrown when recording values on
 histograms

fixes #232, fixes #332
---
 .../scala/kamon/metric/instrument/Histogram.scala     | 19 +++++++++++++++++--
 1 file changed, 17 insertions(+), 2 deletions(-)

(limited to 'kamon-core/src/main/scala/kamon/metric/instrument')

diff --git a/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala b/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala
index dc9a4bbf..77cb503b 100644
--- a/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala
+++ b/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala
@@ -20,6 +20,7 @@ import java.nio.LongBuffer
 
 import kamon.metric.instrument.Histogram.{ DynamicRange, Snapshot }
 import org.HdrHistogram.ModifiedAtomicHistogram
+import org.slf4j.LoggerFactory
 
 trait Histogram extends Instrument {
   type SnapshotType = Histogram.Snapshot
@@ -135,6 +136,10 @@ object Histogram {
   }
 }
 
+object HdrHistogram {
+  private val log = LoggerFactory.getLogger(classOf[HdrHistogram])
+}
+
 /**
  *  This implementation is meant to be used for real time data collection where data snapshots are taken often over time.
  *  The collect(..) operation extracts all the recorded values from the histogram and resets the counts, but still
@@ -142,10 +147,20 @@ object Histogram {
  */
 class HdrHistogram(dynamicRange: DynamicRange) extends ModifiedAtomicHistogram(dynamicRange.lowestDiscernibleValue,
   dynamicRange.highestTrackableValue, dynamicRange.precision) with Histogram {
+  import HdrHistogram.log
+
+  def record(value: Long): Unit = tryRecord(value, 1L)
 
-  def record(value: Long): Unit = recordValue(value)
+  def record(value: Long, count: Long): Unit = tryRecord(value, count)
 
-  def record(value: Long, count: Long): Unit = recordValueWithCount(value, count)
+  private def tryRecord(value: Long, count: Long): Unit = {
+    try {
+      recordValueWithCount(value, count)
+    } catch {
+      case anyException: Throwable ⇒
+        log.warn("Failed to store value {} in HdrHistogram, please review your range configuration.")
+    }
+  }
 
   def collect(context: CollectionContext): Histogram.Snapshot = {
     import context.buffer
-- 
cgit v1.2.3