From 8c080a581e344c188d84a70f291df2f257a3096b Mon Sep 17 00:00:00 2001
From: Athou <jeremiepanzer@gmail.com>
Date: Fri, 28 Jun 2013 22:31:40 +0200
Subject: [PATCH] metrics for entry cache

---
 src/main/java/com/commafeed/backend/MetricsBean.java | 12 ++++++++++++
 .../commafeed/backend/feeds/FeedRefreshUpdater.java  |  6 ++++--
 2 files changed, 16 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/commafeed/backend/MetricsBean.java b/src/main/java/com/commafeed/backend/MetricsBean.java
index e7e921c9..9a984e89 100644
--- a/src/main/java/com/commafeed/backend/MetricsBean.java
+++ b/src/main/java/com/commafeed/backend/MetricsBean.java
@@ -64,6 +64,16 @@ public class MetricsBean {
 		thisMinute.statusesInserted += statusesCount;
 	}
 
+	public void entryCacheHit() {
+		thisHour.entryCacheHit++;
+		thisMinute.entryCacheHit++;
+	}
+
+	public void entryCacheMiss() {
+		thisHour.entryCacheMiss++;
+		thisMinute.entryCacheMiss++;
+	}
+
 	public void pushReceived(int feedCount) {
 
 		thisHour.pushNotificationsReceived++;
@@ -101,6 +111,8 @@ public class MetricsBean {
 		private int threadWaited;
 		private int pushNotificationsReceived;
 		private int pushFeedsQueued;
+		private int entryCacheHit;
+		private int entryCacheMiss;
 
 		public int getFeedsRefreshed() {
 			return feedsRefreshed;
diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
index c56d2427..6e6b556f 100644
--- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
+++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshUpdater.java
@@ -172,11 +172,13 @@ public class FeedRefreshUpdater {
 			locked = lock.tryLock(1, TimeUnit.MINUTES);
 			if (locked) {
 				if (!cache.hasFeedEntry(feed, entry)) {
-					log.info("cache miss for {}", entry.getUrl());
+					log.debug("cache miss for {}", entry.getUrl());
 					feedUpdateService.updateEntry(feed, entry, subscriptions);
 					cache.putFeedEntry(feed, entry);
+					metricsBean.entryCacheMiss();
 				} else {
-					log.info("cache hit for {}", entry.getUrl());
+					log.debug("cache hit for {}", entry.getUrl());
+					metricsBean.entryCacheHit();
 				}
 				success = true;
 			} else {