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) {


Reply via email to