incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [4/8] git commit: Added metrics.
Date Sun, 31 Mar 2013 01:46:18 GMT
Added metrics.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/0212a39c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/0212a39c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/0212a39c

Branch: refs/heads/0.1.5
Commit: 0212a39c79d8c398ab150b944e80aa2063d3ac39
Parents: 4ef6e5c
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Sat Mar 30 21:40:44 2013 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Sat Mar 30 21:40:44 2013 -0400

----------------------------------------------------------------------
 .../apache/blur/store/blockcache/BlockCache.java   |   23 ++++++++++++--
 1 files changed, 19 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/0212a39c/src/blur-store/src/main/java/org/apache/blur/store/blockcache/BlockCache.java
----------------------------------------------------------------------
diff --git a/src/blur-store/src/main/java/org/apache/blur/store/blockcache/BlockCache.java
b/src/blur-store/src/main/java/org/apache/blur/store/blockcache/BlockCache.java
index b2947b9..7a3eb99 100644
--- a/src/blur-store/src/main/java/org/apache/blur/store/blockcache/BlockCache.java
+++ b/src/blur-store/src/main/java/org/apache/blur/store/blockcache/BlockCache.java
@@ -26,6 +26,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 import com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap;
 import com.googlecode.concurrentlinkedhashmap.EvictionListener;
 import com.yammer.metrics.Metrics;
+import com.yammer.metrics.core.Gauge;
 import com.yammer.metrics.core.Meter;
 import com.yammer.metrics.core.MetricName;
 
@@ -33,6 +34,7 @@ public class BlockCache {
 
   public static final int _128M = 134217728;
   public static final int _8K = 8192;
+
   private final ConcurrentMap<BlockCacheKey, BlockCacheLocation> _cache;
   private final ByteBuffer[] _slabs;
   private final BlockLocks[] _locks;
@@ -63,8 +65,20 @@ public class BlockCache {
       _locks[i] = new BlockLocks(_numberOfBlocksPerSlab);
       _lockCounters[i] = new AtomicInteger();
     }
-    
+
     evictions = Metrics.newMeter(new MetricName(ORG_APACHE_BLUR, CACHE, EVICTION), EVICTION,
TimeUnit.SECONDS);
+    Metrics.newGauge(new MetricName(ORG_APACHE_BLUR, CACHE, ENTRIES), new Gauge<Long>()
{
+      @Override
+      public Long value() {
+        return (long) getSize();
+      }
+    });
+    Metrics.newGauge(new MetricName(ORG_APACHE_BLUR, CACHE, SIZE), new Gauge<Long>()
{
+      @Override
+      public Long value() {
+        return ((long) getSize()) * (long) _8K;
+      }
+    });
 
     EvictionListener<BlockCacheKey, BlockCacheLocation> listener = new EvictionListener<BlockCacheKey,
BlockCacheLocation>() {
       @Override
@@ -73,7 +87,8 @@ public class BlockCache {
         evictions.mark();
       }
     };
-    _cache = new ConcurrentLinkedHashMap.Builder<BlockCacheKey, BlockCacheLocation>().maximumWeightedCapacity(_maxEntries).listener(listener).build();
+    _cache = new ConcurrentLinkedHashMap.Builder<BlockCacheKey, BlockCacheLocation>()
+        .maximumWeightedCapacity(_maxEntries).listener(listener).build();
   }
 
   private void releaseLocation(BlockCacheLocation location) {
@@ -89,8 +104,8 @@ public class BlockCache {
 
   public boolean store(BlockCacheKey blockCacheKey, int blockOffset, byte[] data, int offset,
int length) {
     if (length + blockOffset > _blockSize) {
-      throw new RuntimeException("Buffer size exceeded, expecting max ["
-          + _blockSize + "] got length [" + length + "] with blockOffset [" + blockOffset
+ "]" );
+      throw new RuntimeException("Buffer size exceeded, expecting max [" + _blockSize + "]
got length [" + length
+          + "] with blockOffset [" + blockOffset + "]");
     }
     BlockCacheLocation location = _cache.get(blockCacheKey);
     boolean newLocation = false;


Mime
View raw message