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 2019/05/08 17:59:24 UTC
svn commit: r1858936 -
/uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java
Author: cwiklik
Date: Wed May 8 17:59:23 2019
New Revision: 1858936
URL: http://svn.apache.org/viewvc?rev=1858936&view=rev
Log:
UIMA-6039 set init end time when JP reports initialization completed.
Modified:
uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java
Modified: uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java?rev=1858936&r1=1858935&r2=1858936&view=diff
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java (original)
+++ uima/uima-ducc/trunk/uima-ducc-agent/src/main/java/org/apache/uima/ducc/agent/NodeAgent.java Wed May 8 17:59:23 2019
@@ -1287,12 +1287,11 @@ public class NodeAgent extends AbstractD
processEntry.getValue().setProcessJmxUrl(duccEvent.getProcessJmxUrl());
}
ITimeWindow tw = processEntry.getValue().getTimeWindowInit();
- if (tw != null && tw.getEnd() == null ) {
- if ( !duccEvent.getState().equals(ProcessState.Initializing)) {
+ if (tw != null ) {
+ if ( !duccEvent.getState().equals(ProcessState.Initializing)) {
// Mark the time the process ended initialization. It also
// covers a case when the process terminates while initializing
tw.setEnd(TimeStamp.getCurrentMillis());
-
if ( duccEvent.getState().equals(ProcessState.Running)) {
ITimeWindow twr = new TimeWindow();
String millis;
@@ -1302,6 +1301,8 @@ public class NodeAgent extends AbstractD
twr.setStart(millis);
}
}
+ } else {
+ logger.info(methodName, null,"++++++++++++ Agent Init TimeWindow not available - tw==null");
}
ManagedProcess deployedProcess = null;
synchronized (monitor) {