uima-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cwik...@apache.org
Subject svn commit: r1078842 - /uima/uima-as/trunk/uimaj-as-core/src/main/java/org/apache/uima/aae/controller/AggregateAnalysisEngineController_impl.java
Date Mon, 07 Mar 2011 16:34:08 GMT
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;



Mime
View raw message