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 18:52:08 UTC
svn commit: r1078866 -
/uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Author: cwiklik
Date: Mon Mar 7 17:52:08 2011
New Revision: 1078866
URL: http://svn.apache.org/viewvc?rev=1078866&view=rev
Log:
UIMA-2084 Cleaned up dumpState(). Removed redundant code.
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=1078866&r1=1078865&r2=1078866&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 17:52:08 2011
@@ -3096,30 +3096,28 @@ public class AggregateAnalysisEngineCont
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 all delegates ...
for (Iterator it = set.iterator(); it.hasNext();) {
delegates.append("\n");
Map.Entry entry = (Map.Entry) it.next();
Endpoint endpoint = (Endpoint) entry.getValue();
+ ServiceState state = ServiceState.INITIALIZING;
if ( endpoint.isRemote() ) {
if ( endpoint.isInitialized() ) {
- delegates.append(lbl1+lbl1+"Remote Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.RUNNING);
- } else {
- delegates.append(lbl1+lbl1+"Remote Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.INITIALIZING);
+ state = ServiceState.RUNNING;
}
+ delegates.append(lbl1+lbl1+"Remote Delegate:"+endpoint.getDelegateKey()+" State: "+state.toString());
} else {
if ( endpoint.isInitialized() ) {
- delegates.append(lbl1+lbl1+"Co-located Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.RUNNING);
- } else {
- delegates.append(lbl1+lbl1+"Co-located Delegate:"+endpoint.getDelegateKey()+" State: "+ServiceState.INITIALIZING);
+ state = ServiceState.RUNNING;
}
+ delegates.append(lbl1+lbl1+"Co-located Delegate:"+endpoint.getDelegateKey()+" State: "+state.toString());
+ // If a delegate is an aggregate, call its dumpState method
synchronized(childControllerList) {
if ( childControllerList.size() > 0 ) {
for( AnalysisEngineController childController : childControllerList ) {