diff --git a/src/main/java/com/commafeed/backend/MetricsBean.java b/src/main/java/com/commafeed/backend/MetricsBean.java index 226d8721..ed3cc53a 100644 --- a/src/main/java/com/commafeed/backend/MetricsBean.java +++ b/src/main/java/com/commafeed/backend/MetricsBean.java @@ -48,6 +48,11 @@ public class MetricsBean { thisMinute.statusesInserted += statusesCount; } + public void threadWaited() { + thisHour.threadWaited++; + thisMinute.threadWaited++; + } + public Metric getLastMinute() { return lastMinute; } @@ -61,6 +66,7 @@ public class MetricsBean { private int feedsUpdated; private int entriesInserted; private int statusesInserted; + private int threadWaited; public int getFeedsRefreshed() { return feedsRefreshed; @@ -94,5 +100,13 @@ public class MetricsBean { this.statusesInserted = statusesInserted; } + public int getThreadWaited() { + return threadWaited; + } + + public void setThreadWaited(int threadWaited) { + this.threadWaited = threadWaited; + } + } } diff --git a/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java b/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java index 73da837a..a2859e89 100644 --- a/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java +++ b/src/main/java/com/commafeed/backend/feeds/FeedRefreshWorker.java @@ -11,6 +11,7 @@ import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import com.commafeed.backend.MetricsBean; import com.commafeed.backend.HttpGetter.NotModifiedException; import com.commafeed.backend.model.Feed; import com.commafeed.backend.model.FeedEntry; @@ -39,6 +40,9 @@ public class FeedRefreshWorker { @Inject FeedPushInfoService feedPushInfoService; + @Inject + MetricsBean metricsBean; + public void start(MutableBoolean running, String threadName) { log.info("{} starting", threadName); @@ -58,6 +62,7 @@ public class FeedRefreshWorker { update(feed); } else { log.debug("sleeping"); + metricsBean.threadWaited(); Thread.sleep(15000); } } catch (InterruptedException e) {