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 2011/03/07 17:34:08 UTC
svn commit: r1078842 -
/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Author: cwiklik
Date: Mon Mar 7 16:34:08 2011
New Revision: 1078842
URL: http://svn.apache.org/viewvc?rev=1078842&view=rev
Log:
UIMA-2084 - modified dumpState()
Modified:
uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Modified: uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java?rev=1078842&r1=1078841&r2=1078842&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java (original)
+++ uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java Mon Mar 7 16:34:08 2011
@@ -3091,38 +3091,51 @@ public class AggregateAnalysisEngineCont
throw new Exception("Controller:"+getComponentName()+" Unable to change state of colocated delegate");
}
}
+
- public void dumpState() {
- StringBuffer remoteDelegates = new StringBuffer("------------ "+getComponentName()+" Remote Delegates:\n\t");
- StringBuffer colocatedDelegates = new StringBuffer("------------ "+getComponentName()+" Colocated Delegates:\n\t");
+ public void dumpState(StringBuffer buffer, String lbl1) {
+ StringBuffer delegates = new StringBuffer();
+ boolean first = false;
+ if ( buffer.length() == 0) {
+ first = true;
+ delegates.append("\n"+lbl1+getComponentName()+" Delegates:");
+ }
+ int remotes=0;
synchronized(destinationMap) {
Set set = destinationMap.entrySet();
for (Iterator it = set.iterator(); it.hasNext();) {
+ delegates.append("\n");
Map.Entry entry = (Map.Entry) it.next();
Endpoint endpoint = (Endpoint) entry.getValue();
if ( endpoint.isRemote() ) {
if ( endpoint.isInitialized() ) {
- remoteDelegates.append("Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.RUNNING);
+ delegates.append(lbl1+lbl1+"Remote Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.RUNNING);
} else {
- remoteDelegates.append("Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.INITIALIZING);
+ delegates.append(lbl1+lbl1+"Remote Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.INITIALIZING);
}
- remoteDelegates.append("\n\t");
} else {
if ( endpoint.isInitialized() ) {
- colocatedDelegates.append("Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.RUNNING);
+ delegates.append(lbl1+lbl1+"Co-located Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.RUNNING);
} else {
- colocatedDelegates.append("Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.INITIALIZING);
+ delegates.append(lbl1+lbl1+"Co-located Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.INITIALIZING);
+ }
+ synchronized(childControllerList) {
+ if ( childControllerList.size() > 0 ) {
+ for( AnalysisEngineController childController : childControllerList ) {
+ if ( endpoint.getDelegateKey().equals(childController.getKey()) && !childController.isPrimitive()) {
+ buffer.append(delegates.toString());
+ childController.dumpState(buffer,lbl1+lbl1);
+ delegates.setLength(0);
+ }
+ }
+ }
}
- colocatedDelegates.append("\n\t");
}
}
}
- UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(), "dumpState",
- UIMAEE_Constants.JMS_LOG_RESOURCE_BUNDLE, "UIMAEE_service_state__INFO",
- new Object[] { "\n"+remoteDelegates.toString()+"\n"+colocatedDelegates.toString()});
-
+ buffer.append(delegates.toString());
}
public LocalCache getLocalCache() {
return localCache;