You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2009/09/02 17:24:00 UTC
svn commit: r810560 [4/4] - in
/incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae:
handler/ handler/input/ jmx/
Modified: incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformance.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformance.java?rev=810560&r1=810559&r2=810560&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformance.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformance.java Wed Sep 2 15:23:59 2009
@@ -25,398 +25,350 @@
import org.apache.uima.aae.controller.AnalysisEngineController;
+public class ServicePerformance implements ServicePerformanceMBean {
+ private static final long serialVersionUID = 1L;
-public class ServicePerformance implements ServicePerformanceMBean
-{
- private static final long serialVersionUID = 1L;
- private static final String label="Service Performance";
- private long idleTime=0;
- private long numberOfCASesProcessed=0;
- private long casDeserializationTime=0;
- private long casSerializationTime=0;
- private long analysisTime=0;
- private long maxSerializationTime=0;
- private long maxDeserializationTime=0;
- private long maxAnalysisTime=0;
- private long casPoolWaitTime=0;
- private long shadowCasPoolWaitTime=0;
- private long timeSpentInCMGetNext = 0;
- private Object sem = new Object();
- private AnalysisEngineController controller;
- private boolean isRemoteDelegate = false;
- private long uptime = System.nanoTime();
- long lastUpdate=System.nanoTime();
- private int processThreadCount=1;
-
- private Object waitmux = new Object();
-
- private boolean waitingForCAS = false;
-
- private long totalWaitTimeForCAS = 0;
-
- private long lastCASWaitTimeUpdate = 0;
-
- private Object shadowPoolMux = new Object();
- private boolean waitingForSPCAS = false;
- private long lastSPCASWaitTimeUpdate = 0;
-
- private Object getNextMux = new Object();
- private boolean waitingInGetNext = false;
- private long lastGetNextWaitTimeUpdate = 0;
- private long totalGetNextWaitTime = 0;
-
- public ServicePerformance()
- {
- }
-
- public ServicePerformance(AnalysisEngineController aController)
- {
- controller = aController;
- }
-
- public void setRemoteDelegate()
- {
- isRemoteDelegate = true;
- }
- public String getLabel()
- {
- return label;
- }
-
- public synchronized void reset()
- {
- idleTime = 0;
- numberOfCASesProcessed=0;
- casDeserializationTime=0;
- casSerializationTime=0;
- casPoolWaitTime = 0;
- shadowCasPoolWaitTime=0;
- analysisTime=0;
- maxSerializationTime=0;
- maxDeserializationTime=0;
- maxAnalysisTime=0;
- timeSpentInCMGetNext = 0;
- uptime = System.nanoTime();
- }
-
-
- public void setIdleTime( long anIdleTime )
- {
- synchronized( sem )
- {
- idleTime = anIdleTime;
- }
- }
- public double getIdleTime()
- {
-
- if ( controller != null )
- {
- // Force update of the idle time
- return ((double)controller.getIdleTime()/(double) 1000000);
- }
- else
- {
- synchronized( sem )
- {
- return ((double)idleTime/(double) 1000000);
- }
-
- }
- }
-
- public long getRawIdleTime()
- {
- return idleTime;
- }
- public void incrementIdleTime(long anIdleTime)
- {
- synchronized( sem )
- {
- idleTime += anIdleTime;
- lastUpdate = System.nanoTime();
- }
- }
-
- /**
- * Adjust the analysis time. This method is called when a reply is received from a remote
- * delegate. Each reply message containing a CAS include the current actual analysis time
- * This is not a delta, its the running analysis time.
- *
- * @param anAnalysisTime
- */
- public synchronized void setAnalysisTime( long anAnalysisTime )
- {
- analysisTime = anAnalysisTime;
- }
- public synchronized void incrementAnalysisTime( long anAnalysisTime )
- {
- synchronized(sem)
- {
- if ( maxAnalysisTime < anAnalysisTime )
- {
- maxAnalysisTime = anAnalysisTime;
- }
- analysisTime += anAnalysisTime;
- }
- }
-
- public synchronized double getAnalysisTime()
- {
- if ( controller != null )
- {
- return ((double)controller.getAnalysisTime()/(double) 1000000);
- }
- else
- {
- synchronized( sem )
- {
- return (double)analysisTime/(double)1000000;
- }
-
- }
-
-
- }
-
- public synchronized long getRawAnalysisTime()
- {
- if ( controller != null )
- {
- return controller.getAnalysisTime();
+ private static final String label = "Service Performance";
+
+ private long idleTime = 0;
+
+ private long numberOfCASesProcessed = 0;
+
+ private long casDeserializationTime = 0;
+
+ private long casSerializationTime = 0;
+
+ private long analysisTime = 0;
+
+ private long maxSerializationTime = 0;
+
+ private long maxDeserializationTime = 0;
+
+ private long maxAnalysisTime = 0;
+
+ private long casPoolWaitTime = 0;
+
+ private long shadowCasPoolWaitTime = 0;
+
+ private long timeSpentInCMGetNext = 0;
+
+ private Object sem = new Object();
+
+ private AnalysisEngineController controller;
+
+ private boolean isRemoteDelegate = false;
+
+ private long uptime = System.nanoTime();
+
+ long lastUpdate = System.nanoTime();
+
+ private int processThreadCount = 1;
+
+ private Object waitmux = new Object();
+
+ private boolean waitingForCAS = false;
+
+ private long totalWaitTimeForCAS = 0;
+
+ private long lastCASWaitTimeUpdate = 0;
+
+ private Object shadowPoolMux = new Object();
+
+ private boolean waitingForSPCAS = false;
+
+ private long lastSPCASWaitTimeUpdate = 0;
+
+ private Object getNextMux = new Object();
+
+ private boolean waitingInGetNext = false;
+
+ private long lastGetNextWaitTimeUpdate = 0;
+
+ private long totalGetNextWaitTime = 0;
+
+ public ServicePerformance() {
+ }
+
+ public ServicePerformance(AnalysisEngineController aController) {
+ controller = aController;
+ }
+
+ public void setRemoteDelegate() {
+ isRemoteDelegate = true;
+ }
+
+ public String getLabel() {
+ return label;
+ }
+
+ public synchronized void reset() {
+ idleTime = 0;
+ numberOfCASesProcessed = 0;
+ casDeserializationTime = 0;
+ casSerializationTime = 0;
+ casPoolWaitTime = 0;
+ shadowCasPoolWaitTime = 0;
+ analysisTime = 0;
+ maxSerializationTime = 0;
+ maxDeserializationTime = 0;
+ maxAnalysisTime = 0;
+ timeSpentInCMGetNext = 0;
+ uptime = System.nanoTime();
+ }
+
+ public void setIdleTime(long anIdleTime) {
+ synchronized (sem) {
+ idleTime = anIdleTime;
+ }
+ }
+
+ public double getIdleTime() {
+
+ if (controller != null) {
+ // Force update of the idle time
+ return ((double) controller.getIdleTime() / (double) 1000000);
+ } else {
+ synchronized (sem) {
+ return ((double) idleTime / (double) 1000000);
+ }
+
+ }
+ }
+
+ public long getRawIdleTime() {
+ return idleTime;
+ }
+
+ public void incrementIdleTime(long anIdleTime) {
+ synchronized (sem) {
+ idleTime += anIdleTime;
+ lastUpdate = System.nanoTime();
+ }
+ }
+
+ /**
+ * Adjust the analysis time. This method is called when a reply is received from a remote
+ * delegate. Each reply message containing a CAS include the current actual analysis time This is
+ * not a delta, its the running analysis time.
+ *
+ * @param anAnalysisTime
+ */
+ public synchronized void setAnalysisTime(long anAnalysisTime) {
+ analysisTime = anAnalysisTime;
+ }
+
+ public synchronized void incrementAnalysisTime(long anAnalysisTime) {
+ synchronized (sem) {
+ if (maxAnalysisTime < anAnalysisTime) {
+ maxAnalysisTime = anAnalysisTime;
+ }
+ analysisTime += anAnalysisTime;
}
- else
- {
- synchronized( sem )
- {
+ }
+
+ public synchronized double getAnalysisTime() {
+ if (controller != null) {
+ return ((double) controller.getAnalysisTime() / (double) 1000000);
+ } else {
+ synchronized (sem) {
+ return (double) analysisTime / (double) 1000000;
+ }
+
+ }
+
+ }
+
+ public synchronized long getRawAnalysisTime() {
+ if (controller != null) {
+ return controller.getAnalysisTime();
+ } else {
+ synchronized (sem) {
return analysisTime;
}
}
- }
+ }
+
+ public long getNumberOfCASesProcessed() {
+ return numberOfCASesProcessed;
+ }
+
+ public synchronized void incrementNumberOfCASesProcessed() {
+ numberOfCASesProcessed++;
+ }
+
+ public synchronized double getCasDeserializationTime() {
+ if (casDeserializationTime > 0) {
+ return ((double) casDeserializationTime / (double) 1000000);
+ }
+ return 0.0;
+ }
+
+ public synchronized long getRawCasDeserializationTime() {
+ return casDeserializationTime;
+ }
+
+ public synchronized void incrementCasDeserializationTime(long aCasDeserializationTime) {
+ if (maxDeserializationTime < aCasDeserializationTime) {
+ maxDeserializationTime = aCasDeserializationTime;
+ }
+ casDeserializationTime += aCasDeserializationTime;
+ }
+
+ public double getCasSerializationTime() {
+ return ((double) casSerializationTime / (double) 1000000);
+ }
+
+ public long getRawCasSerializationTime() {
+ return casSerializationTime;
+ }
+
+ public synchronized void incrementCasSerializationTime(long casSerializationTime) {
+ if (maxSerializationTime < casSerializationTime) {
+ maxSerializationTime = casSerializationTime;
+ }
+ this.casSerializationTime += casSerializationTime;
+ }
+
+ public double getMaxSerializationTime() {
+ return (double) maxSerializationTime / (double) 1000000;
+ }
+
+ public double getMaxDeserializationTime() {
+ return (double) maxDeserializationTime / (double) 1000000;
+ }
+
+ public double getMaxAnalysisTime() {
+ return (double) maxAnalysisTime / (double) 1000000;
+ }
+
+ public void incrementCasPoolWaitTime(long aCasPoolsWaitTime) {
+ synchronized (sem) {
+ casPoolWaitTime += aCasPoolsWaitTime;
+ }
+ }
+
+ public double getCasPoolWaitTime() {
+ synchronized (sem) {
+ if (controller != null) {
+ return (double) getTimeWaitingForCAS() / (double) 1000000;
+ } else {
+ return (double) casPoolWaitTime / (double) 1000000;
+ }
+ }
+ }
- public long getNumberOfCASesProcessed()
- {
- return numberOfCASesProcessed;
- }
-
- public synchronized void incrementNumberOfCASesProcessed()
- {
- numberOfCASesProcessed++;
- }
-
- public synchronized double getCasDeserializationTime()
- {
- if ( casDeserializationTime > 0 )
- {
- return ((double)casDeserializationTime/(double) 1000000);
- }
- return 0.0;
- }
- public synchronized long getRawCasDeserializationTime()
- {
- return casDeserializationTime;
- }
- public synchronized void incrementCasDeserializationTime(long aCasDeserializationTime)
- {
- if ( maxDeserializationTime < aCasDeserializationTime )
- {
- maxDeserializationTime = aCasDeserializationTime;
- }
- casDeserializationTime += aCasDeserializationTime;
- }
- public double getCasSerializationTime()
- {
- return ((double)casSerializationTime/(double) 1000000);
- }
- public long getRawCasSerializationTime()
- {
- return casSerializationTime;
- }
- public synchronized void incrementCasSerializationTime(long casSerializationTime)
- {
- if ( maxSerializationTime < casSerializationTime )
- {
- maxSerializationTime = casSerializationTime;
- }
- this.casSerializationTime += casSerializationTime;
- }
-
- public double getMaxSerializationTime()
- {
- return (double)maxSerializationTime/(double)1000000;
- }
- public double getMaxDeserializationTime()
- {
- return (double)maxDeserializationTime/(double)1000000;
- }
-
- public double getMaxAnalysisTime()
- {
- return (double)maxAnalysisTime / (double)1000000;
- }
- public void incrementCasPoolWaitTime(long aCasPoolsWaitTime )
- {
- synchronized (sem )
- {
- casPoolWaitTime += aCasPoolsWaitTime;
- }
- }
- public double getCasPoolWaitTime()
- {
- synchronized (sem )
- {
- if ( controller != null ) {
- return (double)getTimeWaitingForCAS()/(double)1000000;
- } else {
- return (double)casPoolWaitTime/(double)1000000;
- }
- }
- }
- public long getRawCasPoolWaitTime()
- {
- synchronized (sem )
- {
+ public long getRawCasPoolWaitTime() {
+ synchronized (sem) {
return casPoolWaitTime;
}
}
- public double getShadowCasPoolWaitTime()
- {
- return ((double)getTimeWaitingForShadowPoolCAS()/(double) 1000000);
- }
-
- public double getTimeSpentInCMGetNext()
- {
- // Force update of the wait time
- return ((double)getTimeWaitingInGetNext()/(double) 1000000);
- }
-
- public void beginWaitOnCASPool()
- {
- synchronized( waitmux )
- {
- if ( !waitingForCAS )
- {
- waitingForCAS = true;
- lastCASWaitTimeUpdate = System.nanoTime();
- }
- }
- }
- public void endWaitOnCASPool()
- {
- synchronized( waitmux )
- {
- long delta= (System.nanoTime() - lastCASWaitTimeUpdate);
- totalWaitTimeForCAS += delta;
- waitingForCAS = false;
- }
- }
-
-
-
- public long getTimeWaitingForCAS()
- {
- synchronized( waitmux )
- {
- long now = System.nanoTime();
- if ( waitingForCAS )
- {
- long delta= (System.nanoTime() - lastCASWaitTimeUpdate);
- totalWaitTimeForCAS += delta;
- lastCASWaitTimeUpdate = now;
- }
- return totalWaitTimeForCAS;
- }
- }
-
-
-
- public void beginWaitOnShadowCASPool()
- {
- synchronized( shadowPoolMux )
- {
- if ( !waitingForSPCAS )
- {
- waitingForSPCAS = true;
- lastSPCASWaitTimeUpdate = System.nanoTime();
- }
- }
- }
- public void endWaitOnShadowCASPool()
- {
- synchronized( shadowPoolMux )
- {
- long delta= (System.nanoTime() - lastSPCASWaitTimeUpdate);
- shadowCasPoolWaitTime += delta;
- waitingForSPCAS = false;
- }
- }
-
- public long getTimeWaitingForShadowPoolCAS()
- {
- synchronized( shadowPoolMux )
- {
- long now = System.nanoTime();
- if ( waitingForSPCAS )
- {
- long delta= (System.nanoTime() - lastSPCASWaitTimeUpdate);
- shadowCasPoolWaitTime += delta;
- lastSPCASWaitTimeUpdate = now;
- }
- return shadowCasPoolWaitTime;
- }
-
- }
-
-
- public void beginGetNextWait()
- {
- synchronized( getNextMux )
- {
- if ( !waitingInGetNext )
- {
- waitingInGetNext = true;
- lastGetNextWaitTimeUpdate = System.nanoTime();
- }
- else
- {
-
- }
- }
- }
- public void endGetNextWait()
- {
- synchronized( getNextMux )
- {
- long delta= (System.nanoTime() - lastGetNextWaitTimeUpdate);
- totalGetNextWaitTime += delta;
- waitingInGetNext = false;
- }
- }
-
- public long getTimeWaitingInGetNext()
- {
- synchronized( getNextMux )
- {
- long now = System.nanoTime();
- if ( waitingInGetNext )
- {
- long delta= (System.nanoTime() - lastGetNextWaitTimeUpdate);
- totalGetNextWaitTime += delta;
- lastGetNextWaitTimeUpdate = now;
- }
- return totalGetNextWaitTime;
- }
-
- }
-
- public int getProcessThreadCount() {
- return processThreadCount;
- }
-
- public void setProcessThreadCount(int processThreadCount) {
- this.processThreadCount = processThreadCount;
- }
-
-
-
+
+ public double getShadowCasPoolWaitTime() {
+ return ((double) getTimeWaitingForShadowPoolCAS() / (double) 1000000);
+ }
+
+ public double getTimeSpentInCMGetNext() {
+ // Force update of the wait time
+ return ((double) getTimeWaitingInGetNext() / (double) 1000000);
+ }
+
+ public void beginWaitOnCASPool() {
+ synchronized (waitmux) {
+ if (!waitingForCAS) {
+ waitingForCAS = true;
+ lastCASWaitTimeUpdate = System.nanoTime();
+ }
+ }
+ }
+
+ public void endWaitOnCASPool() {
+ synchronized (waitmux) {
+ long delta = (System.nanoTime() - lastCASWaitTimeUpdate);
+ totalWaitTimeForCAS += delta;
+ waitingForCAS = false;
+ }
+ }
+
+ public long getTimeWaitingForCAS() {
+ synchronized (waitmux) {
+ long now = System.nanoTime();
+ if (waitingForCAS) {
+ long delta = (System.nanoTime() - lastCASWaitTimeUpdate);
+ totalWaitTimeForCAS += delta;
+ lastCASWaitTimeUpdate = now;
+ }
+ return totalWaitTimeForCAS;
+ }
+ }
+
+ public void beginWaitOnShadowCASPool() {
+ synchronized (shadowPoolMux) {
+ if (!waitingForSPCAS) {
+ waitingForSPCAS = true;
+ lastSPCASWaitTimeUpdate = System.nanoTime();
+ }
+ }
+ }
+
+ public void endWaitOnShadowCASPool() {
+ synchronized (shadowPoolMux) {
+ long delta = (System.nanoTime() - lastSPCASWaitTimeUpdate);
+ shadowCasPoolWaitTime += delta;
+ waitingForSPCAS = false;
+ }
+ }
+
+ public long getTimeWaitingForShadowPoolCAS() {
+ synchronized (shadowPoolMux) {
+ long now = System.nanoTime();
+ if (waitingForSPCAS) {
+ long delta = (System.nanoTime() - lastSPCASWaitTimeUpdate);
+ shadowCasPoolWaitTime += delta;
+ lastSPCASWaitTimeUpdate = now;
+ }
+ return shadowCasPoolWaitTime;
+ }
+
+ }
+
+ public void beginGetNextWait() {
+ synchronized (getNextMux) {
+ if (!waitingInGetNext) {
+ waitingInGetNext = true;
+ lastGetNextWaitTimeUpdate = System.nanoTime();
+ } else {
+
+ }
+ }
+ }
+
+ public void endGetNextWait() {
+ synchronized (getNextMux) {
+ long delta = (System.nanoTime() - lastGetNextWaitTimeUpdate);
+ totalGetNextWaitTime += delta;
+ waitingInGetNext = false;
+ }
+ }
+
+ public long getTimeWaitingInGetNext() {
+ synchronized (getNextMux) {
+ long now = System.nanoTime();
+ if (waitingInGetNext) {
+ long delta = (System.nanoTime() - lastGetNextWaitTimeUpdate);
+ totalGetNextWaitTime += delta;
+ lastGetNextWaitTimeUpdate = now;
+ }
+ return totalGetNextWaitTime;
+ }
+
+ }
+
+ public int getProcessThreadCount() {
+ return processThreadCount;
+ }
+
+ public void setProcessThreadCount(int processThreadCount) {
+ this.processThreadCount = processThreadCount;
+ }
+
}
Modified: incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformanceMBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformanceMBean.java?rev=810560&r1=810559&r2=810560&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformanceMBean.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/ServicePerformanceMBean.java Wed Sep 2 15:23:59 2009
@@ -21,19 +21,24 @@
import java.io.Serializable;
+public interface ServicePerformanceMBean extends Serializable {
+ public double getIdleTime();
-public interface ServicePerformanceMBean extends Serializable
-{
- public double getIdleTime();
-
- public void reset();
-
- public long getNumberOfCASesProcessed();
- public double getCasDeserializationTime();
- public double getCasSerializationTime();
- public double getAnalysisTime();
- public double getCasPoolWaitTime();
- public double getShadowCasPoolWaitTime();
- public double getTimeSpentInCMGetNext();
- public int getProcessThreadCount();
+ public void reset();
+
+ public long getNumberOfCASesProcessed();
+
+ public double getCasDeserializationTime();
+
+ public double getCasSerializationTime();
+
+ public double getAnalysisTime();
+
+ public double getCasPoolWaitTime();
+
+ public double getShadowCasPoolWaitTime();
+
+ public double getTimeSpentInCMGetNext();
+
+ public int getProcessThreadCount();
}
Modified: incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java?rev=810560&r1=810559&r2=810560&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java Wed Sep 2 15:23:59 2009
@@ -23,312 +23,323 @@
/**
* This class exposes client side statistics via JMX
- *
+ *
*/
-public class UimaASClientInfo implements
- UimaASClientInfoMBean {
+public class UimaASClientInfo implements UimaASClientInfoMBean {
-
- private String applicationName;
- private long idleTime;
- private long serializationTime;
- private long deserializationTime;
- private long totalCasesProcessed;
- private long totalCasesRequested;
- private long totalProcessTime;
- private long totalTimeWaitingForReply;
- private long totalResponseLatencyTime;
- private long totalTimeWaitingForCas;
- private long maxSerializationTime;
- private long maxDeserializationTime;
- private long maxIdleTime;
- private long maxProcessTime;
- private long maxTimeWaitingForReply;
- private long maxResponseLatencyTime;
- private long maxTimeWaitingForCas;
- private String endpointName;
- private int replyWindowSize;
- private int casPoolSize;
- private long _metaTimeoutErrorCount;
- private long _processTimeoutErrorCount;
- private long _processErrorCount;
- private long _metaErrorCount;
-
- public synchronized void reset()
- {
- idleTime = 0;
- serializationTime=0;
- deserializationTime=0;
- totalCasesProcessed=0;
- totalCasesRequested=0;
- totalProcessTime=0;
- totalTimeWaitingForReply=0;
- totalResponseLatencyTime=0;
- totalTimeWaitingForCas=0;
- maxSerializationTime=0;
- maxDeserializationTime=0;
- maxIdleTime=0;
- maxProcessTime=0;
- maxTimeWaitingForReply=0;
- maxResponseLatencyTime=0;
- maxTimeWaitingForCas=0;
- _metaTimeoutErrorCount=0;
- _processTimeoutErrorCount=0;
- _processErrorCount=0;
- _metaErrorCount=0;
- }
- public synchronized long getMetaErrorCount()
- {
- return _metaErrorCount;
- }
- public synchronized void incrementMetaErrorCount()
- {
- _metaErrorCount++;
- }
+ private String applicationName;
- public synchronized long getMetaTimeoutErrorCount() {
- return _metaTimeoutErrorCount;
- }
-
- public synchronized void incrementMetaTimeoutErrorCount() {
- _metaTimeoutErrorCount++;
- }
-
- public synchronized long getProcessTimeoutErrorCount() {
- return _processTimeoutErrorCount;
- }
-
- public synchronized void incrementProcessTimeoutErrorCount() {
- _processTimeoutErrorCount++;
- }
-
- public synchronized long getProcessErrorCount() {
- return _processErrorCount;
- }
-
- public synchronized void incrementProcessErrorCount() {
- _processErrorCount++;
- }
-
- public String getEndpointName() {
- return endpointName;
- }
-
- public void setEndpointName(String endpointName) {
- this.endpointName = endpointName;
- }
-
- public int getReplyWindowSize() {
- return replyWindowSize;
- }
-
- public void setReplyWindowSize(int replyWindowSize) {
- this.replyWindowSize = replyWindowSize;
- }
-
- public int getCasPoolSize() {
- return casPoolSize;
- }
-
- public void setCasPoolSize(int casPoolSize) {
- this.casPoolSize = casPoolSize;
- }
-
- public UimaASClientInfo()
- {
-
- }
-
- public String getApplicationName() {
- return applicationName;
- }
-
- private String format(double aValue )
- {
- return String.format("%,.2f ms", aValue);
- }
- public synchronized String getAverageDeserializationTime() {
- if ( totalCasesProcessed > 0 )
- {
- double floatValue = (double)((double)deserializationTime/(double)totalCasesProcessed)/(double)1000000;
- return format(floatValue);
- }
- else
- return "0.0";
- }
-
- public synchronized String getAverageIdleTime() {
- if ( totalCasesProcessed > 0 )
- {
- double floatValue = (double)((double)idleTime/(double)totalCasesProcessed)/(double)1000000;
- return format(floatValue);
- }
- else
- return "0.0";
- }
-
- public synchronized String getAverageSerializationTime() {
- if ( totalCasesProcessed > 0 )
- {
- double floatValue = (double)((double)serializationTime/(double)totalCasesProcessed)/(double)1000000;
- return format(floatValue);
- }
- else
- return "0.0";
- }
-
- public synchronized String getAverageTimeToProcessCas() {
- if ( totalCasesProcessed > 0 )
- {
- double floatValue = (double)((double)totalProcessTime/(double)totalCasesProcessed)/(double)1000000;
- return format(floatValue);
- }
- else
- return "0.0";
- }
-
- public synchronized String getAverageTimeWaitingForReply() {
- return ( totalCasesProcessed > 0 ) ?
- format(((double)totalTimeWaitingForReply/(double)totalCasesProcessed)/(double)1000000)
- : "0.0";
- }
-
- public synchronized String getAverageResponseLatencyTime() {
- return ( totalCasesProcessed > 0 ) ?
- format(((double)totalResponseLatencyTime/(double)totalCasesProcessed)/(double)1000000)
- : "0.0";
- }
+ private long idleTime;
- public synchronized String getAverageTimeWaitingForCas() {
- return ( totalCasesRequested > 0 ) ?
- format(((double)totalTimeWaitingForCas/(double)totalCasesRequested)/(double)1000000)
- : "0.0";
- }
-
- public synchronized String getMaxDeserializationTime() {
- return format((double)maxDeserializationTime/(double)1000000);
- }
-
- public synchronized String getMaxIdleTime() {
- return format((double)maxIdleTime/(double)1000000);
- }
-
- public synchronized String getMaxProcessTime() {
- return format((double)maxProcessTime/(double)1000000);
- }
-
- public synchronized String getMaxSerializationTime() {
- return format((double)maxSerializationTime/(double)1000000);
- }
+ private long serializationTime;
- public synchronized String getMaxTimeWaitingForReply() {
- return format((double)maxTimeWaitingForReply/(double)1000000);
- }
-
- public synchronized String getMaxResponseLatencyTime() {
- return format((double)maxResponseLatencyTime/(double)1000000);
- }
+ private long deserializationTime;
- public synchronized String getMaxTimeWaitingForCas() {
- return format((double)maxTimeWaitingForCas/(double)1000000);
- }
-
- public synchronized String getTotalDeserializationTime() {
- return format((double)deserializationTime/(double)1000000);
- }
-
- public synchronized String getTotalIdleTime() {
- return format((double)idleTime/(double)1000000);
- }
-
- public synchronized long getTotalNumberOfCasesProcessed() {
- return totalCasesProcessed;
- }
+ private long totalCasesProcessed;
+
+ private long totalCasesRequested;
+
+ private long totalProcessTime;
+
+ private long totalTimeWaitingForReply;
+
+ private long totalResponseLatencyTime;
+
+ private long totalTimeWaitingForCas;
+
+ private long maxSerializationTime;
+
+ private long maxDeserializationTime;
+
+ private long maxIdleTime;
+
+ private long maxProcessTime;
+
+ private long maxTimeWaitingForReply;
+
+ private long maxResponseLatencyTime;
+
+ private long maxTimeWaitingForCas;
+
+ private String endpointName;
+
+ private int replyWindowSize;
+
+ private int casPoolSize;
+
+ private long _metaTimeoutErrorCount;
+
+ private long _processTimeoutErrorCount;
+
+ private long _processErrorCount;
+
+ private long _metaErrorCount;
+
+ public synchronized void reset() {
+ idleTime = 0;
+ serializationTime = 0;
+ deserializationTime = 0;
+ totalCasesProcessed = 0;
+ totalCasesRequested = 0;
+ totalProcessTime = 0;
+ totalTimeWaitingForReply = 0;
+ totalResponseLatencyTime = 0;
+ totalTimeWaitingForCas = 0;
+ maxSerializationTime = 0;
+ maxDeserializationTime = 0;
+ maxIdleTime = 0;
+ maxProcessTime = 0;
+ maxTimeWaitingForReply = 0;
+ maxResponseLatencyTime = 0;
+ maxTimeWaitingForCas = 0;
+ _metaTimeoutErrorCount = 0;
+ _processTimeoutErrorCount = 0;
+ _processErrorCount = 0;
+ _metaErrorCount = 0;
+ }
+
+ public synchronized long getMetaErrorCount() {
+ return _metaErrorCount;
+ }
+
+ public synchronized void incrementMetaErrorCount() {
+ _metaErrorCount++;
+ }
+
+ public synchronized long getMetaTimeoutErrorCount() {
+ return _metaTimeoutErrorCount;
+ }
+
+ public synchronized void incrementMetaTimeoutErrorCount() {
+ _metaTimeoutErrorCount++;
+ }
+
+ public synchronized long getProcessTimeoutErrorCount() {
+ return _processTimeoutErrorCount;
+ }
+
+ public synchronized void incrementProcessTimeoutErrorCount() {
+ _processTimeoutErrorCount++;
+ }
+
+ public synchronized long getProcessErrorCount() {
+ return _processErrorCount;
+ }
+
+ public synchronized void incrementProcessErrorCount() {
+ _processErrorCount++;
+ }
+
+ public String getEndpointName() {
+ return endpointName;
+ }
+
+ public void setEndpointName(String endpointName) {
+ this.endpointName = endpointName;
+ }
- public synchronized long getTotalNumberOfCasesRequested() {
- return totalCasesRequested;
+ public int getReplyWindowSize() {
+ return replyWindowSize;
+ }
+
+ public void setReplyWindowSize(int replyWindowSize) {
+ this.replyWindowSize = replyWindowSize;
+ }
+
+ public int getCasPoolSize() {
+ return casPoolSize;
+ }
+
+ public void setCasPoolSize(int casPoolSize) {
+ this.casPoolSize = casPoolSize;
+ }
+
+ public UimaASClientInfo() {
+
+ }
+
+ public String getApplicationName() {
+ return applicationName;
+ }
+
+ private String format(double aValue) {
+ return String.format("%,.2f ms", aValue);
+ }
+
+ public synchronized String getAverageDeserializationTime() {
+ if (totalCasesProcessed > 0) {
+ double floatValue = (double) ((double) deserializationTime / (double) totalCasesProcessed)
+ / (double) 1000000;
+ return format(floatValue);
+ } else
+ return "0.0";
+ }
+
+ public synchronized String getAverageIdleTime() {
+ if (totalCasesProcessed > 0) {
+ double floatValue = (double) ((double) idleTime / (double) totalCasesProcessed)
+ / (double) 1000000;
+ return format(floatValue);
+ } else
+ return "0.0";
+ }
+
+ public synchronized String getAverageSerializationTime() {
+ if (totalCasesProcessed > 0) {
+ double floatValue = (double) ((double) serializationTime / (double) totalCasesProcessed)
+ / (double) 1000000;
+ return format(floatValue);
+ } else
+ return "0.0";
+ }
+
+ public synchronized String getAverageTimeToProcessCas() {
+ if (totalCasesProcessed > 0) {
+ double floatValue = (double) ((double) totalProcessTime / (double) totalCasesProcessed)
+ / (double) 1000000;
+ return format(floatValue);
+ } else
+ return "0.0";
+ }
+
+ public synchronized String getAverageTimeWaitingForReply() {
+ return (totalCasesProcessed > 0) ? format(((double) totalTimeWaitingForReply / (double) totalCasesProcessed)
+ / (double) 1000000)
+ : "0.0";
+ }
+
+ public synchronized String getAverageResponseLatencyTime() {
+ return (totalCasesProcessed > 0) ? format(((double) totalResponseLatencyTime / (double) totalCasesProcessed)
+ / (double) 1000000)
+ : "0.0";
+ }
+
+ public synchronized String getAverageTimeWaitingForCas() {
+ return (totalCasesRequested > 0) ? format(((double) totalTimeWaitingForCas / (double) totalCasesRequested)
+ / (double) 1000000)
+ : "0.0";
+ }
+
+ public synchronized String getMaxDeserializationTime() {
+ return format((double) maxDeserializationTime / (double) 1000000);
+ }
+
+ public synchronized String getMaxIdleTime() {
+ return format((double) maxIdleTime / (double) 1000000);
+ }
+
+ public synchronized String getMaxProcessTime() {
+ return format((double) maxProcessTime / (double) 1000000);
+ }
+
+ public synchronized String getMaxSerializationTime() {
+ return format((double) maxSerializationTime / (double) 1000000);
+ }
+
+ public synchronized String getMaxTimeWaitingForReply() {
+ return format((double) maxTimeWaitingForReply / (double) 1000000);
+ }
+
+ public synchronized String getMaxResponseLatencyTime() {
+ return format((double) maxResponseLatencyTime / (double) 1000000);
+ }
+
+ public synchronized String getMaxTimeWaitingForCas() {
+ return format((double) maxTimeWaitingForCas / (double) 1000000);
+ }
+
+ public synchronized String getTotalDeserializationTime() {
+ return format((double) deserializationTime / (double) 1000000);
+ }
+
+ public synchronized String getTotalIdleTime() {
+ return format((double) idleTime / (double) 1000000);
+ }
+
+ public synchronized long getTotalNumberOfCasesProcessed() {
+ return totalCasesProcessed;
+ }
+
+ public synchronized long getTotalNumberOfCasesRequested() {
+ return totalCasesRequested;
+ }
+
+ public synchronized String getTotalSerializationTime() {
+ return format((double) serializationTime / (double) 1000000);
+ }
+
+ public synchronized String getTotalTimeToProcess() {
+ return format((double) totalProcessTime / (double) 1000000);
+ }
+
+ public synchronized String getTotalTimeWaitingForReply() {
+ return format((double) totalTimeWaitingForReply / (double) 1000000);
+ }
+
+ public synchronized String getTotalResponseLatencyTime() {
+ return format((double) totalResponseLatencyTime / (double) 1000000);
+ }
+
+ public synchronized String getTotalTimeWaitingForCas() {
+ return format((double) totalTimeWaitingForCas / (double) 1000000);
+ }
+
+ public void setApplicationName(String anApplicationName) {
+ applicationName = anApplicationName;
+ }
+
+ public synchronized void incrementTotalIdleTime(long anIdleTime) {
+ if (maxIdleTime < anIdleTime) {
+ maxIdleTime = anIdleTime;
}
+ idleTime += anIdleTime;
+ }
+
+ public synchronized void incrementTotalNumberOfCasesProcessed() {
+ totalCasesProcessed++;
+ }
- public synchronized String getTotalSerializationTime() {
- return format((double)serializationTime/(double)1000000);
- }
-
- public synchronized String getTotalTimeToProcess() {
- return format((double)totalProcessTime/(double)1000000);
- }
+ public synchronized void incrementTotalSerializationTime(long aSerializationTime) {
- public synchronized String getTotalTimeWaitingForReply() {
- return format((double)totalTimeWaitingForReply/(double)1000000);
+ if (maxSerializationTime < aSerializationTime) {
+ maxSerializationTime = aSerializationTime;
}
-
- public synchronized String getTotalResponseLatencyTime() {
- return format((double)totalResponseLatencyTime/(double)1000000);
+ serializationTime += aSerializationTime;
+ }
+
+ public synchronized void incrementTotalTimeToProcess(long aTimeToProcess) {
+ if (maxProcessTime < aTimeToProcess) {
+ maxProcessTime = aTimeToProcess;
}
+ totalProcessTime += aTimeToProcess;
+ }
- public synchronized String getTotalTimeWaitingForCas() {
- return format((double)totalTimeWaitingForCas/(double)1000000);
+ public synchronized void incrementTotalDeserializationTime(long aDeserializationTime) {
+ if (maxDeserializationTime < aDeserializationTime) {
+ maxDeserializationTime = aDeserializationTime;
}
-
- public void setApplicationName(String anApplicationName) {
- applicationName = anApplicationName;
- }
-
- public synchronized void incrementTotalIdleTime(long anIdleTime) {
- if ( maxIdleTime < anIdleTime )
- {
- maxIdleTime = anIdleTime;
- }
- idleTime += anIdleTime;
- }
-
- public synchronized void incrementTotalNumberOfCasesProcessed() {
- totalCasesProcessed++;
- }
-
- public synchronized void incrementTotalSerializationTime(long aSerializationTime) {
-
- if ( maxSerializationTime < aSerializationTime )
- {
- maxSerializationTime = aSerializationTime;
- }
- serializationTime += aSerializationTime;
- }
-
- public synchronized void incrementTotalTimeToProcess(long aTimeToProcess) {
- if ( maxProcessTime < aTimeToProcess )
- {
- maxProcessTime = aTimeToProcess;
- }
- totalProcessTime += aTimeToProcess;
- }
-
- public synchronized void incrementTotalDeserializationTime(long aDeserializationTime) {
- if ( maxDeserializationTime < aDeserializationTime )
- {
- maxDeserializationTime = aDeserializationTime;
- }
- deserializationTime += aDeserializationTime;
- }
- public synchronized void incrementTotalTimeWaitingForReply( long aTimeWaitingForReply ) {
- if ( maxTimeWaitingForReply < aTimeWaitingForReply )
- {
- maxTimeWaitingForReply = aTimeWaitingForReply;
- }
- totalTimeWaitingForReply += aTimeWaitingForReply;
+ deserializationTime += aDeserializationTime;
+ }
+
+ public synchronized void incrementTotalTimeWaitingForReply(long aTimeWaitingForReply) {
+ if (maxTimeWaitingForReply < aTimeWaitingForReply) {
+ maxTimeWaitingForReply = aTimeWaitingForReply;
}
- public synchronized void incrementTotalResponseLatencyTime( long aResponseLatencyTime ) {
- if ( maxResponseLatencyTime < aResponseLatencyTime )
- {
- maxResponseLatencyTime = aResponseLatencyTime;
- }
- totalResponseLatencyTime += aResponseLatencyTime;
+ totalTimeWaitingForReply += aTimeWaitingForReply;
+ }
+
+ public synchronized void incrementTotalResponseLatencyTime(long aResponseLatencyTime) {
+ if (maxResponseLatencyTime < aResponseLatencyTime) {
+ maxResponseLatencyTime = aResponseLatencyTime;
}
- public synchronized void incrementTotalTimeWaitingForCas( long aTimeWaitingForCas ) {
- totalCasesRequested++;
- if ( maxTimeWaitingForCas < aTimeWaitingForCas )
- {
- maxTimeWaitingForCas = aTimeWaitingForCas;
- }
- totalTimeWaitingForCas += aTimeWaitingForCas;
+ totalResponseLatencyTime += aResponseLatencyTime;
+ }
+
+ public synchronized void incrementTotalTimeWaitingForCas(long aTimeWaitingForCas) {
+ totalCasesRequested++;
+ if (maxTimeWaitingForCas < aTimeWaitingForCas) {
+ maxTimeWaitingForCas = aTimeWaitingForCas;
}
+ totalTimeWaitingForCas += aTimeWaitingForCas;
+ }
}
Modified: incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java?rev=810560&r1=810559&r2=810560&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java Wed Sep 2 15:23:59 2009
@@ -21,69 +21,99 @@
public interface UimaASClientInfoMBean {
- public void setApplicationName( String anApplicationName );
- public String getApplicationName();
+ public void setApplicationName(String anApplicationName);
- public void incrementTotalNumberOfCasesProcessed();
- public long getTotalNumberOfCasesProcessed();
-
- public String getEndpointName();
- public void setEndpointName(String endpointName);
-
- public int getReplyWindowSize();
- public void setReplyWindowSize(int replyWindowSize);
-
- public int getCasPoolSize();
- public void setCasPoolSize(int casPoolSize);
-
-
- public void incrementTotalTimeToProcess( long aTotalTimeToProcess );
- public String getTotalTimeToProcess();
- public String getAverageTimeToProcessCas();
- public String getMaxProcessTime();
-
- public void incrementTotalSerializationTime( long aTotalSerializationTime );
- public String getTotalSerializationTime();
- public String getAverageSerializationTime();
- public String getMaxSerializationTime();
-
- public void incrementTotalDeserializationTime( long aTotalDeserializationTime );
- public String getTotalDeserializationTime();
- public String getAverageDeserializationTime();
- public String getMaxDeserializationTime();
-
- public void incrementTotalIdleTime( long aTotalIdleTime );
- public String getTotalIdleTime();
- public String getAverageIdleTime();
- public String getMaxIdleTime();
-
- public void incrementTotalTimeWaitingForReply( long aTimeWaitingForReply );
- public String getTotalTimeWaitingForReply();
- public String getAverageTimeWaitingForReply();
- public String getMaxTimeWaitingForReply();
-
- public void incrementTotalResponseLatencyTime( long aResponseLatencyTime );
- public String getTotalResponseLatencyTime();
- public String getAverageResponseLatencyTime();
- public String getMaxResponseLatencyTime();
-
- public void incrementTotalTimeWaitingForCas( long aTimeWaitingForCas );
- public long getTotalNumberOfCasesRequested();
- public String getTotalTimeWaitingForCas();
- public String getAverageTimeWaitingForCas();
- public String getMaxTimeWaitingForCas();
-
- public long getMetaTimeoutErrorCount();
- public void incrementMetaTimeoutErrorCount();
-
- public long getProcessTimeoutErrorCount();
- public void incrementProcessTimeoutErrorCount();
-
- public long getProcessErrorCount();
- public void incrementProcessErrorCount();
-
- public long getMetaErrorCount();
- public void incrementMetaErrorCount();
+ public String getApplicationName();
- public void reset();
+ public void incrementTotalNumberOfCasesProcessed();
+
+ public long getTotalNumberOfCasesProcessed();
+
+ public String getEndpointName();
+
+ public void setEndpointName(String endpointName);
+
+ public int getReplyWindowSize();
+
+ public void setReplyWindowSize(int replyWindowSize);
+
+ public int getCasPoolSize();
+
+ public void setCasPoolSize(int casPoolSize);
+
+ public void incrementTotalTimeToProcess(long aTotalTimeToProcess);
+
+ public String getTotalTimeToProcess();
+
+ public String getAverageTimeToProcessCas();
+
+ public String getMaxProcessTime();
+
+ public void incrementTotalSerializationTime(long aTotalSerializationTime);
+
+ public String getTotalSerializationTime();
+
+ public String getAverageSerializationTime();
+
+ public String getMaxSerializationTime();
+
+ public void incrementTotalDeserializationTime(long aTotalDeserializationTime);
+
+ public String getTotalDeserializationTime();
+
+ public String getAverageDeserializationTime();
+
+ public String getMaxDeserializationTime();
+
+ public void incrementTotalIdleTime(long aTotalIdleTime);
+
+ public String getTotalIdleTime();
+
+ public String getAverageIdleTime();
+
+ public String getMaxIdleTime();
+
+ public void incrementTotalTimeWaitingForReply(long aTimeWaitingForReply);
+
+ public String getTotalTimeWaitingForReply();
+
+ public String getAverageTimeWaitingForReply();
+
+ public String getMaxTimeWaitingForReply();
+
+ public void incrementTotalResponseLatencyTime(long aResponseLatencyTime);
+
+ public String getTotalResponseLatencyTime();
+
+ public String getAverageResponseLatencyTime();
+
+ public String getMaxResponseLatencyTime();
+
+ public void incrementTotalTimeWaitingForCas(long aTimeWaitingForCas);
+
+ public long getTotalNumberOfCasesRequested();
+
+ public String getTotalTimeWaitingForCas();
+
+ public String getAverageTimeWaitingForCas();
+
+ public String getMaxTimeWaitingForCas();
+
+ public long getMetaTimeoutErrorCount();
+
+ public void incrementMetaTimeoutErrorCount();
+
+ public long getProcessTimeoutErrorCount();
+
+ public void incrementProcessTimeoutErrorCount();
+
+ public long getProcessErrorCount();
+
+ public void incrementProcessErrorCount();
+
+ public long getMetaErrorCount();
+
+ public void incrementMetaErrorCount();
+
+ public void reset();
}