You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2013/08/23 22:22:12 UTC
svn commit: r1517016 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/processors/DefaultNodeInventoryProcessor.java
Author: degenaro
Date: Fri Aug 23 20:22:12 2013
New Revision: 1517016
URL: http://svn.apache.org/r1517016
Log:
UIMA-3163 JP Time Run is too big
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/processors/DefaultNodeInventoryProcessor.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/processors/DefaultNodeInventoryProcessor.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/processors/DefaultNodeInventoryProcessor.java?rev=1517016&r1=1517015&r2=1517016&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/processors/DefaultNodeInventoryProcessor.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/processors/DefaultNodeInventoryProcessor.java Fri Aug 23 20:22:12 2013
@@ -113,6 +113,25 @@ public class DefaultNodeInventoryProcess
outgoingMessage.getIn().setBody(new NodeInventoryUpdateDuccEvent(inventory));
StringBuffer sb = new StringBuffer("Node Inventory ("+inventory.size()+")");
for( Map.Entry<DuccId, IDuccProcess> p : inventory.entrySet()) {
+ /*
+ long endInitLong = 0;
+ String endInit = "";
+ ITimeWindow wInit = p.getValue().getTimeWindowInit();
+ if(wInit != null) {
+ endInit = wInit.getEnd();
+ endInitLong = wInit.getEndLong();
+ }
+ long startRunLong = 0;
+ String startRun = "";
+ ITimeWindow wRun = p.getValue().getTimeWindowRun();
+ if(wRun != null) {
+ startRun = wRun.getStart();
+ startRunLong = wRun.getStartLong();
+ }
+ if(endInitLong > startRunLong) {
+ logger.warn(methodName, null, "endInit:"+endInitLong+" "+"startRun:"+startRunLong);
+ }
+ */
int pipelineInitStats = (p.getValue().getUimaPipelineComponents() == null ) ? 0 :
p.getValue().getUimaPipelineComponents().size();
sb.append("\n\t[Process Type=").
@@ -124,6 +143,8 @@ public class DefaultNodeInventoryProcess
append(" State=").append(p.getValue().getProcessState()).
append(" Resident Memory=").append(p.getValue().getResidentMemory()).
append(" Init Stats List Size:"+pipelineInitStats).
+ //append(" end init:"+endInit).
+ //append(" start run:"+startRun).
append("] ");
if ( p.getValue().getProcessState().equals(ProcessState.Stopped) ||
p.getValue().getProcessState().equals(ProcessState.Failed) ||