You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by ea...@apache.org on 2008/11/05 21:43:53 UTC
svn commit: r711692 - in
/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx:
UimaASClientInfo.java UimaASClientInfoMBean.java
Author: eae
Date: Wed Nov 5 12:43:53 2008
New Revision: 711692
URL: http://svn.apache.org/viewvc?rev=711692&view=rev
Log:
UIMA-1213 apply Lev's uima-1213_uimaj-as-core.patch and uima-1213_uimaj-as-jms.patch
Modified:
incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java
incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java?rev=711692&r1=711691&r2=711692&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfo.java Wed Nov 5 12:43:53 2008
@@ -34,15 +34,18 @@
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;
@@ -57,15 +60,18 @@
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;
@@ -198,7 +204,13 @@
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);
}
@@ -223,6 +235,10 @@
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);
}
@@ -235,6 +251,10 @@
return totalCasesProcessed;
}
+ public synchronized long getTotalNumberOfCasesRequested() {
+ return totalCasesRequested;
+ }
+
public synchronized String getTotalSerializationTime() {
return format((double)serializationTime/(double)1000000);
}
@@ -251,6 +271,10 @@
return format((double)totalResponseLatencyTime/(double)1000000);
}
+ public synchronized String getTotalTimeWaitingForCas() {
+ return format((double)totalTimeWaitingForCas/(double)1000000);
+ }
+
public void setApplicationName(String anApplicationName) {
applicationName = anApplicationName;
}
@@ -305,5 +329,12 @@
}
totalResponseLatencyTime += aResponseLatencyTime;
}
-
+ public synchronized void incrementTotalTimeWaitingForCas( long aTimeWaitingForCas ) {
+ totalCasesRequested++;
+ if ( maxTimeWaitingForCas < aTimeWaitingForCas )
+ {
+ maxTimeWaitingForCas = aTimeWaitingForCas;
+ }
+ totalTimeWaitingForCas += aTimeWaitingForCas;
+ }
}
Modified: incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java
URL: http://svn.apache.org/viewvc/incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java?rev=711692&r1=711691&r2=711692&view=diff
==============================================================================
--- incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java (original)
+++ incubator/uima/sandbox/trunk/uima-as/uimaj-as-core/src/main/java/org/apache/uima/aae/jmx/UimaASClientInfoMBean.java Wed Nov 5 12:43:53 2008
@@ -40,34 +40,39 @@
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 getMaxProcessTime();
- public String getMaxSerializationTime();
- public String getMaxDeserializationTime();
- public String getMaxIdleTime();
public String getMaxResponseLatencyTime();
- public String getMaxTimeWaitingForReply();
-
+
+ public void incrementTotalTimeWaitingForCas( long aTimeWaitingForCas );
+ public long getTotalNumberOfCasesRequested();
+ public String getTotalTimeWaitingForCas();
+ public String getAverageTimeWaitingForCas();
+ public String getMaxTimeWaitingForCas();
+
public long getMetaTimeoutErrorCount();
public void incrementMetaTimeoutErrorCount();