[hibernate-commits] Hibernate SVN: r20175 - in search/trunk/hibernate-search/src/main/java/org/hibernate/search: jmx and 1 other directories.

[hibernate-commits at lists.jboss.org]

Author: hardy.ferentschik
Date: 2010-08-19 07:44:21 -0400 (Thu, 19 Aug 2010)
New Revision: 20175

Added:
   search/trunk/hibernate-search/src/main/java/org/hibernate/search/jmx/StatisticsImpl.java
   search/trunk/hibernate-search/src/main/java/org/hibernate/search/jmx/StatisticsImplMBean.java
   search/trunk/hibernate-search/src/main/java/org/hibernate/search/stat/
   search/trunk/hibernate-search/src/main/java/org/hibernate/search/stat/Statistics.java
Log:
HSEARCH-278 Introduced a Statistics interface and implementation. Also exposed it via JMX

Added: search/trunk/hibernate-search/src/main/java/org/hibernate/search/jmx/StatisticsImpl.java
===================================================================
--- search/trunk/hibernate-search/src/main/java/org/hibernate/search/jmx/StatisticsImpl.java	                        (rev 0)
+++ search/trunk/hibernate-search/src/main/java/org/hibernate/search/jmx/StatisticsImpl.java	2010-08-19 11:44:21 UTC (rev 20175)
@@ -0,0 +1,100 @@
+/*
+ * Hibernate, Relational Persistence for Idiomatic Java
+ *
+ *  Copyright (c) 2010, Red Hat, Inc. and/or its affiliates or third-party contributors as
+ *  indicated by the @author tags or express copyright attribution
+ *  statements applied by the authors.  All third-party contributions are
+ *  distributed under license by Red Hat, Inc.
+ *
+ *  This copyrighted material is made available to anyone wishing to use, modify,
+ *  copy, or redistribute it subject to the terms and conditions of the GNU
+ *  Lesser General Public License, as published by the Free Software Foundation.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
+ *  or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public License
+ *  for more details.
+ *
+ *  You should have received a copy of the GNU Lesser General Public License
+ *  along with this distribution; if not, write to:
+ *  Free Software Foundation, Inc.
+ *  51 Franklin Street, Fifth Floor
+ *  Boston, MA  02110-1301  USA
+ */
+package org.hibernate.search.jmx;
+
+import java.util.concurrent.atomic.AtomicLong;
+
+import org.hibernate.search.jmx.StatisticsImplMBean;
+import org.hibernate.search.stat.Statistics;
+
+/**
+ * @author Hardy Ferentschik
+ */
+public class StatisticsImpl implements Statistics, StatisticsImplMBean {
+	private AtomicLong searchQueryCount = new AtomicLong();
+	private AtomicLong searchExecutionAvgTime = new AtomicLong();
+	private AtomicLong searchExecutionTotalTime = new AtomicLong();
+	private AtomicLong searchExecutionMaxTime = new AtomicLong();
+	private AtomicLong searchExecutionMinTime = new AtomicLong();
+	private volatile String queryExecutionMaxTimeQueryString;
+	private volatile boolean isStatisticsEnabled;
+
+
+	public void clear() {
+		searchQueryCount.set( 0 );
+	}
+
+	public long getSearchQueryExecutionCount() {
+		return searchQueryCount.get();
+	}
+
+	public long getSearchQueryExecutionMaxTime() {
+		return searchExecutionMaxTime.get();
+	}
+
+	public long getSearchQueryExecutionMinTime() {
+		return searchExecutionMinTime.get();
+	}
+
+	public long getSearchQueryExecutionAvgTime() {
+		return searchExecutionAvgTime.get();
+	}
+
+	public String getSearchQueryExecutionMaxTimeQueryString() {
+		return queryExecutionMaxTimeQueryString;
+	}
+
+	public void searchExecuted(String searchString, long time) {
+		searchQueryCount.getAndIncrement();
+		boolean isLongestQuery = false;
+		for ( long old = searchExecutionMaxTime.get();
+			  ( time > old ) && ( isLongestQuery = !searchExecutionMaxTime.compareAndSet( old, time ) );
+			  old = searchExecutionMaxTime.get() ) {
+			;
+		}
+		if ( isLongestQuery ) {
+			queryExecutionMaxTimeQueryString = searchString;
+		}
+
+		boolean isShortestQuery = false;
+		for ( long old = searchExecutionMinTime.get();
+			  ( time < old ) && ( isShortestQuery = !searchExecutionMinTime.compareAndSet( old, time ) );
+			  old = searchExecutionMinTime.get() ) {
+			;
+		}
+
+		searchExecutionTotalTime.getAndAdd( time );
+		searchExecutionAvgTime.getAndSet( searchExecutionTotalTime.get() / searchQueryCount.get() );
+	}
+
+	public boolean isStatisticsEnabled() {
+		return isStatisticsEnabled;
+	}
+
+	public void setStatisticsEnabled(boolean b) {
+		isStatisticsEnabled = b;
+	}
+}
+
+

Added: search/trunk/hibernate-search/src/main/java/org/hibernate/search/jmx/StatisticsImplMBean.java
===================================================================
--- search/trunk/hibernate-search/src/main/java/org/hibernate/search/jmx/StatisticsImplMBean.java	                        (rev 0)
+++ search/trunk/hibernate-search/src/main/java/org/hibernate/search/jmx/StatisticsImplMBean.java	2010-08-19 11:44:21 UTC (rev 20175)
@@ -0,0 +1,37 @@
+/*
+ * Hibernate, Relational Persistence for Idiomatic Java
+ *
+ *  Copyright (c) 2010, Red Hat, Inc. and/or its affiliates or third-party contributors as
+ *  indicated by the @author tags or express copyright attribution
+ *  statements applied by the authors.  All third-party contributions are
+ *  distributed under license by Red Hat, Inc.
+ *
+ *  This copyrighted material is made available to anyone wishing to use, modify,
+ *  copy, or redistribute it subject to the terms and conditions of the GNU
+ *  Lesser General Public License, as published by the Free Software Foundation.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
+ *  or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public License
+ *  for more details.
+ *
+ *  You should have received a copy of the GNU Lesser General Public License
+ *  along with this distribution; if not, write to:
+ *  Free Software Foundation, Inc.
+ *  51 Franklin Street, Fifth Floor
+ *  Boston, MA  02110-1301  USA
+ */
+
+// $Id:$
+package org.hibernate.search.jmx;
+
+import org.hibernate.search.stat.Statistics;
+
+/**
+ * @author Hardy Ferentschik
+ */
+public interface StatisticsImplMBean extends Statistics {
+	public static final String STATISTICS_MBEAN_OBJECT_NAME = "org.hibernate.search.jmx:type=StatisticsMBean";
+}
+
+

Added: search/trunk/hibernate-search/src/main/java/org/hibernate/search/stat/Statistics.java
===================================================================
--- search/trunk/hibernate-search/src/main/java/org/hibernate/search/stat/Statistics.java	                        (rev 0)
+++ search/trunk/hibernate-search/src/main/java/org/hibernate/search/stat/Statistics.java	2010-08-19 11:44:21 UTC (rev 20175)
@@ -0,0 +1,10 @@
+// $Id:$
+package org.hibernate.search.stat;
+
+/**
+ * @author Hardy Ferentschik
+ */
+public class Statistics {
+}
+
+